imeWindows.of(Time.seconds(60)))
.apply((JoinFunction) (T1, T2) -> {
double firstValue = T1.getTemp();
double secondValue = T2.getTemp();
double m = firstValue-secondValue;
return m;
});
comparisonStream.writeAsText("/tmp/output_k.txt",
org.apache.flink.core.fs.FileSystem.WriteMode.OVERWRITE);
And my
windowing by event time, all the sources need to emit watermarks.
> - watermarks are the logical clock used when event-time timing
> - you could use either processing time windows, or adjust watermark strategy
> of your sources accordingly
>
> ... didn't check other potential s
