flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From kl0u <...@git.apache.org>
Subject [GitHub] flink pull request #5481: [FLINK-8560] Access to the current key in ProcessF...
Date Thu, 01 Mar 2018 14:06:09 GMT
Github user kl0u commented on a diff in the pull request:

    https://github.com/apache/flink/pull/5481#discussion_r171566773
  
    --- Diff: flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/KeyedStream.scala
---
    @@ -66,9 +66,9 @@ class KeyedStream[T, K](javaStream: KeyedJavaStream[T, K]) extends DataStream[T]
         * function, this function can also query the time and set timers. When reacting to
the firing
         * of set timers the function can directly emit elements and/or register yet more
timers.
         *
    -    * @param processFunction The [[ProcessFunction]] that is called for each element
    -    *                   in the stream.
    +    * @param processFunction The [[ProcessFunction]] that is called for each element
in the stream.
    --- End diff --
    
    Please also add that the user now should use the new `KeyedProcessFunction` instead.


---

Mime
View raw message