You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ke...@apache.org on 2017/06/10 03:14:04 UTC
[5/5] beam git commit: This closes #3338: [BEAM-2371] Port some
DirectRunner overrides to SDK-agnostic APIs
This closes #3338: [BEAM-2371] Port some DirectRunner overrides to SDK-agnostic APIs
Port DirectRunner TestStream override to SDK-agnostic APIs
Port DirectRunner WriteFiles override to SDK-agnostic APIs
Port DirectGroupByKey to SDK-agnostic APIs
Port ViewOverrideFactory to SDK-agnostic APIs
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/1597f3ca
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/1597f3ca
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/1597f3ca
Branch: refs/heads/master
Commit: 1597f3ca64558f0099237aeb618b144e132ddcc6
Parents: b4c7716 eaaf45f
Author: Kenneth Knowles <kl...@google.com>
Authored: Fri Jun 9 19:57:17 2017 -0700
Committer: Kenneth Knowles <kl...@google.com>
Committed: Fri Jun 9 19:57:17 2017 -0700
----------------------------------------------------------------------
.../CreatePCollectionViewTranslation.java | 4 +-
.../core/construction/PTransformMatchers.java | 17 +++++--
.../construction/TestStreamTranslation.java | 49 +++++++++++++++++++-
.../beam/runners/direct/DirectGroupByKey.java | 13 +++---
.../direct/DirectGroupByKeyOverrideFactory.java | 14 ++++--
.../direct/TestStreamEvaluatorFactory.java | 20 ++++++--
.../runners/direct/ViewOverrideFactory.java | 48 +++++++++++--------
.../direct/WriteWithShardingFactory.java | 30 ++++++++----
.../direct/ViewEvaluatorFactoryTest.java | 3 +-
.../runners/direct/ViewOverrideFactoryTest.java | 23 +++++++--
.../direct/WriteWithShardingFactoryTest.java | 26 +++++++----
.../org/apache/beam/sdk/testing/TestStream.java | 12 +++++
.../beam/sdk/values/PCollectionViews.java | 10 ++++
13 files changed, 207 insertions(+), 62 deletions(-)
----------------------------------------------------------------------