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 <k...@google.com>
Authored: Fri Jun 9 19:57:17 2017 -0700
Committer: Kenneth Knowles <k...@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(-)
----------------------------------------------------------------------


Reply via email to