[jira] [Commented] (STORM-1573) Add batch support for MongoInsertBolt

[ASF GitHub Bot (JIRA)]

    [ 
https://issues.apache.org/jira/browse/STORM-1573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15219214#comment-15219214
 ] 

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_r57993615
  
    --- 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 --
    
    Thanks @HeartSaVioR Fixed the issue.


> 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)