java - Does Storm Trident newValueStream after persistentAggregate maintain partition from groupBy -


i trying scale trident topology post processing after groupby , persistentaggregate, using newvaluestream stream values after aggregate step. wondering if tuples remained partitioned during groupby step, or redistributed in other fashion.

relevant code:

.groupby(new fields("key")) .name("groupby") .persistentaggregate(new memorymapstate.factory(), new fields("foo", "bar"), new aggregator(), new fields("foobar")) .newvaluesstream() .name("newvaluestream") 


Comments

Popular posts from this blog

c++ - QTextObjectInterface with Qml TextEdit (QQuickTextEdit) -

javascript - angular ng-required radio button not toggling required off in firefox 33, OK in chrome -

xcode - Swift Playground - Files are not readable -