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/07/10 23:25:21 UTC
[2/3] storm git commit: Merge branch 'STORM-2589' of
https://github.com/vesense/storm into STORM-2589-merge
Merge branch 'STORM-2589' of https://github.com/vesense/storm into STORM-2589-merge
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/53616605
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/53616605
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/53616605
Branch: refs/heads/master
Commit: 53616605396461fb08b490655eedc063252e918e
Parents: 64fab1e 3d4c59e
Author: Jungtaek Lim <ka...@gmail.com>
Authored: Tue Jul 11 08:24:45 2017 +0900
Committer: Jungtaek Lim <ka...@gmail.com>
Committed: Tue Jul 11 08:24:45 2017 +0900
----------------------------------------------------------------------
external/storm-mongodb/README.md | 1 +
external/storm-mongodb/pom.xml | 3 -
.../storm/mongodb/bolt/AbstractMongoBolt.java | 22 ++--
.../storm/mongodb/bolt/MongoInsertBolt.java | 19 ++--
.../storm/mongodb/bolt/MongoLookupBolt.java | 15 ++-
.../storm/mongodb/bolt/MongoUpdateBolt.java | 12 +-
.../storm/mongodb/common/MongoDBClient.java | 103 ------------------
.../storm/mongodb/common/MongoDbClient.java | 109 +++++++++++++++++++
.../apache/storm/mongodb/common/MongoUtils.java | 10 +-
.../mongodb/common/QueryFilterCreator.java | 9 +-
.../common/SimpleQueryFilterCreator.java | 9 +-
.../common/mapper/MongoLookupMapper.java | 9 +-
.../mongodb/common/mapper/MongoMapper.java | 5 +-
.../common/mapper/MongoUpdateMapper.java | 7 +-
.../common/mapper/SimpleMongoLookupMapper.java | 12 +-
.../common/mapper/SimpleMongoMapper.java | 9 +-
.../common/mapper/SimpleMongoUpdateMapper.java | 5 +-
.../mongodb/trident/state/MongoMapState.java | 40 +++++--
.../storm/mongodb/trident/state/MongoState.java | 21 +++-
.../trident/state/MongoStateFactory.java | 1 +
.../mongodb/trident/state/MongoStateQuery.java | 5 +-
.../trident/state/MongoStateUpdater.java | 1 +
.../mongodb/TestMongoDataSourcesProvider.java | 4 +-
23 files changed, 246 insertions(+), 185 deletions(-)
----------------------------------------------------------------------