You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by sr...@apache.org on 2015/12/02 00:49:25 UTC
[4/7] storm git commit: Merge branch 'master' of
https://github.com/fhussonnois/storm into STORM-1075
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 <ha...@hortonworks.com>
Authored: Mon Nov 30 22:47:14 2015 -0800
Committer: Sriharsha Chintalapani <ha...@hortonworks.com>
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
----------------------------------------------------------------------