[GitHub] metron pull request #1213: METRON-1681: Decouple the ParserBolt from the Par...

[mmiklavc]

Github user mmiklavc commented on a diff in the pull request:

    https://github.com/apache/metron/pull/1213#discussion_r223857790
  
    --- Diff: 
metron-platform/metron-parsers/src/main/java/org/apache/metron/parsers/bolt/ParserBolt.java
 ---
    @@ -251,8 +249,21 @@ public void execute(Tuple tuple) {
                   , sensorParserConfig.getReadMetadata()
                   , sensorParserConfig.getRawMessageStrategyConfig()
           );
    -      parserRunner.setOnSuccess(parserResult -> onSuccess(parserResult, 
tuple));
    -      parserRunner.execute(sensorType, rawMessage, parserConfigurations);
    +      List<ParserResult> parserResults = parserRunner.execute(sensorType, 
rawMessage, parserConfigurations);
    +      int numWritten = 0;
    +      for(ParserResult parserResult: parserResults) {
    --- End diff --
    
    Thanks for this Ryan, I do think it's easier to follow.


---