samza-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Jagadish Venkatraman <>
Subject Re: Question about Window
Date Wed, 12 Jul 2017 14:06:39 GMT
Hi Rui,

Are you using the low-level API or the high-level API? The high-level API (
*StreamApplication*) that offers built-in support for windows/triggers is
currently in preview stage, and we are working to make it production ready
with the next release.

It looks like you are referring to the low-level *WindowableTask* API. In
this API, you are guaranteed a periodic callback after every
*windowMs* milliseconds.
It should be possible (with minimal effort) to implement Calendar windowing
on top of this - you can set a low value for *
<> *and periodically evaluate inside *window *if
results should be emitted based on Calendar time.

Please do let us know if you had further questions.


On Wed, Jul 12, 2017 at 6:57 AM, Rui Tang <> wrote:

> According to the windowing (
> documentation, I know that I can specify a fixed duration window, like
> 8640000ms (one day). That means if the window starts at 9:00 AM, then it
> will end at 9:00 AM the next day.
> But I need a kind of window that overlaps some calendar day, that means
> whenever the window starts, it will end at the end of the day. How can I do
> this using Samza windowing system? Do I need to create my own window and
> trigger implementation?
> Thank you!

Jagadish V,
Graduate Student,
Department of Computer Science,
Stanford University

  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message