1

私はこのようなものが必要です。

//Create a named window (w1)
Create window w1....

//then insert events into window
insert into w1....
select amount,.....
from....
where...

//remove from window
on RemoveEventArrived as r
Delete from w1
where w1.id = r.id

w1という名前のwindowから別のイベントに挿入します

//inserting into final output event
insert into derivedevent
select sum(w.amount)
from w1 as w

suppose event sequence:
1. Event with id=1 and amount= 100 arrived.
   o/p of sum(amount) triggered and gives 100.

2. Event withid = 2 and amount=200 arrived.
  o/p of sum(amount) triggered and gives 300.

3. **Remove** Event with id=1 arrived.
o/p of sum(amount) triggered and gives 200.

4. Event with id = 3 and amount=500 arrived
o/p of sum(amount) triggered and gives  700

しかし、3 番目のイベントは、自動的に派生イベントの再計算をトリガーできませんでした。
4番目のイベントの到着がトリガーされ、必要に応じて出力が得られます。
それを行う標準的な方法はありますか？

新しいイベントがウィンドウに到着するか、ウィンドウを離れるかの合計金額を計算したい。

4

1 に答える 1

1

3.イベント（削除）は、何も削除されていない限り、「derivedeventに挿入」によって新しい合計の出力をトリガーします。したがって、IDキーが間違っている可能性があります。それでも問題が解決しない場合は、最小限のテストケースをesperユーザーのメーリングリストに送信してください。または、@ Auditを使用して、各ステートメントに対してエンジンが内部で何を実行するかを確認します。

于 2012-11-28T11:56:25.563 に答える