[
https://issues.apache.org/jira/browse/STORM-1573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15219219#comment-15219219
]
ASF GitHub Bot commented on STORM-1573:
---------------------------------------
Github user vesense commented on a diff in the pull request:
https://github.com/apache/storm/pull/1230#discussion_r57993862
--- Diff:
external/storm-mongodb/src/main/java/org/apache/storm/mongodb/bolt/MongoInsertBolt.java
---
@@ -99,6 +107,29 @@ public MongoInsertBolt withOrdered(boolean ordered) {
return this;
}
+ public MongoInsertBolt withFlushIntervalSecs(int flushIntervalSecs) {
+ this.flushIntervalSecs = flushIntervalSecs;
+ return this;
+ }
+
+ @Override
+ public Map<String, Object> getComponentConfiguration() {
+ Map<String, Object> conf = super.getComponentConfiguration();
+ if (conf == null) {
+ conf = new Config();
+ }
+
+ if (conf.containsKey(Config.TOPOLOGY_MESSAGE_TIMEOUT_SECS) &&
flushIntervalSecs == 0) {
--- End diff --
also updated 1.x-branch
> Add batch support for MongoInsertBolt
> -------------------------------------
>
> Key: STORM-1573
> URL: https://issues.apache.org/jira/browse/STORM-1573
> Project: Apache Storm
> Issue Type: Improvement
> Reporter: Xin Wang
> Assignee: Xin Wang
>
> 1. Support MongoInsertBolt batch inserting _withBatch_ option
> 2. Specify whether to sort _withOrdered_ option
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
