beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dhalp...@apache.org
Subject [9/9] incubator-beam git commit: Closes #487
Date Fri, 17 Jun 2016 22:13:56 GMT
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 <dhalperi@google.com>
Authored: Fri Jun 17 15:13:39 2016 -0700
Committer: Dan Halperin <dhalperi@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(-)
----------------------------------------------------------------------



Mime
View raw message