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 2016/12/16 22:22:06 UTC
[2/2] incubator-beam git commit: This closes #1547
This closes #1547
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/cc28f0cb
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/cc28f0cb
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/cc28f0cb
Branch: refs/heads/master
Commit: cc28f0cb4c44169f933475ae29a32599024d3a1f
Parents: 217c29b 3f227a0
Author: Thomas Groh <tg...@google.com>
Authored: Fri Dec 16 14:21:50 2016 -0800
Committer: Thomas Groh <tg...@google.com>
Committed: Fri Dec 16 14:21:50 2016 -0800
----------------------------------------------------------------------
...ectGBKIntoKeyedWorkItemsOverrideFactory.java | 7 ++--
.../direct/DirectGroupByKeyOverrideFactory.java | 3 +-
.../beam/runners/direct/DirectRunner.java | 7 +++-
.../direct/PTransformOverrideFactory.java | 35 -----------------
.../direct/ParDoMultiOverrideFactory.java | 9 +++--
.../ParDoSingleViaMultiOverrideFactory.java | 11 +++---
.../direct/TestStreamEvaluatorFactory.java | 5 ++-
.../runners/direct/ViewEvaluatorFactory.java | 4 +-
.../direct/WriteWithShardingFactory.java | 6 ++-
.../direct/WriteWithShardingFactoryTest.java | 4 +-
.../beam/sdk/annotations/Experimental.java | 5 ++-
.../sdk/runners/PTransformOverrideFactory.java | 41 ++++++++++++++++++++
12 files changed, 80 insertions(+), 57 deletions(-)
----------------------------------------------------------------------