beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From k...@apache.org
Subject [2/2] beam git commit: This closed #2857: Eliminate Pipeline.getOptions
Date Thu, 04 May 2017 20:24:35 GMT
This closed #2857: Eliminate Pipeline.getOptions


Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/1b363ae9
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/1b363ae9
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/1b363ae9

Branch: refs/heads/master
Commit: 1b363ae9f4e3ec1479befef66c5edd785d34ed01
Parents: 70e53e7 55351dc
Author: Kenneth Knowles <klk@google.com>
Authored: Thu May 4 13:01:32 2017 -0700
Committer: Kenneth Knowles <klk@google.com>
Committed: Thu May 4 13:01:32 2017 -0700

----------------------------------------------------------------------
 .../beam/examples/complete/game/GameStats.java  |  7 +++-
 .../examples/complete/game/HourlyTeamScore.java |  6 ++-
 .../examples/complete/game/LeaderBoard.java     | 26 ++++++++----
 .../beam/examples/complete/game/UserScore.java  | 20 +++++----
 .../complete/game/utils/WriteToBigQuery.java    | 32 +++++++-------
 .../game/utils/WriteWindowedToBigQuery.java     |  8 ++--
 .../beam/runners/direct/DirectRunner.java       |  1 +
 .../runners/direct/DisplayDataValidator.java    |  6 +--
 .../dataflow/testing/TestDataflowRunner.java    |  3 +-
 .../testing/TestDataflowRunnerTest.java         | 18 +++-----
 .../apache/beam/runners/spark/SparkRunner.java  |  4 +-
 .../beam/runners/spark/SparkRunnerDebugger.java |  4 +-
 .../beam/runners/spark/TestSparkRunner.java     |  5 +--
 .../spark/translation/EvaluationContext.java    | 16 +++++--
 .../spark/translation/SparkRuntimeContext.java  |  4 +-
 .../SparkRunnerStreamingContextFactory.java     |  2 +-
 .../apache/beam/runners/spark/CacheTest.java    |  2 +-
 .../streaming/TrackStreamingSourcesTest.java    |  2 +-
 .../main/java/org/apache/beam/sdk/Pipeline.java | 14 +------
 .../apache/beam/sdk/testing/TestPipeline.java   | 26 +++++-------
 .../beam/sdk/io/gcp/bigquery/BigQueryIO.java    | 44 ++++++++++----------
 .../sdk/io/gcp/bigquery/BigQueryIOTest.java     |  1 +
 22 files changed, 131 insertions(+), 120 deletions(-)
----------------------------------------------------------------------



Mime
View raw message