org.apache.iceberg.flink.util

Class FlinkCompatibilityUtil

java.lang.Object

org.apache.iceberg.flink.util.FlinkCompatibilityUtil

public class FlinkCompatibilityUtil
extends java.lang.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 and Description
static boolean	isPhysicalColumn(org.apache.flink.table.api.TableColumn 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 Detail

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)