This closes #187
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/082b7a1b Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/082b7a1b Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/082b7a1b Branch: refs/heads/master Commit: 082b7a1bc2b1c45157e034799296965cb475a3d4 Parents: 7465edb d148a87 Author: Davor Bonaci <[email protected]> Authored: Fri Apr 22 09:38:58 2016 -0700 Committer: Davor Bonaci <[email protected]> Committed: Fri Apr 22 09:38:58 2016 -0700 ---------------------------------------------------------------------- .../sdk/options/DataflowPipelineOptions.java | 7 +++- .../sdk/runners/DataflowPipelineRunner.java | 19 +++++++-- .../BlockingDataflowPipelineRunnerTest.java | 2 +- .../sdk/runners/DataflowPipelineRunnerTest.java | 43 ++++++++++++++++---- 4 files changed, 58 insertions(+), 13 deletions(-) ----------------------------------------------------------------------
