You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by tg...@apache.org on 2018/05/22 16:49:57 UTC
[beam] 01/01: Merge pull request #5348: Add a Direct Job Bundle
Factory
This is an automated email from the ASF dual-hosted git repository.
tgroh pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
commit 60e498bfa7e21986cf32407995229b41680cdf32
Merge: 5051030 468e8e7
Author: Thomas Groh <tg...@users.noreply.github.com>
AuthorDate: Tue May 22 09:49:51 2018 -0700
Merge pull request #5348: Add a Direct Job Bundle Factory
[BEAM-3326]
runners/direct-java/build.gradle | 1 +
runners/direct-java/pom.xml | 5 +
.../BundleFactoryOutputRecieverFactory.java | 69 ++++++
.../direct/portable/DirectJobBundleFactory.java | 178 ++++++++++++++
.../BundleFactoryOutputRecieverFactoryTest.java | 259 +++++++++++++++++++++
.../portable/DirectJobBundleFactoryTest.java | 178 ++++++++++++++
.../java/org/apache/beam/sdk/fn/IdGenerator.java | 31 ++-
.../java/org/apache/beam/sdk/fn/package-info.java | 30 ++-
.../org/apache/beam/sdk/fn/IdGeneratorsTest.java | 30 ++-
9 files changed, 729 insertions(+), 52 deletions(-)
--
To stop receiving notification emails like this one, please contact
tgroh@apache.org.