私は現在、groupBy と persistentAggregate の後に後処理を行うトライデント トポロジをスケーリングしようとしています。集約ステップの後に newValueStream を使用して値をストリーミングします。groupBy ステップの間、タプルが分割されたままなのか、それとも他の方法で再配布されたのか疑問に思っていました。
関連コード:
.groupBy(new Fields("key"))
.name("GroupBy")
.persistentAggregate(new MemoryMapState.Factory(), new Fields("foo", "bar"), new Aggregator(), new Fields("foobar"))
.newValuesStream()
.name("NewValueStream")