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 7c3fba01c9a69aca2a75bec52572d097a6f9c777
Merge: ba62679 194ac6d
Author: Eugene Kirpichov <ekirpic...@gmail.com>
AuthorDate: Thu Jun 14 19:03:47 2018 -0700
Merge pull request #5651: [BEAM-4291] Implements distributed artifact
retrieval
[BEAM-4291] Implements distributed artifact retrieval
.../beam/runners/flink/ArtifactSourcePool.java | 67 ---
.../BatchFlinkExecutableStageContext.java | 16 +-
.../functions/FlinkExecutableStageContext.java | 3 -
.../functions/FlinkExecutableStageFunction.java | 9 +-
.../streaming/ExecutableStageDoFnOperator.java | 9 +-
.../streaming/ExecutableStageDoFnOperatorTest.java | 3 -
.../FlinkExecutableStageFunctionTest.java | 3 -
.../fnexecution/artifact/ArtifactSource.java | 41 --
.../BeamFileSystemArtifactRetrievalService.java | 201 +++++++++
.../artifact/BeamFileSystemArtifactSource.java | 88 ----
.../BeamFileSystemArtifactStagingService.java | 22 +-
.../control/DockerJobBundleFactory.java | 7 +-
.../BeamFileSystemArtifactServicesTest.java | 486 +++++++++++++++++++++
.../artifact/BeamFileSystemArtifactSourceTest.java | 132 ------
.../BeamFileSystemArtifactStagingServiceTest.java | 382 ----------------
.../org/apache/beam/sdk/coders/ByteArrayCoder.java | 2 +-
.../apache/beam/sdk/coders/StringUtf8Coder.java | 2 +-
.../main/java/org/apache/beam/sdk/io/FileIO.java | 5 +-
.../java/org/apache/beam/sdk/util/StreamUtils.java | 2 +-
.../org/apache/beam/sdk/util/StreamUtilsTest.java | 6 +-
20 files changed, 725 insertions(+), 761 deletions(-)
--
To stop receiving notification emails like this one, please contact
j...@apache.org.
