Hi, I'm getting data stream from a source and after gathering data in a
time window I want to do some operation like filtering and mapping on
windowed data, but the output of time window operation just allow reduce,
aggregate or ... function and after that, I want to apply functions like
filter or map. How can I apply filter function to the windowed data without
using reduce function before that?
temp.keyBy( 0).
timeWindow(Time.milliseconds(INTERVAL_TIME)).reduce(new
ReduceFunction<Tuple2<Long, byte[]>>() {
