Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/6159#discussion_r195376108
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InternalTimerHeap.java
---
@@ -224,6 +227,15 @@ void bulkAddRestoredTimers(Collection<? extends
InternalTimer<K, N>> restoredTim
return result;
}
+ @Nonnull
+ StateSnapshot snapshot(TimerHeapInternalTimer.TimerSerializer<K, N>
serializer) {
+ return new InternalTimerHeapSnapshot<>(
+ Arrays.copyOfRange(queue, 1, size + 1),
+ serializer,
--- End diff --
This method is not called and the signature will probably change. Just have
it here to roughly outline how it this could be used in the future.
---
