Package 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
All Methods Static Methods Concrete Methods Modifier and Type Method 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)
-