Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/2946#discussion_r103427991
--- 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.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
