Skip to content

Commit 8c67c8e

Browse files
committed
adding hash loading
1 parent f20a790 commit 8c67c8e

File tree

5 files changed

+73
-0
lines changed

5 files changed

+73
-0
lines changed

examples/gemfire/demo/cache.xml

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -36,4 +36,10 @@
3636
<value-constraint>redis.gemfire.Customer</value-constraint>
3737
</region-attributes>
3838
</region>
39+
<region name="hash">
40+
<region-attributes refid="PARTITION">
41+
<key-constraint>java.lang.String</key-constraint>
42+
<value-constraint>java.util.HashMap</value-constraint>
43+
</region-attributes>
44+
</region>
3945
</cache>
Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,4 @@
1+
source.username=
2+
source.password=
3+
ssl-keystore-password=
4+
ssl-truststore-password=
Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,4 @@
1+
target.username=
2+
target.password=
3+
target.truststore.password=
4+
target.keystore.password=
Lines changed: 48 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,48 @@
1+
{
2+
"partitions": 1,
3+
"maxPartitionsPerClusterMember": 1,
4+
"pipeline": {
5+
"stages": [
6+
{
7+
"index": 1,
8+
"stageName": "GEMFIRE_HASH_PREP_STAGE",
9+
"userDefinedType": "CUSTOM",
10+
"metricsEnabled": false
11+
},
12+
{
13+
"database": {
14+
"credentialsDirectoryPath" : "/opt/redislabs/redis-connect/config/samples/credentials",
15+
"databaseURL": "redis://127.0.0.1:14000",
16+
"databaseType": "REDIS",
17+
"customConfiguration": {
18+
"redis.connection.sslEnabled": false,
19+
"truststore": "/opt/redislabs/redis-connect/config/samples/credentials/client-truststore.jks"
20+
}
21+
},
22+
"index": 2,
23+
"stageName": "REDIS_HASH_SINK",
24+
"checkpointStageIndicator": true,
25+
"metricsEnabled" : true
26+
}
27+
]
28+
},
29+
"source": {
30+
"database": {
31+
"credentialsDirectoryPath": "/opt/redislabs/redis-connect/config/samples/credentials",
32+
"databaseType": "GEMFIRE",
33+
"customConfiguration": {
34+
"pool.locator.host": "localhost",
35+
"pool.locator.port": "10334"
36+
}
37+
},
38+
"tables": {
39+
"hash": {
40+
"initialLoad": {
41+
"partitions": 4,
42+
"maxPartitionsPerClusterMember": 1
43+
},
44+
"autoConfigColumnsEnabled": true
45+
}
46+
}
47+
}
48+
}
Lines changed: 11 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,11 @@
1+
#!/bin/bash
2+
3+
version="${1:-1.15.1}"
4+
5+
container_name="gemfire-$version-$(hostname)"
6+
7+
echo "Inserting records in session region.."
8+
docker exec --user root "${container_name}" sh -c "gfsh -e 'connect --locator localhost[10334]' -e 'put --key=\"user1\" --value=(\"name\":\"Jack\",\"age\":35) --region=hash --value-class=java.util.HashMap' -e 'put --key=\"user2\" --value=(\"name\":\"Alice\",\"age\":36) --region=hash --value-class=java.util.HashMap' -e 'put --key=\"user3\" --value=(\"name\":\"Bob\",\"age\":37) --region=hash --value-class=java.util.HashMap' -e 'put --key=\"user4\" --value=(\"name\":\"Carol\",\"age\":38) --region=hash --value-class=java.util.HashMap' -e 'put --key=\"user5\" --value=(\"name\":\"David\",\"age\":39) --region=hash --value-class=java.util.HashMap' -e 'put --key=\"user6\" --value=(\"name\":\"Eva\",\"age\":40) --region=hash --value-class=java.util.HashMap' -e 'put --key=\"user7\" --value=(\"name\":\"Frank\",\"age\":41) --region=hash --value-class=java.util.HashMap' -e 'put --key=\"user8\" --value=(\"name\":\"Grace\",\"age\":42) --region=hash --value-class=java.util.HashMap' -e 'put --key=\"user9\" --value=(\"name\":\"Henry\",\"age\":43) --region=hash --value-class=java.util.HashMap' -e 'put --key=\"user10\" --value=(\"name\":\"Ivy\",\"age\":44) --region=hash --value-class=java.util.HashMap'"
9+
10+
11+
echo "done"

0 commit comments

Comments
 (0)