[GitHub] flink pull request #5500: [FLINK-8667] expose key in KeyedBroadcastProcessFu...

[bowenli86]

Github user bowenli86 commented on a diff in the pull request:

    https://github.com/apache/flink/pull/5500#discussion_r168855562
  
    --- Diff: 
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/CoBroadcastWithKeyedOperator.java
 ---
    @@ -324,6 +324,11 @@ public TimeDomain timeDomain() {
                        return timeDomain;
                }
     
    +           @Override
    +           public KS getCurrentKey() {
    --- End diff --
    
    added


---