You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by bo...@apache.org on 2015/06/02 17:00:33 UTC
[05/12] storm git commit: Apply changes to README.md
Apply changes to README.md
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/52fec9ab
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/52fec9ab
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/52fec9ab
Branch: refs/heads/master
Commit: 52fec9ab2cc3e9464fab158002fd27887eb6ff85
Parents: 2b1f1ae
Author: Jungtaek Lim <ka...@gmail.com>
Authored: Sun Apr 5 19:15:27 2015 +0900
Committer: Jungtaek Lim <ka...@gmail.com>
Committed: Sun Apr 5 19:15:27 2015 +0900
----------------------------------------------------------------------
external/storm-redis/README.md | 20 ++++++++++++++++----
1 file changed, 16 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/52fec9ab/external/storm-redis/README.md
----------------------------------------------------------------------
diff --git a/external/storm-redis/README.md b/external/storm-redis/README.md
index 32480e6..aa7a874 100644
--- a/external/storm-redis/README.md
+++ b/external/storm-redis/README.md
@@ -184,7 +184,8 @@ RedisState
JedisPoolConfig poolConfig = new JedisPoolConfig.Builder()
.setHost(redisHost).setPort(redisPort)
.build();
- TridentTupleMapper tupleMapper = new WordCountTupleMapper();
+ RedisStoreMapper storeMapper = new WordCountStoreMapper();
+ RedisLookupMapper lookupMapper = new WordCountLookupMapper();
RedisState.Factory factory = new RedisState.Factory(poolConfig);
TridentTopology topology = new TridentTopology();
@@ -192,8 +193,13 @@ RedisState
stream.partitionPersist(factory,
fields,
- new RedisStateUpdater("test_", tupleMapper, 86400000),
+ new RedisStateUpdater(storeMapper, 86400000),
new Fields());
+
+ TridentState state = topology.newStaticState(factory);
+ stream = stream.stateQuery(state, new Fields("word"),
+ new RedisStateQuerier(lookupMapper),
+ new Fields("columnName","columnValue"));
```
RedisClusterState
@@ -205,7 +211,8 @@ RedisClusterState
}
JedisClusterConfig clusterConfig = new JedisClusterConfig.Builder().setNodes(nodes)
.build();
- TridentTupleMapper tupleMapper = new WordCountTupleMapper();
+ RedisStoreMapper storeMapper = new WordCountStoreMapper();
+ RedisLookupMapper lookupMapper = new WordCountLookupMapper();
RedisClusterState.Factory factory = new RedisClusterState.Factory(clusterConfig);
TridentTopology topology = new TridentTopology();
@@ -213,8 +220,13 @@ RedisClusterState
stream.partitionPersist(factory,
fields,
- new RedisClusterStateUpdater("test_", tupleMapper, 86400000),
+ new RedisClusterStateUpdater(storeMapper, 86400000),
new Fields());
+
+ TridentState state = topology.newStaticState(factory);
+ stream = stream.stateQuery(state, new Fields("word"),
+ new RedisClusterStateQuerier(lookupMapper),
+ new Fields("columnName","columnValue"));
```
## License