Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/5481#discussion_r169571197 --- Diff: flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/DataStream.scala --- @@ -686,6 +686,27 @@ class DataStream[T](stream: JavaStream[T]) { asScalaStream(javaStream.process(processFunction, implicitly[TypeInformation[R]])) } + /** + * Applies the given [[KeyedProcessFunction]] on the input stream, thereby --- End diff -- ditto
---