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],
