This closes #2764
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/6d859002 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/6d859002 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/6d859002 Branch: refs/heads/master Commit: 6d8590028d8578ecd4772af9ddc5fc960d292da2 Parents: 625c996 2ac2a34 Author: Thomas Groh <tg...@google.com> Authored: Fri May 5 10:27:59 2017 -0700 Committer: Thomas Groh <tg...@google.com> Committed: Fri May 5 10:27:59 2017 -0700 ---------------------------------------------------------------------- .../beam/examples/WindowedWordCountIT.java | 1 - .../game/utils/WriteWindowedToBigQuery.java | 1 - .../apache/beam/runners/apex/ApexRunner.java | 2 +- .../apex/translation/TransformTranslator.java | 1 - .../apex/translation/TranslationContext.java | 2 +- .../DeduplicatedFlattenFactory.java | 2 +- .../EmptyFlattenAsCreateFactory.java | 2 +- .../core/construction/PTransformMatchers.java | 2 +- .../construction/PTransformReplacements.java | 2 +- .../runners/core/construction/PTransforms.java | 2 +- .../core/construction/PrimitiveCreate.java | 2 +- .../core/construction/SdkComponents.java | 2 +- .../UnsupportedOverrideFactory.java | 2 +- .../EmptyFlattenAsCreateFactoryTest.java | 2 +- .../construction/PTransformMatchersTest.java | 2 +- .../PTransformReplacementsTest.java | 2 +- .../core/construction/PTransformsTest.java | 2 +- .../core/construction/SdkComponentsTest.java | 2 +- .../SingleInputOutputOverrideFactoryTest.java | 2 +- .../direct/BoundedReadEvaluatorFactory.java | 2 +- .../beam/runners/direct/CommittedResult.java | 2 +- .../beam/runners/direct/CompletionCallback.java | 2 +- ...ectGBKIntoKeyedWorkItemsOverrideFactory.java | 2 +- .../apache/beam/runners/direct/DirectGraph.java | 2 +- .../beam/runners/direct/DirectGraphVisitor.java | 2 +- .../direct/DirectGroupByKeyOverrideFactory.java | 2 +- .../beam/runners/direct/EmptyInputProvider.java | 2 +- .../beam/runners/direct/EvaluationContext.java | 2 +- .../direct/ExecutorServiceParallelExecutor.java | 2 +- .../runners/direct/FlattenEvaluatorFactory.java | 2 +- .../GroupAlsoByWindowEvaluatorFactory.java | 2 +- .../direct/GroupByKeyOnlyEvaluatorFactory.java | 2 +- .../direct/ImmutabilityEnforcementFactory.java | 2 +- .../beam/runners/direct/ModelEnforcement.java | 2 +- .../runners/direct/ModelEnforcementFactory.java | 2 +- .../beam/runners/direct/ParDoEvaluator.java | 2 +- .../runners/direct/ParDoEvaluatorFactory.java | 2 +- .../direct/ParDoMultiOverrideFactory.java | 2 +- .../direct/PassthroughTransformEvaluator.java | 2 +- .../beam/runners/direct/PipelineExecutor.java | 2 +- .../beam/runners/direct/RootInputProvider.java | 2 +- .../runners/direct/RootProviderRegistry.java | 2 +- ...littableProcessElementsEvaluatorFactory.java | 2 +- .../direct/StatefulParDoEvaluatorFactory.java | 2 +- .../apache/beam/runners/direct/StepAndKey.java | 2 +- .../runners/direct/StepTransformResult.java | 2 +- .../direct/TestStreamEvaluatorFactory.java | 2 +- .../direct/TransformEvaluatorFactory.java | 2 +- .../direct/TransformEvaluatorRegistry.java | 2 +- .../beam/runners/direct/TransformExecutor.java | 2 +- .../beam/runners/direct/TransformResult.java | 2 +- .../direct/UnboundedReadEvaluatorFactory.java | 2 +- .../runners/direct/ViewEvaluatorFactory.java | 2 +- .../runners/direct/ViewOverrideFactory.java | 2 +- .../direct/WatermarkCallbackExecutor.java | 2 +- .../beam/runners/direct/WatermarkManager.java | 2 +- .../runners/direct/WindowEvaluatorFactory.java | 2 +- .../direct/WriteWithShardingFactory.java | 2 +- .../direct/BoundedReadEvaluatorFactoryTest.java | 2 +- .../runners/direct/CommittedResultTest.java | 2 +- .../runners/direct/DirectGraphVisitorTest.java | 2 +- .../beam/runners/direct/DirectGraphs.java | 2 +- .../DirectGroupByKeyOverrideFactoryTest.java | 2 +- .../runners/direct/EvaluationContextTest.java | 2 +- .../direct/FlattenEvaluatorFactoryTest.java | 2 +- .../ImmutabilityEnforcementFactoryTest.java | 2 +- .../beam/runners/direct/ParDoEvaluatorTest.java | 2 +- .../StatefulParDoEvaluatorFactoryTest.java | 2 +- .../runners/direct/StepTransformResultTest.java | 2 +- .../direct/TestStreamEvaluatorFactoryTest.java | 2 +- .../runners/direct/TransformExecutorTest.java | 2 +- .../UnboundedReadEvaluatorFactoryTest.java | 2 +- .../direct/ViewEvaluatorFactoryTest.java | 2 +- .../runners/direct/ViewOverrideFactoryTest.java | 2 +- .../direct/WatermarkCallbackExecutorTest.java | 2 +- .../runners/direct/WatermarkManagerTest.java | 2 +- .../direct/WriteWithShardingFactoryTest.java | 2 +- .../flink/FlinkBatchTranslationContext.java | 2 +- .../flink/FlinkStreamingPipelineTranslator.java | 2 +- .../flink/FlinkStreamingTranslationContext.java | 2 +- .../dataflow/BatchStatefulParDoOverrides.java | 2 +- .../runners/dataflow/BatchViewOverrides.java | 2 +- .../runners/dataflow/DataflowPipelineJob.java | 2 +- .../dataflow/DataflowPipelineTranslator.java | 2 +- .../beam/runners/dataflow/DataflowRunner.java | 2 +- .../dataflow/PrimitiveParDoSingleFactory.java | 2 +- .../dataflow/ReshuffleOverrideFactory.java | 2 +- .../dataflow/StreamingViewOverrides.java | 2 +- .../runners/dataflow/TransformTranslator.java | 2 +- .../dataflow/util/DataflowTemplateJob.java | 1 - .../dataflow/DataflowPipelineJobTest.java | 2 +- .../PrimitiveParDoSingleFactoryTest.java | 2 +- .../apache/beam/runners/spark/SparkRunner.java | 2 +- .../beam/runners/spark/TestSparkRunner.java | 2 +- .../spark/translation/EvaluationContext.java | 2 +- .../streaming/TrackStreamingSourcesTest.java | 2 +- .../main/java/org/apache/beam/sdk/Pipeline.java | 2 +- .../beam/sdk/runners/AppliedPTransform.java | 73 ++++++++++++++++++++ .../beam/sdk/runners/PTransformMatcher.java | 1 - .../sdk/runners/PTransformOverrideFactory.java | 1 - .../beam/sdk/runners/TransformHierarchy.java | 1 - .../beam/sdk/transforms/AppliedPTransform.java | 72 ------------------- .../java/org/apache/beam/sdk/PipelineTest.java | 2 +- .../beam/sdk/io/gcp/bigquery/BigQueryIO.java | 1 - 104 files changed, 167 insertions(+), 174 deletions(-) ----------------------------------------------------------------------
