This closes #1850
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/34b4a6d9 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/34b4a6d9 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/34b4a6d9 Branch: refs/heads/python-sdk Commit: 34b4a6d9dc2cf5e8da43346077a36b460501afe2 Parents: b21bdf4 31c63cb Author: Thomas Weise <[email protected]> Authored: Fri Jan 27 14:01:09 2017 -0800 Committer: Thomas Weise <[email protected]> Committed: Fri Jan 27 14:01:09 2017 -0800 ---------------------------------------------------------------------- .../beam/runners/apex/ApexPipelineOptions.java | 7 +- .../apache/beam/runners/apex/ApexRunner.java | 43 ++++++++--- .../beam/runners/apex/ApexYarnLauncher.java | 23 +++++- .../beam/runners/apex/ApexRunnerTest.java | 75 ++++++++++++++++++++ .../beam/runners/apex/ApexYarnLauncherTest.java | 9 ++- .../test/resources/beam-runners-apex.properties | 20 ++++++ 6 files changed, 161 insertions(+), 16 deletions(-) ----------------------------------------------------------------------
