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.

Enum Constant Summary

Enum Constants

Enum Constant and Description
v1_10
v1_11
v1_12
v1_13
v1_14
v1_15
v1_3
v1_4
v1_5
v1_6
v1_7
v1_8
v1_9

Method Summary

Modifier and Type	Method and Description
static Optional<FlinkVersion>	byCode(String code)
static FlinkVersion	current() Returns the current version.
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(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.

Methods inherited from class java.lang.Enum

clone, compareTo, equals, finalize, getDeclaringClass, hashCode, name, ordinal, valueOf

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, wait, wait, wait

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

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 name

NullPointerException - if the argument is null

toString

public String toString()

Overrides:

toString in class Enum<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)

current

public static FlinkVersion current()

Returns the current version.