org.apache.paimon.flink

Class LogicalTypeConversion

java.lang.Object

org.apache.paimon.flink.LogicalTypeConversion

public class LogicalTypeConversion
extends Object

Conversion between LogicalType and DataType.

Constructor Summary

Constructors

Constructor and Description
LogicalTypeConversion()

Method Summary

Modifier and Type	Method and Description
static DataType	toDataType(org.apache.flink.table.types.logical.LogicalType logicalType)
static DataType	toDataType(org.apache.flink.table.types.logical.LogicalType logicalType, AtomicInteger currentHighestFieldId)
static RowType	toDataType(org.apache.flink.table.types.logical.RowType logicalType)
static org.apache.flink.table.types.logical.LogicalType	toLogicalType(DataType dataType)
static org.apache.flink.table.types.logical.RowType	toLogicalType(RowType dataType)

Methods inherited from class java.lang.Object

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

Constructor Detail

LogicalTypeConversion

public LogicalTypeConversion()

Method Detail

toLogicalType

public static org.apache.flink.table.types.logical.RowType toLogicalType(RowType dataType)

toLogicalType

public static org.apache.flink.table.types.logical.LogicalType toLogicalType(DataType dataType)

toDataType

public static RowType toDataType(org.apache.flink.table.types.logical.RowType logicalType)

toDataType

public static DataType toDataType(org.apache.flink.table.types.logical.LogicalType logicalType)

toDataType

public static DataType toDataType(org.apache.flink.table.types.logical.LogicalType logicalType,
                                  AtomicInteger currentHighestFieldId)