You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by jk...@apache.org on 2018/04/25 22:09:50 UTC
[beam] branch master updated (b195516 -> 5bb482f)
This is an automated email from the ASF dual-hosted git repository.
jkff pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from b195516 [BEAM-3255] Enabling gradle-based release process (#5187)
add f7a7018 Add in-process ManagedChannelFactory and update tests to use it
add e5d0c8b Add common pipeline options for portable runners
add fa7b0c0 Set artifact names explicitly while staging to service
add 87bdc1c Add CloseableResource to wrap non-closeable resources that must be cleaned up
add 5d5c052 [BEAM-4071] Add Portable Runner Job API shim
new 5bb482f Merge pull request #5150: [BEAM-4071] Add Portable Runner Job API shim
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/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 | 24 +-
.../runners/reference/testing/TestJobService.java | 78 +++++++
.../runners/reference/testing}/package-info.java | 6 +-
.../runners/reference/CloseableResourceTest.java | 109 +++++++++
.../beam/runners/reference/PortableRunnerTest.java | 84 +++++++
.../job/ReferenceRunnerJobServiceTest.java | 10 +-
.../beam/sdk/options/PortablePipelineOptions.java | 46 ++++
...fo.java => InProcessManagedChannelFactory.java} | 20 +-
17 files changed, 926 insertions(+), 68 deletions(-)
create mode 100644 runners/reference/java/src/main/java/org/apache/beam/runners/reference/CloseableResource.java
create mode 100644 runners/reference/java/src/main/java/org/apache/beam/runners/reference/JobServicePipelineResult.java
create mode 100644 runners/reference/java/src/main/java/org/apache/beam/runners/reference/PortableRunner.java
copy sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/planner/BeamRelDataTypeSystem.java => runners/reference/java/src/main/java/org/apache/beam/runners/reference/testing/InProcessManagedChannelFactory.java (54%)
create mode 100644 runners/reference/java/src/main/java/org/apache/beam/runners/reference/testing/TestJobService.java
copy runners/{gearpump/src/main/java/org/apache/beam/runners/gearpump/translators/utils => reference/java/src/main/java/org/apache/beam/runners/reference/testing}/package-info.java (88%)
create mode 100644 runners/reference/java/src/test/java/org/apache/beam/runners/reference/CloseableResourceTest.java
create mode 100644 runners/reference/java/src/test/java/org/apache/beam/runners/reference/PortableRunnerTest.java
create mode 100644 sdks/java/core/src/main/java/org/apache/beam/sdk/options/PortablePipelineOptions.java
copy sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/test/{package-info.java => InProcessManagedChannelFactory.java} (56%)
--
To stop receiving notification emails like this one, please contact
jkff@apache.org.
[beam] 01/01: Merge pull request #5150: [BEAM-4071] Add Portable
Runner Job API shim
Posted by jk...@apache.org.
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 <ek...@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
jkff@apache.org.