You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by xi...@apache.org on 2016/12/16 03:32:47 UTC
[4/4] storm git commit: Merge branch 'STORM-1607' of
https://github.com/vesense/storm
Merge branch 'STORM-1607' of https://github.com/vesense/storm
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/9a928718
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/9a928718
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/9a928718
Branch: refs/heads/master
Commit: 9a928718f24a51130912aa930ea2b80743b28280
Parents: f052669 a833af4
Author: vesense <be...@163.com>
Authored: Fri Dec 16 11:27:33 2016 +0800
Committer: vesense <be...@163.com>
Committed: Fri Dec 16 11:27:33 2016 +0800
----------------------------------------------------------------------
.../storm/mongodb/topology/LookupWordCount.java | 80 ++++++++
.../mongodb/topology/TotalWordCounter.java | 69 +++++++
.../storm/mongodb/topology/UpdateWordCount.java | 16 +-
.../storm/mongodb/trident/PrintFunction.java | 40 ++++
.../storm/mongodb/trident/WordCountTrident.java | 9 +-
.../mongodb/trident/WordCountTridentMap.java | 95 +++++++++
external/storm-mongodb/README.md | 185 ++++++++++++++---
.../storm/mongodb/bolt/MongoLookupBolt.java | 76 +++++++
.../storm/mongodb/bolt/MongoUpdateBolt.java | 18 +-
.../storm/mongodb/common/MongoDBClient.java | 26 ++-
.../apache/storm/mongodb/common/MongoUtils.java | 38 ++++
.../mongodb/common/QueryFilterCreator.java | 10 +-
.../common/SimpleQueryFilterCreator.java | 7 +
.../common/mapper/MongoLookupMapper.java | 44 +++++
.../mongodb/common/mapper/MongoMapper.java | 10 +-
.../common/mapper/MongoUpdateMapper.java | 31 +++
.../common/mapper/SimpleMongoLookupMapper.java | 64 ++++++
.../common/mapper/SimpleMongoMapper.java | 14 ++
.../common/mapper/SimpleMongoUpdateMapper.java | 8 +-
.../mongodb/trident/state/MongoMapState.java | 196 +++++++++++++++++++
.../storm/mongodb/trident/state/MongoState.java | 41 +++-
.../mongodb/trident/state/MongoStateQuery.java | 40 ++++
22 files changed, 1063 insertions(+), 54 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/9a928718/examples/storm-mongodb-examples/src/main/java/org/apache/storm/mongodb/topology/UpdateWordCount.java
----------------------------------------------------------------------
diff --cc examples/storm-mongodb-examples/src/main/java/org/apache/storm/mongodb/topology/UpdateWordCount.java
index f80cc7c,daca619..b4af4ca
--- a/examples/storm-mongodb-examples/src/main/java/org/apache/storm/mongodb/topology/UpdateWordCount.java
+++ b/examples/storm-mongodb-examples/src/main/java/org/apache/storm/mongodb/topology/UpdateWordCount.java
@@@ -19,11 -19,10 +19,11 @@@ package org.apache.storm.mongodb.topolo
import org.apache.storm.Config;
import org.apache.storm.LocalCluster;
+import org.apache.storm.LocalCluster.LocalTopology;
import org.apache.storm.StormSubmitter;
+ import org.apache.storm.mongodb.common.mapper.MongoUpdateMapper;
import org.apache.storm.topology.TopologyBuilder;
import org.apache.storm.tuple.Fields;
- import org.apache.storm.mongodb.bolt.MongoInsertBolt;
import org.apache.storm.mongodb.bolt.MongoUpdateBolt;
import org.apache.storm.mongodb.common.QueryFilterCreator;
import org.apache.storm.mongodb.common.SimpleQueryFilterCreator;
http://git-wip-us.apache.org/repos/asf/storm/blob/9a928718/examples/storm-mongodb-examples/src/main/java/org/apache/storm/mongodb/trident/WordCountTrident.java
----------------------------------------------------------------------