You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by bo...@apache.org on 2016/01/11 21:31:09 UTC
[5/6] storm git commit: Merge branch 'master' of
https://github.com/fhussonnois/storm into STORM-1348
Merge branch 'master' of https://github.com/fhussonnois/storm into STORM-1348
STORM-1348: refactor API to remove Insert/Update builder in Cassandra connector
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/fa1ec6f7
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/fa1ec6f7
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/fa1ec6f7
Branch: refs/heads/master
Commit: fa1ec6f7e2efb1b3dc85b67fd7341d5583f2ad1d
Parents: df32755 0702f54
Author: Robert (Bobby) Evans <ev...@yahoo-inc.com>
Authored: Mon Jan 11 14:19:45 2016 -0600
Committer: Robert (Bobby) Evans <ev...@yahoo-inc.com>
Committed: Mon Jan 11 14:19:45 2016 -0600
----------------------------------------------------------------------
external/storm-cassandra/README.md | 70 ++++++---
.../cassandra/DynamicStatementBuilder.java | 99 ++++--------
.../storm/cassandra/Murmur3StreamGrouping.java | 2 -
.../query/BaseCQLStatementTupleMapper.java | 51 +++++++
.../query/BatchStatementTupleMapper.java | 57 -------
.../cassandra/query/CQLClauseTupleMapper.java | 36 -----
.../cassandra/query/CQLStatementBuilder.java | 4 +-
.../query/CQLStatementTupleMapper.java | 25 ---
.../cassandra/query/CQLTableTupleMapper.java | 39 -----
.../cassandra/query/CQLValuesTupleMapper.java | 74 ---------
.../apache/storm/cassandra/query/Column.java | 74 +++++++++
.../apache/storm/cassandra/query/CqlMapper.java | 86 +++++++++++
.../query/SimpleCQLStatementTupleMapper.java | 51 -------
.../builder/BoundCQLStatementMapperBuilder.java | 106 +++++++++++++
.../SimpleCQLStatementMapperBuilder.java | 92 +++++++++++
.../impl/BatchCQLStatementTupleMapper.java | 58 +++++++
.../impl/BoundCQLStatementTupleMapper.java | 106 +++++++++++++
.../query/impl/BoundStatementMapperBuilder.java | 109 -------------
.../query/impl/InsertStatementBuilder.java | 153 -------------------
.../query/impl/PreparedStatementBinder.java | 143 +++++++++++++++++
.../query/impl/RoutingKeyGenerator.java | 52 +++++++
.../query/impl/SimpleCQLStatementMapper.java | 88 +++++++++++
.../query/impl/UpdateStatementBuilder.java | 118 --------------
.../cassandra/query/selector/FieldSelector.java | 8 +-
.../cassandra/DynamicStatementBuilderTest.java | 120 +++++++++------
.../bolt/BatchCassandraWriterBoltTest.java | 10 +-
.../cassandra/bolt/CassandraWriterBoltTest.java | 10 +-
.../cassandra/trident/TridentTopologyTest.java | 6 +-
28 files changed, 1020 insertions(+), 827 deletions(-)
----------------------------------------------------------------------