Hi Pari,
Try the .until method like this:
> (TimeWindows) TimeWindows.of("tumbling-window-example",
> windowSizeMs).until(60 * 1000L)
Thanks
Eno
> On 13 Jun 2016, at 08:31, Pariksheet Barapatre <pari.data...@gmail.com> wrote:
>
> Hello Experts,
>
> As per documentation in kafka docs -
> *Windowing* is a common prerequisite for stateful transformations which
> group records in a stream, for example, by their timestamps. A local state
> store is usually needed for a windowing operation to store recently
> received records based on the window interval, while old records in the
> store are purged after the specified window retention period
> <http://docs.confluent.io/3.0.0/streams/concepts.html#streams-concepts-windowing>
> .
>
> But I am not finding any example to set window retention period example.
>
> Could somebody help me with example?
>
> long windowSizeMs = 60 *
> 1000L;TimeWindows.of("tumbling-window-example", windowSizeMs);
>
> How to set expiration/purge time for above window example.
>
> Many Thanks
>
> Pari
