Merge pull request #1534 from ishark/redisStore MLHR-1748 #resolve #comment Created concrete input and output operators for Redis Store
Project: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/commit/717168bc Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/tree/717168bc Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/diff/717168bc Branch: refs/heads/feature-AppData Commit: 717168bc8768d4376b5f724fb7a31c975878aea5 Parents: 0b3bb88 ada42ab Author: Chandni Singh <[email protected]> Authored: Fri Aug 14 15:17:27 2015 -0700 Committer: Chandni Singh <[email protected]> Committed: Fri Aug 14 15:17:27 2015 -0700 ---------------------------------------------------------------------- contrib/pom.xml | 8 +- .../redis/AbstractRedisInputOperator.java | 225 +++++++++++++++++- .../redis/RedisKeyValueInputOperator.java | 55 +++++ .../redis/RedisMapAsValueInputOperator.java | 45 ++++ .../contrib/redis/RedisPOJOInputOperator.java | 204 ++++++++++++++++ .../contrib/redis/RedisPOJOOutputOperator.java | 155 +++++++++++++ .../datatorrent/contrib/redis/RedisStore.java | 27 +++ .../contrib/redis/RedisInputOperatorTest.java | 193 ++++++++++++++++ .../contrib/redis/RedisPOJOOperatorTest.java | 230 +++++++++++++++++++ demos/machinedata/pom.xml | 2 +- 10 files changed, 1138 insertions(+), 6 deletions(-) ----------------------------------------------------------------------
