Package org.apache.flink
Enum FlinkVersion
- java.lang.Object
-
- java.lang.Enum<FlinkVersion>
-
- org.apache.flink.FlinkVersion
-
- All Implemented Interfaces:
Serializable
,Comparable<FlinkVersion>
@Public public enum FlinkVersion extends Enum<FlinkVersion>
Enumeration for Flink versions.It used for API versioning, during SQL/Table API upgrades, and for migration tests.
-
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static Optional<FlinkVersion>
byCode(String code)
static FlinkVersion
current()
Returns the version for the current branch.boolean
isNewerVersionThan(FlinkVersion otherVersion)
static Set<FlinkVersion>
rangeOf(FlinkVersion start, FlinkVersion end)
Returns all versions within the defined range, inclusive both start and end.String
toString()
static FlinkVersion
valueOf(int majorVersion, int minorVersion)
static FlinkVersion
valueOf(String name)
Returns the enum constant of this type with the specified name.static FlinkVersion[]
values()
Returns an array containing the constants of this enum type, in the order they are declared.
-
-
-
Enum Constant Detail
-
v1_3
public static final FlinkVersion v1_3
-
v1_4
public static final FlinkVersion v1_4
-
v1_5
public static final FlinkVersion v1_5
-
v1_6
public static final FlinkVersion v1_6
-
v1_7
public static final FlinkVersion v1_7
-
v1_8
public static final FlinkVersion v1_8
-
v1_9
public static final FlinkVersion v1_9
-
v1_10
public static final FlinkVersion v1_10
-
v1_11
public static final FlinkVersion v1_11
-
v1_12
public static final FlinkVersion v1_12
-
v1_13
public static final FlinkVersion v1_13
-
v1_14
public static final FlinkVersion v1_14
-
v1_15
public static final FlinkVersion v1_15
-
v1_16
public static final FlinkVersion v1_16
-
v1_17
public static final FlinkVersion v1_17
-
v1_18
public static final FlinkVersion v1_18
-
v1_19
public static final FlinkVersion v1_19
-
v1_20
public static final FlinkVersion v1_20
-
v2_0
public static final FlinkVersion v2_0
-
-
Method Detail
-
values
public static FlinkVersion[] values()
Returns an array containing the constants of this enum type, in the order they are declared. This method may be used to iterate over the constants as follows:for (FlinkVersion c : FlinkVersion.values()) System.out.println(c);
- Returns:
- an array containing the constants of this enum type, in the order they are declared
-
valueOf
public static FlinkVersion valueOf(String name)
Returns the enum constant of this type with the specified name. The string must match exactly an identifier used to declare an enum constant in this type. (Extraneous whitespace characters are not permitted.)- Parameters:
name
- the name of the enum constant to be returned.- Returns:
- the enum constant with the specified name
- Throws:
IllegalArgumentException
- if this enum type has no constant with the specified nameNullPointerException
- if the argument is null
-
toString
public String toString()
- Overrides:
toString
in classEnum<FlinkVersion>
-
isNewerVersionThan
public boolean isNewerVersionThan(FlinkVersion otherVersion)
-
rangeOf
public static Set<FlinkVersion> rangeOf(FlinkVersion start, FlinkVersion end)
Returns all versions within the defined range, inclusive both start and end.
-
byCode
public static Optional<FlinkVersion> byCode(String code)
-
valueOf
public static FlinkVersion valueOf(int majorVersion, int minorVersion)
-
current
public static FlinkVersion current()
Returns the version for the current branch.
-
-