complex-event-processing - 超能力者。最小値でデータを送信

Question

次の型で Esper にデータを入力します。

{"symbol" :string
 "price"  :double}

毎分の最小価格のシンボルが必要です。私がそのようなことをするとき：

select min(price), symbol 
from Market.win:time_batch(60 sec)

同じ価格 (最小価格) で多くのイベントを取得しますが、シンボルは異なります (そして、1 つのシンボルと価格で 1 つのイベント (1 分あたり) のみを持ちたい)。

Answer 1

動作は SQL クエリに似ており、各行の記号とバッチの最小値を提供します。SQL と同じように、「group by」を使用して、集計がどのレベルで動作するかを制御できます。

select min(price), symbol from Market.win:time_batch(60 sec) group by symbol

ところで、バッチ ウィンドウはイベントをメモリに保持します。「出力スナップショット」があるため、バッチ ウィンドウは必要ありません。