[FLINK-10945] Mark InputDependencyConstraint as PublicEvolving

deepfield · Jan 16, 2019 · 94647f1 · 94647f1
1 parent 171a3b1
commit 94647f1
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 2 deletions.
diff --git a/flink-core/src/main/java/org/apache/flink/api/common/ExecutionConfig.java b/flink-core/src/main/java/org/apache/flink/api/common/ExecutionConfig.java
@@ -525,10 +525,11 @@ public ExecutionMode getExecutionMode() {
  * Sets the default input dependency constraint for vertex scheduling. It indicates when a task
  * should be scheduled considering its inputs status.
  *
- * The default constraint is {@link InputDependencyConstraint#ANY}.
+ * <p>The default constraint is {@link InputDependencyConstraint#ANY}.
  *
  * @param inputDependencyConstraint The input dependency constraint.
  */
+ @PublicEvolving
  public void setDefaultInputDependencyConstraint(InputDependencyConstraint inputDependencyConstraint) {
  this.defaultInputDependencyConstraint = inputDependencyConstraint;
  }
@@ -537,10 +538,11 @@ public void setDefaultInputDependencyConstraint(InputDependencyConstraint inputD
  * Gets the default input dependency constraint for vertex scheduling. It indicates when a task
  * should be scheduled considering its inputs status.
  *
- * The default constraint is {@link InputDependencyConstraint#ANY}.
+ * <p>The default constraint is {@link InputDependencyConstraint#ANY}.
  *
  * @return The input dependency constraint of this job.
  */
+ @PublicEvolving
  public InputDependencyConstraint getDefaultInputDependencyConstraint() {
  return defaultInputDependencyConstraint;
  }

diff --git a/flink-core/src/main/java/org/apache/flink/api/common/InputDependencyConstraint.java b/flink-core/src/main/java/org/apache/flink/api/common/InputDependencyConstraint.java
@@ -18,9 +18,12 @@
 
 package org.apache.flink.api.common;
 
+import org.apache.flink.annotation.PublicEvolving;
+
 /**
  * This constraint indicates when a task should be scheduled considering its inputs status.
  */
+@PublicEvolving
 public enum InputDependencyConstraint {
 
  /**