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 2016/03/17 01:52:09 UTC
[2/3] storm git commit: Merge branch 'STORM-1483-1.x' of
https://github.com/vesense/storm into STORM-1483
Merge branch 'STORM-1483-1.x' of https://github.com/vesense/storm into STORM-1483
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/25657d89
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/25657d89
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/25657d89
Branch: refs/heads/1.x-branch
Commit: 25657d899ddfe1b01be959d32fae7806da4ac410
Parents: 53e1ab0 45fe459
Author: Sriharsha Chintalapani <ha...@hortonworks.com>
Authored: Wed Mar 16 16:38:45 2016 -0700
Committer: Sriharsha Chintalapani <ha...@hortonworks.com>
Committed: Wed Mar 16 16:38:45 2016 -0700
----------------------------------------------------------------------
external/storm-mongodb/README.md | 195 +++++++++++++++++++
external/storm-mongodb/pom.xml | 74 +++++++
.../storm/mongodb/bolt/AbstractMongoBolt.java | 56 ++++++
.../storm/mongodb/bolt/MongoInsertBolt.java | 62 ++++++
.../storm/mongodb/bolt/MongoUpdateBolt.java | 75 +++++++
.../storm/mongodb/common/MongoDBClient.java | 91 +++++++++
.../mongodb/common/QueryFilterCreator.java | 38 ++++
.../common/SimpleQueryFilterCreator.java | 39 ++++
.../mongodb/common/mapper/MongoMapper.java | 38 ++++
.../common/mapper/SimpleMongoMapper.java | 40 ++++
.../common/mapper/SimpleMongoUpdateMapper.java | 41 ++++
.../storm/mongodb/trident/state/MongoState.java | 97 +++++++++
.../trident/state/MongoStateFactory.java | 42 ++++
.../trident/state/MongoStateUpdater.java | 34 ++++
.../storm/mongodb/topology/InsertWordCount.java | 81 ++++++++
.../storm/mongodb/topology/UpdateWordCount.java | 91 +++++++++
.../storm/mongodb/topology/WordCounter.java | 67 +++++++
.../storm/mongodb/topology/WordSpout.java | 88 +++++++++
.../storm/mongodb/trident/WordCountTrident.java | 85 ++++++++
pom.xml | 1 +
storm-dist/binary/src/main/assembly/binary.xml | 14 ++
21 files changed, 1349 insertions(+)
----------------------------------------------------------------------