This closes #2153
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/66283670 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/66283670 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/66283670 Branch: refs/heads/master Commit: 66283670d12a499f911e8a08c71652f16421e6f4 Parents: caba841 f6dd583 Author: Eugene Kirpichov <[email protected]> Authored: Tue Mar 28 13:05:12 2017 -0700 Committer: Eugene Kirpichov <[email protected]> Committed: Tue Mar 28 13:05:12 2017 -0700 ---------------------------------------------------------------------- .../apache/beam/examples/complete/TfIdf.java | 3 +- .../beam/examples/cookbook/FilterExamples.java | 3 +- .../beam/examples/complete/game/GameStats.java | 8 +- .../translation/ApexPipelineTranslator.java | 2 +- .../apex/translation/ParDoTranslator.java | 8 +- .../apex/translation/ParDoTranslatorTest.java | 11 +- .../core/construction/PTransformMatchers.java | 42 +-- .../construction/PTransformMatchersTest.java | 6 +- .../org/apache/beam/runners/core/OldDoFn.java | 10 +- .../beam/runners/core/SplittableParDo.java | 8 +- .../beam/runners/core/SplittableParDoTest.java | 2 +- .../beam/runners/direct/DirectRunner.java | 7 +- .../direct/KeyedPValueTrackingVisitor.java | 4 +- .../runners/direct/ParDoEvaluatorFactory.java | 8 +- .../direct/ParDoMultiOverrideFactory.java | 20 +- .../direct/TransformEvaluatorRegistry.java | 2 +- .../StatefulParDoEvaluatorFactoryTest.java | 3 +- .../beam/runners/flink/examples/TFIDF.java | 3 +- .../flink/FlinkBatchTransformTranslators.java | 6 +- .../FlinkStreamingTransformTranslators.java | 6 +- .../dataflow/BatchStatefulParDoOverrides.java | 31 +- .../dataflow/DataflowPipelineTranslator.java | 8 +- .../beam/runners/dataflow/DataflowRunner.java | 4 +- .../dataflow/PrimitiveParDoSingleFactory.java | 13 +- .../BatchStatefulParDoOverridesTest.java | 2 +- .../DataflowPipelineTranslatorTest.java | 8 +- .../PrimitiveParDoSingleFactoryTest.java | 8 +- .../spark/translation/TransformTranslator.java | 9 +- .../streaming/StreamingTransformTranslator.java | 8 +- .../runners/spark/SparkPipelineStateTest.java | 2 +- .../streaming/TrackStreamingSourcesTest.java | 4 +- .../beam/sdk/AggregatorPipelineExtractor.java | 8 +- .../org/apache/beam/sdk/testing/PAssert.java | 2 +- .../org/apache/beam/sdk/transforms/Combine.java | 4 +- .../org/apache/beam/sdk/transforms/DoFn.java | 8 +- .../org/apache/beam/sdk/transforms/ParDo.java | 325 ++----------------- .../apache/beam/sdk/transforms/Partition.java | 4 +- .../org/apache/beam/sdk/transforms/Sample.java | 7 +- .../org/apache/beam/sdk/transforms/View.java | 2 +- .../transforms/windowing/WindowMappingFn.java | 4 +- .../org/apache/beam/sdk/values/TypedPValue.java | 2 +- .../sdk/AggregatorPipelineExtractorTest.java | 56 ++-- .../apache/beam/sdk/metrics/MetricsTest.java | 5 +- .../sdk/runners/TransformHierarchyTest.java | 14 +- .../apache/beam/sdk/transforms/FlattenTest.java | 4 +- .../apache/beam/sdk/transforms/ParDoTest.java | 83 ++--- .../apache/beam/sdk/transforms/ViewTest.java | 152 ++++----- .../apache/beam/sdk/values/TypedPValueTest.java | 6 +- 48 files changed, 335 insertions(+), 610 deletions(-) ----------------------------------------------------------------------
