Refactor grouping logic from BoltDeclarer functions to classes so that it is easier for them to be reused by Streamlet API, from calling different function
boltDeclarer.XGrouping(parent, streamId, ...); to: StreamGrouping grouper = new X(...); boltDeclarer.grouping(parent, streamId, grouper); - No logic change. - Old functions are still available. [ Full content available at: https://github.com/apache/incubator-heron/pull/3040 ] This message was relayed via gitbox.apache.org for [email protected]
