[GitHub] flink pull request #6276: [FLINK-9486] Introduce TimerState in keyed state b...

[tillrohrmann]

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

    https://github.com/apache/flink/pull/6276#discussion_r201019266
  
    --- Diff: 
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InternalTimer.java
 ---
    @@ -37,10 +62,22 @@
        /**
         * Returns the key that is bound to this timer.
         */
    +   @Nonnull
        K getKey();
     
        /**
         * Returns the namespace that is bound to this timer.
         */
    +   @Nonnull
        N getNamespace();
    +
    +   @SuppressWarnings("unchecked")
    +   static <T extends InternalTimer> Comparator<T> getTimerComparator() {
    --- End diff --
    
    Raw usage of `InternalTimer`


---