An observation and a couple of question from a novice.
The observation: The Flink web site makes available ScalaDocs for
org.apache.flink.api.scala but not for org.apache.flink.streaming.api.scala.
Now for the questions:
Why can't you use map to transform a data stream, say convert all the
elements to integers (e.g. .map { x => 1 }), then create a tumbling
processing time window (e.g.
.windowAll(TumblingProcessingTimeWindows.of(Time.seconds(2))))?
Then the inverse: Why do AllWindiowedStream and WindowStream not have a map
method?
