Package | Description |
---|---|
org.apache.flink | |
org.apache.flink.table.api | |
org.apache.flink.table.delegation | |
org.apache.flink.table.planner.plan | |
org.apache.flink.table.planner.plan.nodes.exec |
Modifier and Type | Method and Description |
---|---|
static FlinkVersion |
FlinkVersion.current()
Returns the current version.
|
static FlinkVersion |
FlinkVersion.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static FlinkVersion[] |
FlinkVersion.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
static Optional<FlinkVersion> |
FlinkVersion.byCode(String code) |
static Set<FlinkVersion> |
FlinkVersion.rangeOf(FlinkVersion start,
FlinkVersion end)
Returns all versions within the defined range, inclusive both start and end.
|
Modifier and Type | Method and Description |
---|---|
boolean |
FlinkVersion.isNewerVersionThan(FlinkVersion otherVersion) |
static Set<FlinkVersion> |
FlinkVersion.rangeOf(FlinkVersion start,
FlinkVersion end)
Returns all versions within the defined range, inclusive both start and end.
|
Modifier and Type | Method and Description |
---|---|
FlinkVersion |
CompiledPlan.getFlinkVersion()
Returns the Flink version used to compile the plan.
|
Modifier and Type | Method and Description |
---|---|
FlinkVersion |
InternalPlan.getFlinkVersion() |
Modifier and Type | Method and Description |
---|---|
FlinkVersion |
ExecNodeGraphInternalPlan.getFlinkVersion() |
Modifier and Type | Method and Description |
---|---|
FlinkVersion |
ExecNodeGraph.getFlinkVersion() |
Constructor and Description |
---|
ExecNodeGraph(FlinkVersion flinkVersion,
List<ExecNode<?>> rootNodes) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.