TridentState で提供される partitionpersist API を使用して、イベントのストリームをバッチで処理することができました。しかし今、このボルトの処理された値を発行し、次のボルトのイベントの別のバッチとしてそれらを収集したいと考えています。
TridentState で提供される partitionpersist API を使用して、イベントのストリームをバッチで処理することができました。しかし今、このボルトの処理された値を発行し、次のボルトのイベントの別のバッチとしてそれらを収集したいと考えています。