Github user aljoscha commented on a diff in the pull request:
— Diff: flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/AllWindowedStream.scala —
@@ -199,6 +198,62 @@ class AllWindowedStream[T, W <: Window](javaStream: JavaAllWStream[T, W])
asScalaStream(javaStream.reduce(reducer, applyFunction, returnType))
+ * Applies the given window function to each window. The window function is called for each
+ * evaluation of the window for each key individually. The output of the window function is
+ * interpreted as a regular non-windowed stream.
+ * Arriving data is pre-aggregated using the given pre-aggregation reducer.
+ * @param preAggregator The reduce function that is used for pre-aggregation
+ * @param windowFunction The process window function.
+ * @return The data stream that is the result of applying the window function to the window.
+ def reduce[R: TypeInformation](
— End diff –
The new methods should be `@PublicEvolving`. I know the existing methods aren't, but they should be and are only like this due to oversights. 😅
That's not an error on your side.