You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by ka...@apache.org on 2017/04/05 00:45:57 UTC
[3/4] storm git commit: Merge branch 'master' of
https://github.com/ef-labs/storm into STORM-1369-merge
Merge branch 'master' of https://github.com/ef-labs/storm into STORM-1369-merge
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/80d22b84
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/80d22b84
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/80d22b84
Branch: refs/heads/master
Commit: 80d22b84827c67fb4596b9b0eaf0b88c6693258a
Parents: b346c1c eb6c308
Author: Jungtaek Lim <ka...@gmail.com>
Authored: Wed Apr 5 09:45:03 2017 +0900
Committer: Jungtaek Lim <ka...@gmail.com>
Committed: Wed Apr 5 09:45:03 2017 +0900
----------------------------------------------------------------------
external/storm-cassandra/README.md | 159 +++++++++---
external/storm-cassandra/pom.xml | 9 +
.../storm/cassandra/executor/AsyncExecutor.java | 167 ++++++++++++-
.../executor/AsyncExecutorProvider.java | 2 +-
.../executor/AsyncResultSetHandler.java | 58 +++++
.../query/AyncCQLResultSetValuesMapper.java | 36 +++
.../trident/state/CassandraBackingMap.java | 241 +++++++++++++++++++
.../trident/state/CassandraMapStateFactory.java | 106 ++++++++
.../trident/state/MapStateFactoryBuilder.java | 226 +++++++++++++++++
.../state/NonTransactionalTupleStateMapper.java | 64 +++++
.../trident/state/OpaqueTupleStateMapper.java | 127 ++++++++++
.../trident/state/SerializedStateMapper.java | 67 ++++++
.../trident/state/SimpleStateMapper.java | 104 ++++++++
.../cassandra/trident/state/SimpleTuple.java | 213 ++++++++++++++++
.../cassandra/trident/state/StateMapper.java | 35 +++
.../state/TransactionalTupleStateMapper.java | 105 ++++++++
.../TridentAyncCQLResultSetValuesMapper.java | 117 +++++++++
.../testtools/EmbeddedCassandraResource.java | 193 +++++++++++++++
.../storm/cassandra/trident/MapStateTest.java | 230 ++++++++++++++++++
.../src/test/resources/cassandra.yaml | 39 +++
20 files changed, 2261 insertions(+), 37 deletions(-)
----------------------------------------------------------------------