« Return to Thread: time batch window with a dynamic batching time

Re: time batch window with a dynamic batching time

by Thomas Bernhardt :: Rate this Message:

| View in Thread

Some parts of this message have been removed. Learn more about Nabble's security policy.
Hi Nathan,

in Esper 4.5 there is a expiry expression batch window, would that work?

Best regards,
Tom

From: "Reese, Nathan" <nreese@...>
To: "user@..." <user@...>
Sent: Tuesday, March 27, 2012 11:19 AM
Subject: [esper-user] time batch window with a dynamic batching time

Would it be possible to add a window that releases events in a batch fashion but with a time period cued from event arrival instead of a static time period.  I have a use case where pattern matches need to be batched but the time period can range dramatically.  Below is an example EPL statement using the suggested time_batch_accum window.

select * from pattern[
    every event1=MyEvent(...)
    ->
    (
        every event2=MyOtherEvent(...)
        and not EndEvent(...)
    )
].std:groupwin(event1.id).win:time_batch_accum(1 min)
for grouped_delivery(event1.id)


time_batch_accum: Tumbling window that batches events and releases them every specified time period after the last event has been received.  Batch timer resets each time a new event is added to the window.  Batched events are released when no more events arrive within the specified time period.

Thanks

Nathan


 « Return to Thread: time batch window with a dynamic batching time