You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by lc...@apache.org on 2016/05/10 20:35:57 UTC
[1/2] incubator-beam git commit: [BEAM-271] Option to configure
remote Dataflow windmill service endpoint
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 <ra...@google.com>
Authored: Mon May 9 23:38:32 2016 -0700
Committer: Luke Cwik <lc...@google.com>
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.
*/
[2/2] incubator-beam git commit: [BEAM-271] This closes #314
Posted by lc...@apache.org.
[BEAM-271] This closes #314
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/b915f79d
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/b915f79d
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/b915f79d
Branch: refs/heads/master
Commit: b915f79d1cbf116599d4b9229d45dc7757583ac3
Parents: 4020e36 cbeed43
Author: Luke Cwik <lc...@google.com>
Authored: Tue May 10 13:29:39 2016 -0700
Committer: Luke Cwik <lc...@google.com>
Committed: Tue May 10 13:29:39 2016 -0700
----------------------------------------------------------------------
.../dataflow/options/DataflowPipelineDebugOptions.java | 12 ++++++++++++
1 file changed, 12 insertions(+)
----------------------------------------------------------------------