Merge branch 'master' of https://github.com/fhussonnois/storm into STORM-1075
Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/5d222702 Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/5d222702 Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/5d222702 Branch: refs/heads/master Commit: 5d22270272bc4e9138e092216ce4e0584096ad75 Parents: 0acc1ce b039d33 Author: Sriharsha Chintalapani <[email protected]> Authored: Mon Nov 30 22:47:14 2015 -0800 Committer: Sriharsha Chintalapani <[email protected]> Committed: Mon Nov 30 22:47:14 2015 -0800 ---------------------------------------------------------------------- external/storm-cassandra/README.md | 198 ++++++++++++++++++ external/storm-cassandra/pom.xml | 124 ++++++++++++ .../AbstractExecutionResultHandler.java | 60 ++++++ .../cassandra/BaseExecutionResultHandler.java | 85 ++++++++ .../storm/cassandra/CassandraContext.java | 92 +++++++++ .../cassandra/DynamicStatementBuilder.java | 199 ++++++++++++++++++ .../storm/cassandra/ExecutionResultHandler.java | 98 +++++++++ .../storm/cassandra/Murmur3StreamGrouping.java | 133 ++++++++++++ .../storm/cassandra/bolt/BaseCassandraBolt.java | 194 ++++++++++++++++++ .../bolt/BatchCassandraWriterBolt.java | 201 ++++++++++++++++++ .../cassandra/bolt/CassandraWriterBolt.java | 72 +++++++ .../cassandra/bolt/GroupingBatchBuilder.java | 68 +++++++ .../bolt/PairBatchStatementTuples.java | 52 +++++ .../cassandra/bolt/PairStatementTuple.java | 50 +++++ .../storm/cassandra/client/CassandraConf.java | 202 +++++++++++++++++++ .../storm/cassandra/client/ClusterFactory.java | 73 +++++++ .../storm/cassandra/client/SimpleClient.java | 42 ++++ .../cassandra/client/SimpleClientProvider.java | 35 ++++ .../cassandra/client/impl/DefaultClient.java | 123 +++++++++++ .../cassandra/context/BaseBeanFactory.java | 65 ++++++ .../storm/cassandra/context/BeanFactory.java | 48 +++++ .../storm/cassandra/context/WorkerCtx.java | 89 ++++++++ .../storm/cassandra/executor/AsyncExecutor.java | 153 ++++++++++++++ .../executor/AsyncExecutorProvider.java | 40 ++++ .../cassandra/executor/AsyncResultHandler.java | 64 ++++++ .../executor/ExecutionResultCollector.java | 99 +++++++++ .../executor/impl/BatchAsyncResultHandler.java | 73 +++++++ .../executor/impl/SingleAsyncResultHandler.java | 72 +++++++ .../query/BatchStatementTupleMapper.java | 57 ++++++ .../cassandra/query/CQLClauseTupleMapper.java | 36 ++++ .../cassandra/query/CQLStatementBuilder.java | 31 +++ .../query/CQLStatementTupleMapper.java | 86 ++++++++ .../cassandra/query/CQLTableTupleMapper.java | 39 ++++ .../cassandra/query/CQLValuesTupleMapper.java | 74 +++++++ .../storm/cassandra/query/ContextQuery.java | 83 ++++++++ .../query/SimpleCQLStatementTupleMapper.java | 51 +++++ .../query/impl/BoundStatementMapperBuilder.java | 107 ++++++++++ .../query/impl/InsertStatementBuilder.java | 153 ++++++++++++++ .../query/impl/UpdateStatementBuilder.java | 118 +++++++++++ .../cassandra/query/selector/FieldSelector.java | 68 +++++++ .../cassandra/DynamicStatementBuilderTest.java | 133 ++++++++++++ .../apache/storm/cassandra/WeatherSpout.java | 84 ++++++++ .../storm/cassandra/bolt/BaseTopologyTest.java | 60 ++++++ .../bolt/BatchCassandraWriterBoltTest.java | 62 ++++++ .../cassandra/bolt/CassandraWriterBoltTest.java | 63 ++++++ .../src/test/resources/schema.cql | 7 + pom.xml | 1 + storm-dist/binary/src/main/assembly/binary.xml | 15 +- 48 files changed, 4131 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/5d222702/pom.xml ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/5d222702/storm-dist/binary/src/main/assembly/binary.xml ----------------------------------------------------------------------
