beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From lc...@apache.org
Subject [2/3] incubator-beam git commit: Move 'update' pipeline option to correct interface
Date Wed, 02 Mar 2016 16:43:31 GMT
Move 'update' pipeline option to correct interface


Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/1f31d4d5
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/1f31d4d5
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/1f31d4d5

Branch: refs/heads/master
Commit: 1f31d4d5980619916a39c70a0af046fc4235b71e
Parents: c9e5525
Author: Scott Wegner <swegner@google.com>
Authored: Mon Feb 29 15:24:49 2016 -0800
Committer: Luke Cwik <lcwik@google.com>
Committed: Wed Mar 2 08:41:32 2016 -0800

----------------------------------------------------------------------
 .../sdk/options/DataflowPipelineDebugOptions.java      |  4 ++++
 .../dataflow/sdk/options/DataflowPipelineOptions.java  | 13 +++++++++++++
 2 files changed, 17 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/1f31d4d5/sdk/src/main/java/com/google/cloud/dataflow/sdk/options/DataflowPipelineDebugOptions.java
----------------------------------------------------------------------
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 e94b56d..3ceec89 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 interface DataflowPipelineDebugOptions extends PipelineOptions
{
 
   /**
    * 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);
 
   /**

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/1f31d4d5/sdk/src/main/java/com/google/cloud/dataflow/sdk/options/DataflowPipelineOptions.java
----------------------------------------------------------------------
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 a0f188a..1aa4342 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
@@ -92,6 +92,19 @@ public interface DataflowPipelineOptions extends
   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
    * the job name matches the required pattern of [a-z]([-a-z0-9]*[a-z0-9])? and length limit
of 40


Mime
View raw message