This is an automated email from the ASF dual-hosted git repository.
tgroh pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 9714b44 Merge pull request #4869: BigQueryIO.read().fromQuery()
improvements
add cc8088f Add ExecutableStage -> ProcessBundleDescriptor
add aae99c8 Clean up GrpcFnServer Constructor Signature
add 6b3ab1d Add a RemoteExecutionTest
add 98b6bbb Clean up a couple of SdkHarnessClient Signatures
add b4952d5 Separate RemoteInputDestinations from SdkHarnessClient
new 757b7b3 Merge pull request #4754: Convert an ExecutableStage to a
ProcessBundleDescriptor
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../core/construction/graph/PipelineNode.java | 2 +-
runners/java-fn-execution/build.gradle | 1 +
runners/java-fn-execution/pom.xml | 7 +-
.../beam/runners/fnexecution/GrpcFnServer.java | 3 +-
.../control/ProcessBundleDescriptors.java | 254 +++++++++++++++++++++
.../fnexecution/control/SdkHarnessClient.java | 23 +-
.../fnexecution/data/RemoteInputDestination.java | 20 +-
.../fnexecution/control/RemoteExecutionTest.java | 230 +++++++++++++++++++
.../fnexecution/control/SdkHarnessClientTest.java | 2 +-
.../data/RemoteInputDestinationTest.java | 56 +++++
10 files changed, 564 insertions(+), 34 deletions(-)
create mode 100644
runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/ProcessBundleDescriptors.java
copy
sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/data/LogicalEndpoint.java
=>
runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/data/RemoteInputDestination.java
(64%)
create mode 100644
runners/java-fn-execution/src/test/java/org/apache/beam/runners/fnexecution/control/RemoteExecutionTest.java
create mode 100644
runners/java-fn-execution/src/test/java/org/apache/beam/runners/fnexecution/data/RemoteInputDestinationTest.java
--
To stop receiving notification emails like this one, please contact
[email protected].
