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/04/25 17:30:04 UTC
[09/50] [abbrv] beam git commit: This closes #2501
This closes #2501
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/fdbadfc9
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/fdbadfc9
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/fdbadfc9
Branch: refs/heads/jstorm-runner
Commit: fdbadfc9cceecf645f2325777ab32f1cb3041953
Parents: 3c2b855 f3b4960
Author: Thomas Groh <tg...@google.com>
Authored: Fri Apr 14 16:52:03 2017 -0700
Committer: Thomas Groh <tg...@google.com>
Committed: Fri Apr 14 16:52:03 2017 -0700
----------------------------------------------------------------------
.../apache/beam/runners/apex/ApexRunner.java | 32 +++--
.../DeduplicatedFlattenFactory.java | 63 +++++----
.../EmptyFlattenAsCreateFactory.java | 20 ++-
.../core/construction/PTransformMatchers.java | 2 -
.../construction/PTransformReplacements.java | 69 ++++++++++
.../core/construction/PrimitiveCreate.java | 13 +-
.../SingleInputOutputOverrideFactory.java | 9 +-
.../UnsupportedOverrideFactory.java | 14 +-
.../DeduplicatedFlattenFactoryTest.java | 18 +--
.../EmptyFlattenAsCreateFactoryTest.java | 36 ++++-
.../PTransformReplacementsTest.java | 131 +++++++++++++++++++
.../SingleInputOutputOverrideFactoryTest.java | 31 ++---
.../UnsupportedOverrideFactoryTest.java | 11 +-
...ectGBKIntoKeyedWorkItemsOverrideFactory.java | 16 ++-
.../direct/DirectGroupByKeyOverrideFactory.java | 14 +-
.../direct/ParDoMultiOverrideFactory.java | 22 ++--
.../direct/TestStreamEvaluatorFactory.java | 14 +-
.../runners/direct/ViewOverrideFactory.java | 18 +--
.../direct/WriteWithShardingFactory.java | 16 +--
.../DirectGroupByKeyOverrideFactoryTest.java | 12 +-
.../direct/ParDoMultiOverrideFactoryTest.java | 45 -------
.../direct/TestStreamEvaluatorFactoryTest.java | 12 --
.../runners/direct/ViewOverrideFactoryTest.java | 42 ++++--
.../direct/WriteWithShardingFactoryTest.java | 23 ++--
.../flink/FlinkStreamingPipelineTranslator.java | 56 ++++----
.../dataflow/BatchStatefulParDoOverrides.java | 42 +++---
.../runners/dataflow/BatchViewOverrides.java | 17 ++-
.../beam/runners/dataflow/DataflowRunner.java | 92 ++++++-------
.../dataflow/PrimitiveParDoSingleFactory.java | 15 ++-
.../dataflow/ReshuffleOverrideFactory.java | 12 +-
.../dataflow/StreamingViewOverrides.java | 14 +-
.../PrimitiveParDoSingleFactoryTest.java | 59 +++++++--
.../beam/runners/spark/TestSparkRunner.java | 14 +-
.../main/java/org/apache/beam/sdk/Pipeline.java | 15 ++-
.../sdk/runners/PTransformOverrideFactory.java | 33 +++--
.../beam/sdk/transforms/AppliedPTransform.java | 5 +
.../java/org/apache/beam/sdk/PipelineTest.java | 33 ++---
37 files changed, 675 insertions(+), 415 deletions(-)
----------------------------------------------------------------------