This closes #125
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/0bb4f9c1 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/0bb4f9c1 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/0bb4f9c1 Branch: refs/heads/master Commit: 0bb4f9c1e2d79afc685817d45e4c7328085c5d32 Parents: 9ff4269 77a77c9 Author: bchambers <[email protected]> Authored: Fri Apr 15 12:12:50 2016 -0700 Committer: bchambers <[email protected]> Committed: Fri Apr 15 12:12:50 2016 -0700 ---------------------------------------------------------------------- .../runners/DataflowPipelineTranslatorTest.java | 94 +++++++++++--------- .../runners/inprocess/ForwardingPTransform.java | 6 ++ .../beam/sdk/transforms/DoFnReflector.java | 6 ++ .../beam/sdk/transforms/DoFnWithContext.java | 14 ++- .../org/apache/beam/sdk/transforms/Filter.java | 27 ++++++ .../apache/beam/sdk/transforms/GroupByKey.java | 9 ++ .../transforms/IntraBundleParallelization.java | 9 ++ .../org/apache/beam/sdk/transforms/ParDo.java | 62 ++++++++++--- .../apache/beam/sdk/transforms/Partition.java | 13 +++ .../inprocess/ForwardingPTransformTest.java | 10 +++ .../sdk/transforms/DoFnWithContextTest.java | 11 +++ .../apache/beam/sdk/transforms/FilterTest.java | 20 +++++ .../beam/sdk/transforms/GroupByKeyTest.java | 15 ++++ .../IntraBundleParallelizationTest.java | 26 ++++++ .../apache/beam/sdk/transforms/ParDoTest.java | 74 ++++++++++++--- .../beam/sdk/transforms/PartitionTest.java | 13 +++ 16 files changed, 341 insertions(+), 68 deletions(-) ----------------------------------------------------------------------
