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 <[email protected]> Authored: Thu May 4 13:01:32 2017 -0700 Committer: Kenneth Knowles <[email protected]> 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(-) ----------------------------------------------------------------------
