Package org.apache.iceberg.flink.util

Class FlinkCompatibilityUtil

java.lang.Object

org.apache.iceberg.flink.util.FlinkCompatibilityUtil

public class FlinkCompatibilityUtil
extends Object

This is a small util class that try to hide calls to Flink Internal or PublicEvolve interfaces as Flink can change those APIs during minor version release.

Method Summary

Modifier and Type	Method	Description
static boolean	isPhysicalColumn(org.apache.flink.table.api.TableColumn column)
static boolean	isPhysicalColumn(org.apache.flink.table.catalog.Column column)
static org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.table.data.RowData>	toTypeInfo(org.apache.flink.table.types.logical.RowType rowType)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

toTypeInfo

public static org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.table.data.RowData> toTypeInfo(org.apache.flink.table.types.logical.RowType rowType)

isPhysicalColumn

public static boolean isPhysicalColumn(org.apache.flink.table.api.TableColumn column)

isPhysicalColumn

public static boolean isPhysicalColumn(org.apache.flink.table.catalog.Column column)