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 <[email protected]> Authored: Wed Mar 16 16:38:45 2016 -0700 Committer: Sriharsha Chintalapani <[email protected]> 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(+) ----------------------------------------------------------------------
