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/11 07:41:24 UTC
[5/6] storm git commit: Merge branch 'STORM-1211' of
https://github.com/satishd/storm into STORM-1211
Merge branch 'STORM-1211' of https://github.com/satishd/storm into STORM-1211
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/0be444ea
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/0be444ea
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/0be444ea
Branch: refs/heads/master
Commit: 0be444ea832707f76747534aaa39eb7be214942a
Parents: 8482026 cc009d4
Author: Sriharsha Chintalapani <ha...@hortonworks.com>
Authored: Thu Dec 10 21:28:14 2015 -0800
Committer: Sriharsha Chintalapani <ha...@hortonworks.com>
Committed: Thu Dec 10 21:28:14 2015 -0800
----------------------------------------------------------------------
external/storm-cassandra/README.md | 28 ++++
external/storm-cassandra/pom.xml | 9 ++
.../cassandra/client/impl/DefaultClient.java | 22 +--
.../query/CQLResultSetValuesMapper.java | 36 +++++
.../query/impl/BoundStatementMapperBuilder.java | 8 +-
.../cassandra/trident/state/CassandraQuery.java | 44 ++++++
.../cassandra/trident/state/CassandraState.java | 158 +++++++++++++++++++
.../trident/state/CassandraStateFactory.java | 51 ++++++
.../trident/state/CassandraStateUpdater.java | 36 +++++
.../state/TridentResultSetValuesMapper.java | 63 ++++++++
.../cassandra/DynamicStatementBuilderTest.java | 46 +++---
.../apache/storm/cassandra/WeatherSpout.java | 4 +-
.../bolt/BatchCassandraWriterBoltTest.java | 13 +-
.../cassandra/bolt/CassandraWriterBoltTest.java | 13 +-
.../cassandra/trident/TridentTopologyTest.java | 125 +++++++++++++++
.../cassandra/trident/WeatherBatchSpout.java | 104 ++++++++++++
.../src/test/resources/schema.cql | 12 +-
17 files changed, 725 insertions(+), 47 deletions(-)
----------------------------------------------------------------------