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
Post a Comment