You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by jk...@apache.org on 2017/03/28 20:07:21 UTC
[5/5] beam git commit: This closes #2153
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 <ki...@google.com>
Authored: Tue Mar 28 13:05:12 2017 -0700
Committer: Eugene Kirpichov <ki...@google.com>
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(-)
----------------------------------------------------------------------