where it
shows the countWindow being created with a GlobalWindow. After applying your
changes and it working, that section made more sense to me.
Cheers,
David
From: Vishnu Viswanath
Sent: 13 July 2016 12:35:44
To: user@flink.apache.org
Subject: Re: countWindow custom
Hi David,
countWindow(size,slide) creates a GlobalWindow, not a TimeWindow. Also you
have to use Tuple instead of Tuple2.
class SequentialDeltaCheck extends WindowFunction[RawObservation,
String, Tuple, GlobalWindow]{
def apply(key: Tuple, window: GlobalWindow, input:
Iterable[RawObservation],
Hello everyone,
I'm relatively new to using Apache Flink and Scala, and am just getting to
grips with some of the basic functionality both provide. I've hit a wall
trying to implement a custom WindowFunction over a keyed countWindow however,
and hoped someone may have a pointer. The full cod
