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:38 UTC
[10/12] storm git commit: STORM-753 Correct README to reflect
RedisStoreMapper
STORM-753 Correct README to reflect RedisStoreMapper
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/1eb85a22
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/1eb85a22
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/1eb85a22
Branch: refs/heads/master
Commit: 1eb85a2285a4d291ce60734bb00e5d0747986885
Parents: 84fc764
Author: Jungtaek Lim <ka...@gmail.com>
Authored: Tue Jun 2 06:55:45 2015 +0900
Committer: Jungtaek Lim <ka...@gmail.com>
Committed: Tue Jun 2 06:55:45 2015 +0900
----------------------------------------------------------------------
external/storm-redis/README.md | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/1eb85a22/external/storm-redis/README.md
----------------------------------------------------------------------
diff --git a/external/storm-redis/README.md b/external/storm-redis/README.md
index 86cd937..6e4063e 100644
--- a/external/storm-redis/README.md
+++ b/external/storm-redis/README.md
@@ -193,7 +193,7 @@ RedisState
stream.partitionPersist(factory,
fields,
- new RedisStateUpdater("test_", tupleMapper).withExpire(86400000),
+ new RedisStateUpdater(storeMapper).withExpire(86400000),
new Fields());
TridentState state = topology.newStaticState(factory);
@@ -220,7 +220,7 @@ RedisClusterState
stream.partitionPersist(factory,
fields,
- new RedisClusterStateUpdater("test_", tupleMapper).withExpire(86400000),
+ new RedisClusterStateUpdater(storeMapper).withExpire(86400000),
new Fields());
TridentState state = topology.newStaticState(factory);