Thanks for the help. I use a Fold and a WindowFunction in conjunction now
and it works fine. Though I wish there would be a less complicated way to
do this.
cheers Martin
On Thu, May 12, 2016 at 11:59 AM, Fabian Hueske wrote:
> Hi Martin,
>
> You can use a FoldFunction and a WindowFunction to p
Hi Martin,
You can use a FoldFunction and a WindowFunction to process the same!
window. The FoldFunction is eagerly applied, so the window state is only
one element. When the window is closed, the aggregated element is given to
the WindowFunction where you can add start and end time. The iterator
Hej,
I have a windowed stream and I want to run a (generic) fold function on it.
The result should have the start and the end time stamp of the window as
fields (so I can relate it to the original data). *Is there a simple way to
get the timestamps from within the fold function?*
I could find the
