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/02/23 17:26:35 UTC
[22/23] storm git commit: Merge branch 'branch_storm_redis' of
https://github.com/dashengju/storm into STORM-609
Merge branch 'branch_storm_redis' of https://github.com/dashengju/storm into STORM-609
STORM-609: Add storm-redis to storm external
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/240eb7c6
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/240eb7c6
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/240eb7c6
Branch: refs/heads/master
Commit: 240eb7c6a8155555c622ac5746e83c46dc2c16de
Parents: 9d0df23 c40c172
Author: Robert (Bobby) Evans <ev...@yahoo-inc.com>
Authored: Mon Feb 23 10:18:52 2015 -0600
Committer: Robert (Bobby) Evans <ev...@yahoo-inc.com>
Committed: Mon Feb 23 10:18:52 2015 -0600
----------------------------------------------------------------------
external/storm-redis/LICENSE | 202 ++++++++++++
external/storm-redis/README.md | 137 ++++++++
external/storm-redis/pom.xml | 65 ++++
.../storm/redis/bolt/AbstractRedisBolt.java | 67 ++++
.../trident/mapper/TridentTupleMapper.java | 27 ++
.../trident/state/RedisClusterMapState.java | 294 +++++++++++++++++
.../redis/trident/state/RedisClusterState.java | 80 +++++
.../trident/state/RedisClusterStateQuerier.java | 78 +++++
.../trident/state/RedisClusterStateUpdater.java | 76 +++++
.../redis/trident/state/RedisMapState.java | 323 +++++++++++++++++++
.../storm/redis/trident/state/RedisState.java | 83 +++++
.../redis/trident/state/RedisStateQuerier.java | 70 ++++
.../state/RedisStateSetCountQuerier.java | 74 +++++
.../trident/state/RedisStateSetUpdater.java | 80 +++++
.../redis/trident/state/RedisStateUpdater.java | 75 +++++
.../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 | 127 ++++++++
.../redis/topology/PersistentWordCount.java | 117 +++++++
.../storm/redis/topology/WordCounter.java | 58 ++++
.../apache/storm/redis/topology/WordSpout.java | 88 +++++
.../storm/redis/trident/PrintFunction.java | 40 +++
.../redis/trident/WordCountTridentRedis.java | 97 ++++++
.../trident/WordCountTridentRedisCluster.java | 103 ++++++
.../WordCountTridentRedisClusterMap.java | 101 ++++++
.../redis/trident/WordCountTridentRedisMap.java | 95 ++++++
.../redis/trident/WordCountTupleMapper.java | 16 +
pom.xml | 1 +
32 files changed, 2928 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/240eb7c6/pom.xml
----------------------------------------------------------------------