org.apache.iceberg.flink

Class FlinkTypeToType

java.lang.Object

org.apache.iceberg.flink.FlinkTypeVisitor<Type>

org.apache.iceberg.flink.FlinkTypeToType

public class FlinkTypeToType
extends FlinkTypeVisitor<Type>

Method Summary

Modifier and Type	Method and Description
Type	atomic(org.apache.flink.table.types.AtomicDataType type)
Type	collection(org.apache.flink.table.types.CollectionDataType collection, Type elementType)
Type	fields(org.apache.flink.table.types.FieldsDataType fields, java.util.List<Type> types)
Type	map(org.apache.flink.table.types.KeyValueDataType map, Type keyType, Type valueType)

Methods inherited from class java.lang.Object

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

Method Detail

fields

public Type fields(org.apache.flink.table.types.FieldsDataType fields,
                   java.util.List<Type> types)

Overrides:

fields in class FlinkTypeVisitor<Type>

collection

public Type collection(org.apache.flink.table.types.CollectionDataType collection,
                       Type elementType)

Overrides:

collection in class FlinkTypeVisitor<Type>

map

public Type map(org.apache.flink.table.types.KeyValueDataType map,
                Type keyType,
                Type valueType)

Overrides:

map in class FlinkTypeVisitor<Type>

atomic

public Type atomic(org.apache.flink.table.types.AtomicDataType type)

Overrides:

atomic in class FlinkTypeVisitor<Type>