kl0u commented on a change in pull request #13509:
URL: https://github.com/apache/flink/pull/13509#discussion_r497334734
##########
File path:
flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/sideoutput/SideOutputExample.java
##########
@@ -148,4 +156,29 @@ public void processElement(
}
}
+
+ /**
+ * This {@link WatermarkStrategy} assigns the current system time as
the event-time timestamp.
+ * In a real use case you should use proper timestamps and an
appropriate {@link
+ * WatermarkStrategy}.
+ */
+ private static class IngestionTimeWatermarkStrategy<T> implements
WatermarkStrategy<T> {
Review comment:
I was thinking more of a testing module, like the `MockSource`, but I
think you are right to not expose it even there.
----------------------------------------------------------------
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]
