storm-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From srihar...@apache.org
Subject [4/4] storm git commit: Merge branch 'STORM-1483'
Date Tue, 15 Mar 2016 16:39:51 GMT
Merge branch 'STORM-1483'


Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/afcb2a06
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/afcb2a06
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/afcb2a06

Branch: refs/heads/master
Commit: afcb2a065fac88e203af93c264bf0a473cac970f
Parents: 1a0ed9a a2a28e5
Author: Sriharsha Chintalapani <harsha@hortonworks.com>
Authored: Tue Mar 15 09:26:47 2016 -0700
Committer: Sriharsha Chintalapani <harsha@hortonworks.com>
Committed: Tue Mar 15 09:26:47 2016 -0700

----------------------------------------------------------------------
 CHANGELOG.md                                    |   1 +
 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 ++
 22 files changed, 1350 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/storm/blob/afcb2a06/CHANGELOG.md
----------------------------------------------------------------------
diff --cc CHANGELOG.md
index 603aa8c,60944bc..3908916
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@@ -55,7 -55,7 +55,8 @@@
   * STORM-1521: When using Kerberos login from keytab with multiple bolts/executors ticket
is not renewed in hbase bolt.
  
  ## 1.0.0
+  * STORM-1483: add storm-mongodb connector
 + * STORM-1608: Fix stateful topology acking behavior
   * STORM-1609: Netty Client is not best effort delivery on failed Connection
   * STORM-1620: Update curator to fix CURATOR-209
   * STORM-1469: Adding Plain Sasl Transport Plugin


Mime
View raw message