Repository: incubator-beam Updated Branches: refs/heads/master 4020e3645 -> b915f79d1
[BEAM-271] Option to configure remote Dataflow windmill service endpoint Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/cbeed430 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/cbeed430 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/cbeed430 Branch: refs/heads/master Commit: cbeed43097c06092fc81c066bcb97d1f63683c97 Parents: 4020e36 Author: Raghu Angadi <[email protected]> Authored: Mon May 9 23:38:32 2016 -0700 Committer: Luke Cwik <[email protected]> Committed: Tue May 10 13:29:06 2016 -0700 ---------------------------------------------------------------------- .../dataflow/options/DataflowPipelineDebugOptions.java | 12 ++++++++++++ 1 file changed, 12 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/cbeed430/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/options/DataflowPipelineDebugOptions.java ---------------------------------------------------------------------- diff --git a/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/options/DataflowPipelineDebugOptions.java b/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/options/DataflowPipelineDebugOptions.java index 71c8a78..8765adf 100644 --- a/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/options/DataflowPipelineDebugOptions.java +++ b/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/options/DataflowPipelineDebugOptions.java @@ -191,6 +191,18 @@ public interface DataflowPipelineDebugOptions extends PipelineOptions { void setOverrideWindmillBinary(String value); /** + * Custom windmill service endpoint. + */ + @Description("Custom windmill service endpoint.") + String getWindmillServiceEndpoint(); + void setWindmillServiceEndpoint(String value); + + @Description("Port for communicating with a remote windmill service.") + @Default.Integer(443) + int getWindmillServicePort(); + void setWindmillServicePort(int value); + + /** * Number of threads to use on the Dataflow worker harness. If left unspecified, * the Dataflow service will compute an appropriate number of threads to use. */
