lukecwik commented on a change in pull request #16051:
URL: https://github.com/apache/beam/pull/16051#discussion_r755438861
##########
File path:
sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/data/BeamFnDataInboundObserver2.java
##########
@@ -179,6 +118,80 @@ public void awaitCompletion() throws Exception {
}
}
+ /**
+ * Dispatches the data and timers from the elements which is known to be
complete. Should be used
+ * only if we know that all the data and timers for the bundle are contained
in this single
+ * elements object. When invoked, data and timers are multiplexed to
corresponding receiver
+ * without endpoint done state tracking (since it is guaranteed that all
endpoints are done after
+ * the function call returns.
+ */
+ public void dispatchKnownCompleteElements(Elements elements) throws
Exception {
+ multiplexElements(elements, false);
+ }
+
+ private void multiplexElements(Elements elements, boolean
expectTerminalElements)
Review comment:
What is the purpose of the boolean?
--
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.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
