Yes, your assumption is right. My TrafficWindow is emitting multiple
records and I am looking for a way to iterate over these values and emit
another set of multiple records(which would be the computed values from the
previous stream).
Thanks a lot for your input Mr. Hueske :)
On Fri, Jan 27, 201
Hi,
the window operation is completed after you called apply the first time.
The result is a regular DataStream.
I assume your TrafficWindow emits multiple records. Otherwise, you'd
probably apply a simple MapFunction after the window.
So you are looking for a way to iterate over all values retur
Hi everyone,
I have a window definition like this at the moment in snapshot version
1.2.0:
final StreamExecutionEnvironment env =
StreamExecutionEnvironment.getExecutionEnvironment();
env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime);
env.setParallelism(1);
Da
