Merge branch 'STORM-691' of https://github.com/HeartSaVioR/storm into STORM-691
STORM-691: Add basic lookup / persist bolts Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/cea3faa8 Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/cea3faa8 Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/cea3faa8 Branch: refs/heads/nimbus-ha-branch Commit: cea3faa84464e543131d330ed3ea1522129eb791 Parents: 549b01a 62b5a7e Author: Robert (Bobby) Evans <[email protected]> Authored: Tue Mar 24 09:44:29 2015 -0500 Committer: Robert (Bobby) Evans <[email protected]> Committed: Tue Mar 24 09:44:29 2015 -0500 ---------------------------------------------------------------------- .../storm/redis/bolt/AbstractRedisBolt.java | 8 +- .../storm/redis/bolt/RedisLookupBolt.java | 112 ++++++++++++++++++ .../apache/storm/redis/bolt/RedisStoreBolt.java | 100 ++++++++++++++++ .../redis/common/config/JedisClusterConfig.java | 82 +++++++++++++ .../redis/common/config/JedisPoolConfig.java | 97 ++++++++++++++++ .../common/container/JedisClusterContainer.java | 47 ++++++++ .../JedisCommandsContainerBuilder.java | 38 ++++++ .../JedisCommandsInstanceContainer.java | 25 ++++ .../redis/common/container/JedisContainer.java | 65 +++++++++++ .../common/mapper/RedisDataTypeDescription.java | 50 ++++++++ .../redis/common/mapper/RedisLookupMapper.java | 40 +++++++ .../storm/redis/common/mapper/RedisMapper.java | 22 ++++ .../redis/common/mapper/RedisStoreMapper.java | 21 ++++ .../storm/redis/common/mapper/TupleMapper.java | 27 +++++ .../trident/mapper/TridentTupleMapper.java | 27 ----- .../trident/state/RedisClusterMapState.java | 2 +- .../redis/trident/state/RedisClusterState.java | 2 +- .../trident/state/RedisClusterStateQuerier.java | 10 +- .../trident/state/RedisClusterStateUpdater.java | 10 +- .../redis/trident/state/RedisMapState.java | 2 +- .../storm/redis/trident/state/RedisState.java | 2 +- .../redis/trident/state/RedisStateQuerier.java | 10 +- .../state/RedisStateSetCountQuerier.java | 10 +- .../trident/state/RedisStateSetUpdater.java | 10 +- .../redis/trident/state/RedisStateUpdater.java | 10 +- .../redis/util/config/JedisClusterConfig.java | 82 ------------- .../redis/util/config/JedisPoolConfig.java | 97 ---------------- .../util/container/JedisClusterContainer.java | 47 -------- .../JedisCommandsContainerBuilder.java | 38 ------ .../JedisCommandsInstanceContainer.java | 25 ---- .../redis/util/container/JedisContainer.java | 65 ----------- .../storm/redis/topology/LookupWordCount.java | 115 +++++++++++++------ .../redis/topology/PersistentWordCount.java | 46 +++++++- .../storm/redis/topology/WordCounter.java | 19 ++- .../redis/trident/WordCountTridentRedis.java | 7 +- .../trident/WordCountTridentRedisCluster.java | 6 +- .../WordCountTridentRedisClusterMap.java | 8 +- .../redis/trident/WordCountTridentRedisMap.java | 9 +- .../redis/trident/WordCountTupleMapper.java | 10 +- 39 files changed, 912 insertions(+), 491 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/cea3faa8/external/storm-redis/src/main/java/org/apache/storm/redis/trident/state/RedisMapState.java ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/cea3faa8/external/storm-redis/src/main/java/org/apache/storm/redis/trident/state/RedisState.java ----------------------------------------------------------------------
