This is an automated email from the ASF dual-hosted git repository.
robertwb pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 0291976 Merge pull request #11472 from lukecwik/splittabledofn
add f813a90 [BEAM-9577] New artifact staging and retrieval service for
Java.
add 9c8718e [BEAM-9577] Multi-threaded artifact staging service backend.
add 01af3aa Use futures, better error handling.
add ec67a93 Merge pull request #11342 [BEAM-9577] New artifact staging
and retrieval service for Java.
No new revisions were added by this update.
Summary of changes:
.../artifact/ArtifactRetrievalService.java | 114 ++++
.../artifact/ArtifactStagingService.java | 616 +++++++++++++++++++++
.../artifact/ArtifactRetrievalServiceTest.java | 132 +++++
.../artifact/ArtifactStagingServiceTest.java | 173 ++++++
4 files changed, 1035 insertions(+)
create mode 100644
runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/artifact/ArtifactRetrievalService.java
create mode 100644
runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/artifact/ArtifactStagingService.java
create mode 100644
runners/java-fn-execution/src/test/java/org/apache/beam/runners/fnexecution/artifact/ArtifactRetrievalServiceTest.java
create mode 100644
runners/java-fn-execution/src/test/java/org/apache/beam/runners/fnexecution/artifact/ArtifactStagingServiceTest.java
