rehmanmuradali commented on a change in pull request #11350: [BEAM-1589] Added
@onWindowExpiration annotation.
URL: https://github.com/apache/beam/pull/11350#discussion_r406841025
##########
File path:
runners/core-java/src/main/java/org/apache/beam/runners/core/DoFnRunner.java
##########
@@ -52,6 +52,12 @@ void onTimer(
*/
void finishBundle();
+ /**
+ * Calls a {@link DoFn DoFn's} {@link DoFn.OnWindowExpiration
@OnWindowExpiration} method and
+ * performs additional task, such as extracts a value saved in a state
before garbage collection.
+ */
+ void onWindowExpiration(BoundedWindow window, Instant timestamp, TimeDomain
timeDomain);
Review comment:
@reuvenlax timestamp added to keep the time of outputs from
OnWindowExpiration. This would be window.maxTimestamp()
timeDomain removed
----------------------------------------------------------------
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]
With regards,
Apache Git Services
