elements.
Paul
From: Aljoscha Krettek
Sent: Wednesday, August 31, 2016 10:53:17 AM
To: user@flink.apache.org
Cc: Chad Conkright
Subject: Re: Setting EventTime window width using stream data
Just checking, all the elements that would fall into a window of length X
Just checking, all the elements that would fall into a window of length X
also have X as a property? In that case you should be able to do something
like this:
public Collection assignWindows(PojoType element, long
timestamp, WindowAssignerContext context) {
long size = element.windowSize;
Hi all,
Is it possible to dynamically set the size/width of a SlidingEventTimeWindow
based on a data coming from the stream? Our use case is as follows. We
create a
stream sourced from external system and coming in as a JSON string which is
deserialized to a stream of POJO.The deseria
