You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by pa...@apache.org on 2015/04/01 19:49:44 UTC
[13/45] storm git commit: Merge branch 'STORM-691' of
https://github.com/HeartSaVioR/storm into STORM-691
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 <ev...@yahoo-inc.com>
Authored: Tue Mar 24 09:44:29 2015 -0500
Committer: Robert (Bobby) Evans <ev...@yahoo-inc.com>
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
----------------------------------------------------------------------