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
[email protected].
