New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
[BEAM-5600] Add unimplemented split API to Runner side SDF libraries. #10482
Conversation
for (CloseableFnDataReceiver<?> inputReceiver : inputReceivers.values()) { | ||
@Override | ||
public void split(double fractionOfRemainder) { | ||
throw new UnsupportedOperationException("Support splitting, TODO: BEAM-5600"); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I need access to the control service which is why I made the ActiveBundle a nested class.
b917619
to
c126346
Compare
Run Java PreCommit |
Run Portable_Python PreCommit |
Run Python2_PVR_Flink PreCommit |
Run Java PreCommit |
2 similar comments
Run Java PreCommit |
Run Java PreCommit |
This creates an unsupported API to the RemoteBundle and a default split handler that throws.
c126346
to
d6c0ab2
Compare
...fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/SdkHarnessClient.java
Show resolved
Hide resolved
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Thanks for the changes!
Thanks! LGTM. |
…apache#10482) * [BEAM-5600] Add unimplemented split API to Runner side SDF libraries. This creates an unsupported API to the RemoteBundle and a default split handler that throws.
This creates a split call that forwards the values to the SDK and a default split handler that throws.
Thank you for your contribution! Follow this checklist to help us incorporate your contribution quickly and easily:
R: @username
).[BEAM-XXX] Fixes bug in ApproximateQuantiles
, where you replaceBEAM-XXX
with the appropriate JIRA issue, if applicable. This will automatically link the pull request to the issue.See the Contributor Guide for more tips on how to make review process smoother.
Post-Commit Tests Status (on master branch)
Pre-Commit Tests Status (on master branch)
See .test-infra/jenkins/README for trigger phrase, status and link of all Jenkins jobs.