You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by kl0u <gi...@git.apache.org> on 2018/03/01 14:06:09 UTC

[GitHub] flink pull request #5481: [FLINK-8560] Access to the current key in ProcessF...

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.


---