This closes #3516: Move DirectRunner knob for suppressing runner-determined sharding out of core SDK
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/90ba7536 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/90ba7536 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/90ba7536 Branch: refs/heads/master Commit: 90ba7536ffde38cc24a6570c81ef7d44f03ee7d3 Parents: 4a2f674 3621b95 Author: Kenneth Knowles <[email protected]> Authored: Fri Jul 7 09:16:57 2017 -0700 Committer: Kenneth Knowles <[email protected]> Committed: Fri Jul 7 09:16:57 2017 -0700 ---------------------------------------------------------------------- runners/direct-java/pom.xml | 2 +- .../beam/runners/direct/DirectRegistrar.java | 2 +- .../beam/runners/direct/DirectRunner.java | 5 +-- .../beam/runners/direct/DirectTestOptions.java | 42 ++++++++++++++++++++ .../runners/direct/DirectRegistrarTest.java | 2 +- .../beam/sdk/testing/TestPipelineOptions.java | 10 ----- 6 files changed, 47 insertions(+), 16 deletions(-) ----------------------------------------------------------------------
