org.apache.flink.table.types.logical.utils

Class LogicalTypeUtils

java.lang.Object

org.apache.flink.table.types.logical.utils.LogicalTypeUtils

@Internal
public final class LogicalTypeUtils
extends Object

Utilities for handling LogicalTypes.

Method Summary

Modifier and Type	Method and Description
static String	getAtomicName(List<String> existingNames) Returns a unique name for an atomic type.
static LogicalType	removeTimeAttributes(LogicalType logicalType)
static RowType	renameRowFields(RowType rowType, List<String> newFieldNames) Renames the fields of the given RowType.
static Class<?>	toInternalConversionClass(LogicalType type) Returns the conversion class for the given LogicalType that is used by the table runtime as internal data structure.
static RowType	toRowType(LogicalType t) Converts any logical type to a row type.

Methods inherited from class java.lang.Object

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

Method Detail

removeTimeAttributes

public static LogicalType removeTimeAttributes(LogicalType logicalType)

toInternalConversionClass

public static Class<?> toInternalConversionClass(LogicalType type)

Returns the conversion class for the given LogicalType that is used by the table runtime as internal data structure.

See Also:

RowData

toRowType

public static RowType toRowType(LogicalType t)

Converts any logical type to a row type. Composite types are converted to a row type. Atomic types are wrapped into a field.

getAtomicName

public static String getAtomicName(List<String> existingNames)

Returns a unique name for an atomic type.

renameRowFields

public static RowType renameRowFields(RowType rowType,
                                      List<String> newFieldNames)

Renames the fields of the given RowType.