roeyshemtov commented on a change in pull request #11972:
URL: https://github.com/apache/flink/pull/11972#discussion_r421670658
##########
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/triggers/ProcessingTimeoutTrigger.java
##########
@@ -0,0 +1,100 @@
+package org.apache.flink.streaming.api.windowing.triggers;
+
+import org.apache.flink.annotation.PublicEvolving;
+import org.apache.flink.api.common.state.ValueState;
+import org.apache.flink.api.common.state.ValueStateDescriptor;
+import org.apache.flink.api.common.typeutils.base.LongSerializer;
+import org.apache.flink.streaming.api.windowing.windows.Window;
+
+/**
+ * A {@link Trigger} that can turn any {@link Trigger} into a timeout {@code
Trigger}.
+ *
+ * <p>Each record arriving will emit a ProcessingTimeTimer withing the
interval,
+ * you can control if the timer will be registered periodic for each event
arriving,
+ * by the continualInterval flag.
Review comment:
you right about the purpose of the flag. On second thought
`continualInterval ` is not a good name, but i changed it to
`resetTimerOnNewRecord` , what do you think?
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
