Re: Custom Tumbling Window Assigner

2016-08-16 Thread dan bress
https://ci.apache.org/projects/flink/flink-docs-master/apis/streaming/windows.html#session-windows > > [2] https://techblog.king.com/rbea-scalable-real-time-analytics-king/ > > > > On Mon, Aug 15, 2016 at 7:05 PM, dan bress wrote: > > > I am interesting in writing a custom

Re: Custom Tumbling Window Assigner

2016-08-16 Thread Aljoscha Krettek
g/projects/flink/flink-docs-master/apis/streaming/windows.html#session-windows > [2] https://techblog.king.com/rbea-scalable-real-time-analytics-king/ > > On Mon, Aug 15, 2016 at 7:05 PM, dan bress wrote: > > I am interesting in writing a custom tumbling window assigner to do the >

Re: Custom Tumbling Window Assigner

2016-08-16 Thread Ufuk Celebi
t 7:05 PM, dan bress wrote: > I am interesting in writing a custom tumbling window assigner to do the > following: > > As soon as the first event for that keyed stream comes in, create a window > from that point going forward N milli seconds. Is it possible to do that > usin

Custom Tumbling Window Assigner

2016-08-15 Thread dan bress
I am interesting in writing a custom tumbling window assigner to do the following: As soon as the first event for that keyed stream comes in, create a window from that point going forward N milli seconds. Is it possible to do that using flink? What I want to do is get all events that occurred