This is an automated email from the ASF dual-hosted git repository.
sewen pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 1489cb072ff0b1d6e6465b5c49a6fb9682ff8134
Author: Stephan Ewen <se...@apache.org>
AuthorDate: Sun Dec 8 14:24:21 2019 +0100
[FLINK-15130][core] Deprecate RequiredParameters and Option
This prepares for removal in a future release.
---
.../src/main/java/org/apache/flink/api/java/utils/Option.java | 7 ++++---
.../src/main/java/org/apache/flink/api/java/utils/OptionType.java | 7 ++++---
.../java/org/apache/flink/api/java/utils/RequiredParameters.java | 7 ++++---
.../apache/flink/api/java/utils/RequiredParametersException.java | 7 ++++---
.../src/test/java/org/apache/flink/api/java/utils/OptionsTest.java | 1 +
.../org/apache/flink/api/java/utils/RequiredParametersTest.java | 1 +
6 files changed, 18 insertions(+), 12 deletions(-)
diff --git
a/flink-java/src/main/java/org/apache/flink/api/java/utils/Option.java
b/flink-java/src/main/java/org/apache/flink/api/java/utils/Option.java
index c6f151f..181c217 100644
--- a/flink-java/src/main/java/org/apache/flink/api/java/utils/Option.java
+++ b/flink-java/src/main/java/org/apache/flink/api/java/utils/Option.java
@@ -18,8 +18,6 @@
package org.apache.flink.api.java.utils;
-import org.apache.flink.annotation.PublicEvolving;
-
import java.util.Arrays;
import java.util.Collections;
import java.util.HashSet;
@@ -28,8 +26,11 @@ import java.util.Set;
/**
* Internal representation of a parameter passed to a user defined function.
+ *
+ * @deprecated These classes will be dropped in the next version. Use {@link
ParameterTool} or a third-party
+ * command line parsing library instead.
*/
-@PublicEvolving
+@Deprecated
public class Option {
private String longName;
diff --git
a/flink-java/src/main/java/org/apache/flink/api/java/utils/OptionType.java
b/flink-java/src/main/java/org/apache/flink/api/java/utils/OptionType.java
index 7d7755c..568c7ff 100644
--- a/flink-java/src/main/java/org/apache/flink/api/java/utils/OptionType.java
+++ b/flink-java/src/main/java/org/apache/flink/api/java/utils/OptionType.java
@@ -18,14 +18,15 @@
package org.apache.flink.api.java.utils;
-import org.apache.flink.annotation.PublicEvolving;
-
/**
* Types the parameters of managed with {@link RequiredParameters} can take.
*
* <p>Name maps directly to the corresponding Java type.
+ *
+ * @deprecated These classes will be dropped in the next version. Use {@link
ParameterTool} or a third-party
+ * command line parsing library instead.
*/
-@PublicEvolving
+@Deprecated
public enum OptionType {
INTEGER,
LONG,
diff --git
a/flink-java/src/main/java/org/apache/flink/api/java/utils/RequiredParameters.java
b/flink-java/src/main/java/org/apache/flink/api/java/utils/RequiredParameters.java
index 676a472..a687e84 100644
---
a/flink-java/src/main/java/org/apache/flink/api/java/utils/RequiredParameters.java
+++
b/flink-java/src/main/java/org/apache/flink/api/java/utils/RequiredParameters.java
@@ -18,8 +18,6 @@
package org.apache.flink.api.java.utils;
-import org.apache.flink.annotation.PublicEvolving;
-
import java.util.HashMap;
import java.util.LinkedList;
import java.util.List;
@@ -28,8 +26,11 @@ import java.util.Objects;
/**
* Facility to manage required parameters in user defined functions.
+ *
+ * @deprecated These classes will be dropped in the next version. Use {@link
ParameterTool} or a third-party
+ * command line parsing library instead.
*/
-@PublicEvolving
+@Deprecated
public class RequiredParameters {
private static final String HELP_TEXT_PARAM_DELIMITER = "\t";
diff --git
a/flink-java/src/main/java/org/apache/flink/api/java/utils/RequiredParametersException.java
b/flink-java/src/main/java/org/apache/flink/api/java/utils/RequiredParametersException.java
index 2476a05..4535e12 100644
---
a/flink-java/src/main/java/org/apache/flink/api/java/utils/RequiredParametersException.java
+++
b/flink-java/src/main/java/org/apache/flink/api/java/utils/RequiredParametersException.java
@@ -18,15 +18,16 @@
package org.apache.flink.api.java.utils;
-import org.apache.flink.annotation.PublicEvolving;
-
import java.util.LinkedList;
import java.util.List;
/**
* Exception which is thrown if validation of {@link RequiredParameters} fails.
+ *
+ * @deprecated These classes will be dropped in the next version. Use {@link
ParameterTool} or a third-party
+ * command line parsing library instead.
*/
-@PublicEvolving
+@Deprecated
public class RequiredParametersException extends Exception {
private List<String> missingArguments;
diff --git
a/flink-java/src/test/java/org/apache/flink/api/java/utils/OptionsTest.java
b/flink-java/src/test/java/org/apache/flink/api/java/utils/OptionsTest.java
index d4f0bac..9dbde32 100644
--- a/flink-java/src/test/java/org/apache/flink/api/java/utils/OptionsTest.java
+++ b/flink-java/src/test/java/org/apache/flink/api/java/utils/OptionsTest.java
@@ -28,6 +28,7 @@ import static org.junit.Assert.fail;
/**
* Tests for the Options utility class.
*/
+@Deprecated
public class OptionsTest {
@Rule
diff --git
a/flink-java/src/test/java/org/apache/flink/api/java/utils/RequiredParametersTest.java
b/flink-java/src/test/java/org/apache/flink/api/java/utils/RequiredParametersTest.java
index e8273ef..fa21e79 100644
---
a/flink-java/src/test/java/org/apache/flink/api/java/utils/RequiredParametersTest.java
+++
b/flink-java/src/test/java/org/apache/flink/api/java/utils/RequiredParametersTest.java
@@ -35,6 +35,7 @@ import static org.junit.Assert.fail;
/**
* Tests for RequiredParameter class and its interactions with ParameterTool.
*/
+@Deprecated
public class RequiredParametersTest extends TestLogger {
@Rule
