連続する市場データの集計ビューを生成しようとしています。つまり、2 つのメッセージごとに合計値を計算する必要があります。入ってくるデータを次のように言います。
(V0,T0),(V1,T1),(V2,T2),(V3,T3)....
V
値T
は、データを受信したときのタイムスタンプを意味します。
2 ポイントごとに合計を生成する必要があります。
(R1=Sum(V0,V1),T1),(R2=Sum(V1,V2),T2),(R3=Sum(V2,V3),T3),....
aggregator2
を使用してこれを行う方法、またはこのためのプロセッサを作成する必要があるという提案はありますか?