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/15 17:39:49 UTC
[2/4] storm git commit: Merge branch 'STORM-1483' of
https://github.com/vesense/storm into STORM-1483
Merge branch 'STORM-1483' 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/da2d1c21
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/da2d1c21
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/da2d1c21
Branch: refs/heads/master
Commit: da2d1c212457bae468fadfcbf350b8059a8ddb9a
Parents: c2cf3be 0097a25
Author: Sriharsha Chintalapani <ha...@hortonworks.com>
Authored: Tue Mar 15 08:49:36 2016 -0700
Committer: Sriharsha Chintalapani <ha...@hortonworks.com>
Committed: Tue Mar 15 08:49:36 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(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/da2d1c21/pom.xml
----------------------------------------------------------------------
diff --cc pom.xml
index 73888af,7eee59a..95d8472
--- a/pom.xml
+++ b/pom.xml
@@@ -279,8 -269,8 +279,9 @@@
<module>external/storm-metrics</module>
<module>external/storm-cassandra</module>
<module>external/storm-mqtt</module>
+ <module>external/storm-mongodb</module>
<module>examples/storm-starter</module>
+ <module>storm-clojure</module>
</modules>
<dependencies>