WindowedStream operation questions

Posted by Elias Levy on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/WindowedStream-operation-questions-tp6006.html

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?