[
https://issues.apache.org/jira/browse/BEAM-13193?focusedWorklogId=685466&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-685466
]
ASF GitHub Bot logged work on BEAM-13193:
-----------------------------------------
Author: ASF GitHub Bot
Created on: 23/Nov/21 19:21
Start Date: 23/Nov/21 19:21
Worklog Time Spent: 10m
Work Description: 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]
Issue Time Tracking
-------------------
Worklog Id: (was: 685466)
Time Spent: 7h 40m (was: 7.5h)
> Optional data embedding in Fn API control request and response
> --------------------------------------------------------------
>
> Key: BEAM-13193
> URL: https://issues.apache.org/jira/browse/BEAM-13193
> Project: Beam
> Issue Type: New Feature
> Components: sdk-java-harness, sdk-py-harness
> Reporter: Yichi Zhang
> Priority: P2
> Time Spent: 7h 40m
> Remaining Estimate: 0h
>
> https://docs.google.com/document/d/14p8Y_n4IY5n9L_I9l5x9lVGgml4ZzdCw645HldndCrw/edit
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
