diff --git a/sdk/src/main/java/com/google/cloud/dataflow/sdk/options/DataflowPipelineDebugOptions.java b/sdk/src/main/java/com/google/cloud/dataflow/sdk/options/DataflowPipelineDebugOptions.java index e94b56df87141..3ceec894494ba 100644 --- a/sdk/src/main/java/com/google/cloud/dataflow/sdk/options/DataflowPipelineDebugOptions.java +++ b/sdk/src/main/java/com/google/cloud/dataflow/sdk/options/DataflowPipelineDebugOptions.java @@ -172,11 +172,15 @@ public Dataflow create(PipelineOptions options) { /** * Whether to update the currently running pipeline with the same name as this one. + * + * @deprecated This property is replaced by @{link DataflowPipelineOptions#getUpdate()} */ @JsonIgnore + @Deprecated @Description("If set, replace the existing pipeline with the name specified by --jobName with " + "this pipeline, preserving state.") boolean getUpdate(); + @Deprecated void setUpdate(boolean value); /** diff --git a/sdk/src/main/java/com/google/cloud/dataflow/sdk/options/DataflowPipelineOptions.java b/sdk/src/main/java/com/google/cloud/dataflow/sdk/options/DataflowPipelineOptions.java index a0f188af0785d..1aa434299c4f9 100644 --- a/sdk/src/main/java/com/google/cloud/dataflow/sdk/options/DataflowPipelineOptions.java +++ b/sdk/src/main/java/com/google/cloud/dataflow/sdk/options/DataflowPipelineOptions.java @@ -91,6 +91,19 @@ public interface DataflowPipelineOptions extends String getJobName(); void setJobName(String value); + /** + * Whether to update the currently running pipeline with the same name as this one. + */ + @Override + @SuppressWarnings("deprecation") // base class member deprecated in favor of this one. + @Description( + "If set, replace the existing pipeline with the name specified by --jobName with " + + "this pipeline, preserving state.") + boolean getUpdate(); + @Override + @SuppressWarnings("deprecation") // base class member deprecated in favor of this one. + void setUpdate(boolean value); + /** * Returns a normalized job name constructed from {@link ApplicationNameOptions#getAppName()}, the * local system user name (if available), and the current time. The normalization makes sure that