You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by dh...@apache.org on 2016/06/17 22:13:56 UTC
[9/9] incubator-beam git commit: Closes #487
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 <dh...@google.com>
Authored: Fri Jun 17 15:13:39 2016 -0700
Committer: Dan Halperin <dh...@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(-)
----------------------------------------------------------------------