Trident API の使用を考えているタプルをバッチで処理したいと考えています。ただし、ここではバッチで実行する操作はありません。すべてのタプルは個別に処理されます。ここで必要なのは、すべてのタプルが 1 回だけ処理されるように、1回限りのセマンティクスだけです。これが、Trident を使用する唯一の理由です。
どのタプルが処理されたかの情報を保存して、バッチがリプレイされたときに、それがすでに処理されているときにタプルが実行されないようにしたい。
トポロジにはpersistentAggregate()メソッドが含まれていますが、いくつかの集計操作が必要ですが、すべてのタプルが個別に処理されるため、一連のタプルに対して実行する集計操作はありません.
ここでは、タプルが受ける機能は実行するには細かすぎます。そのため、コンピューティング リソースと時間を節約するために、バッチで処理することを検討しています。
では、タプルをバッチとして消費するが、まだバッチ操作 (ワードカウントなど) を実行しないトポロジを作成するにはどうすればよいでしょうか?