This is an automated email from the ASF dual-hosted git repository.
jkff pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
commit 5bb482f536e75bfacac91a546ab3db843dd2a25e
Merge: b195516 5d5c052
Author: Eugene Kirpichov <ekirpic...@gmail.com>
AuthorDate: Wed Apr 25 15:09:38 2018 -0700
Merge pull request #5150: [BEAM-4071] Add Portable Runner Job API shim
[BEAM-4071] Add Portable Runner Job API shim
.../core/construction/ArtifactServiceStager.java | 58 +++--
.../construction/ArtifactServiceStagerTest.java | 9 +-
.../runners/fnexecution/InProcessSdkHarness.java | 11 +-
.../fnexecution/control/RemoteExecutionTest.java | 12 +-
...ocalFileSystemArtifactRetrievalServiceTest.java | 10 +-
runners/reference/java/build.gradle | 5 +-
.../beam/runners/reference/CloseableResource.java | 120 ++++++++++
.../reference/JobServicePipelineResult.java | 147 +++++++++++++
.../beam/runners/reference/PortableRunner.java | 245 +++++++++++++++++++++
.../testing/InProcessManagedChannelFactory.java} | 28 +--
.../runners/reference/testing/TestJobService.java | 78 +++++++
.../runners/reference/testing/package-info.java} | 18 +-
.../runners/reference/CloseableResourceTest.java | 109 +++++++++
.../beam/runners/reference/PortableRunnerTest.java | 84 +++++++
.../job/ReferenceRunnerJobServiceTest.java | 10 +-
.../beam/sdk/options/PortablePipelineOptions.java | 46 ++++
.../fn/test/InProcessManagedChannelFactory.java | 28 +--
17 files changed, 928 insertions(+), 90 deletions(-)
--
To stop receiving notification emails like this one, please contact
j...@apache.org.
