Closes #487
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/8a9dcc71 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/8a9dcc71 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/8a9dcc71 Branch: refs/heads/master Commit: 8a9dcc71f08aa72a008344b75c30949703e7f6f5 Parents: 81dcd52 3841f41 Author: Dan Halperin <dhalp...@google.com> Authored: Fri Jun 17 15:13:39 2016 -0700 Committer: Dan Halperin <dhalp...@google.com> Committed: Fri Jun 17 15:13:39 2016 -0700 ---------------------------------------------------------------------- .../beam/examples/DebuggingWordCount.java | 2 +- .../apache/beam/examples/MinimalWordCount.java | 4 +- .../apache/beam/examples/WindowedWordCount.java | 2 +- .../org/apache/beam/examples/WordCount.java | 2 +- .../examples/common/DataflowExampleUtils.java | 18 +- .../beam/examples/complete/AutoComplete.java | 4 +- .../apache/beam/examples/complete/TfIdf.java | 2 +- .../examples/complete/TopWikipediaSessions.java | 2 +- .../examples/cookbook/BigQueryTornadoes.java | 2 +- .../cookbook/CombinePerKeyExamples.java | 2 +- .../examples/cookbook/DatastoreWordCount.java | 4 +- .../beam/examples/cookbook/DeDupExample.java | 2 +- .../beam/examples/cookbook/FilterExamples.java | 2 +- .../beam/examples/cookbook/JoinExamples.java | 2 +- .../examples/cookbook/MaxPerKeyExamples.java | 2 +- .../beam/examples/MinimalWordCountJava8.java | 4 +- .../beam/examples/complete/game/GameStats.java | 2 +- .../examples/complete/game/HourlyTeamScore.java | 2 +- .../examples/complete/game/LeaderBoard.java | 2 +- .../beam/examples/complete/game/UserScore.java | 2 +- .../beam/runners/flink/FlinkPipelineRunner.java | 2 +- .../BlockingDataflowPipelineRunner.java | 186 - .../dataflow/BlockingDataflowRunner.java | 186 + .../dataflow/DataflowJobCancelledException.java | 2 +- .../dataflow/DataflowJobExecutionException.java | 2 +- .../dataflow/DataflowJobUpdatedException.java | 2 +- .../runners/dataflow/DataflowPipelineJob.java | 2 +- .../dataflow/DataflowPipelineRegistrar.java | 8 +- .../dataflow/DataflowPipelineRunner.java | 3229 ------------------ .../dataflow/DataflowPipelineRunnerHooks.java | 39 - .../dataflow/DataflowPipelineTranslator.java | 10 +- .../beam/runners/dataflow/DataflowRunner.java | 3229 ++++++++++++++++++ .../runners/dataflow/DataflowRunnerHooks.java | 39 + .../runners/dataflow/internal/package-info.java | 2 +- .../BlockingDataflowPipelineOptions.java | 6 +- .../options/DataflowPipelineOptions.java | 4 +- .../DataflowPipelineWorkerPoolOptions.java | 6 +- .../testing/TestDataflowPipelineRunner.java | 10 +- .../BlockingDataflowPipelineRunnerTest.java | 304 -- .../dataflow/BlockingDataflowRunnerTest.java | 304 ++ .../dataflow/DataflowPipelineRegistrarTest.java | 4 +- .../dataflow/DataflowPipelineRunnerTest.java | 1417 -------- .../DataflowPipelineTranslatorTest.java | 50 +- .../runners/dataflow/DataflowRunnerTest.java | 1417 ++++++++ .../runners/dataflow/io/DataflowAvroIOTest.java | 4 +- .../dataflow/io/DataflowPubsubIOTest.java | 4 +- .../runners/dataflow/io/DataflowTextIOTest.java | 4 +- .../testing/TestDataflowPipelineRunnerTest.java | 601 ---- .../testing/TestDataflowRunnerTest.java | 601 ++++ .../DataflowDisplayDataEvaluator.java | 10 +- .../transforms/DataflowGroupByKeyTest.java | 8 +- .../dataflow/transforms/DataflowViewTest.java | 8 +- .../util/DataflowPathValidatorTest.java | 8 +- .../beam/runners/spark/SimpleWordCountTest.java | 2 +- .../spark/translation/SerializationTest.java | 2 +- .../apache/beam/sdk/runners/package-info.java | 12 +- .../apache/beam/sdk/testing/TestPipeline.java | 2 +- .../apache/beam/sdk/transforms/Aggregator.java | 2 +- .../beam/sdk/util/BigQueryTableRowIterator.java | 2 +- .../beam/sdk/runners/PipelineRunnerTest.java | 2 +- .../src/main/java/DebuggingWordCount.java | 2 +- .../src/main/java/MinimalWordCount.java | 4 +- .../src/main/java/WindowedWordCount.java | 2 +- .../src/main/java/WordCount.java | 2 +- .../main/java/common/DataflowExampleUtils.java | 14 +- .../src/main/java/StarterPipeline.java | 2 +- .../src/main/java/it/pkg/StarterPipeline.java | 2 +- sdks/java/pom.xml | 2 +- 68 files changed, 5913 insertions(+), 5913 deletions(-) ----------------------------------------------------------------------