Skip to content

Commit 49c7864

Browse files
authored
add flag for direct path that reads from system properties (#30588)
* add flag for direct path that reads from system properties * remove unused imports * change flag name to something more unique * remove instance factory and just use boolean * fix option name format
1 parent dbbfb80 commit 49c7864

File tree

1 file changed

+8
-0
lines changed

1 file changed

+8
-0
lines changed

runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/options/DataflowStreamingPipelineOptions.java

+8
Original file line numberDiff line numberDiff line change
@@ -211,6 +211,14 @@ public interface DataflowStreamingPipelineOptions extends PipelineOptions {
211211

212212
void setWindmillServiceStreamMaxBackoffMillis(int value);
213213

214+
@Description(
215+
"If true, Dataflow streaming pipeline will be running in direct path mode."
216+
+ " VMs must have IPv6 enabled for this to work.")
217+
@Default.Boolean(false)
218+
boolean getIsWindmillServiceDirectPathEnabled();
219+
220+
void setIsWindmillServiceDirectPathEnabled(boolean isWindmillServiceDirectPathEnabled);
221+
214222
/**
215223
* Factory for creating local Windmill address. Reads from system propery 'windmill.hostport' for
216224
* backwards compatibility.

0 commit comments

Comments
 (0)