Package org.apache.iceberg.flink.data

Class AvroWithFlinkSchemaVisitor<T>

java.lang.Object

org.apache.iceberg.avro.AvroWithPartnerByStructureVisitor<org.apache.flink.table.types.logical.LogicalType,T>

org.apache.iceberg.flink.data.AvroWithFlinkSchemaVisitor<T>

public abstract class AvroWithFlinkSchemaVisitor<T>
extends AvroWithPartnerByStructureVisitor<org.apache.flink.table.types.logical.LogicalType,T>

Constructor Summary

Constructors

Constructor	Description
AvroWithFlinkSchemaVisitor()

Method Summary

Modifier and Type	Method	Description
protected org.apache.flink.table.types.logical.LogicalType	arrayElementType(org.apache.flink.table.types.logical.LogicalType arrayType)
protected Pair<String,org.apache.flink.table.types.logical.LogicalType>	fieldNameAndType(org.apache.flink.table.types.logical.LogicalType structType, int pos)
protected boolean	isMapType(org.apache.flink.table.types.logical.LogicalType logicalType)
protected boolean	isStringType(org.apache.flink.table.types.logical.LogicalType logicalType)
protected org.apache.flink.table.types.logical.LogicalType	mapKeyType(org.apache.flink.table.types.logical.LogicalType mapType)
protected org.apache.flink.table.types.logical.LogicalType	mapValueType(org.apache.flink.table.types.logical.LogicalType mapType)
protected org.apache.flink.table.types.logical.LogicalType	nullType()

Methods inherited from class org.apache.iceberg.avro.AvroWithPartnerByStructureVisitor

array, map, map, primitive, record, union, visit

Methods inherited from class java.lang.Object

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

Constructor Details

AvroWithFlinkSchemaVisitor

public AvroWithFlinkSchemaVisitor()

Method Details

isStringType

protected boolean isStringType(org.apache.flink.table.types.logical.LogicalType logicalType)

Specified by:

isStringType in class AvroWithPartnerByStructureVisitor<org.apache.flink.table.types.logical.LogicalType,T>

isMapType

protected boolean isMapType(org.apache.flink.table.types.logical.LogicalType logicalType)

Specified by:

isMapType in class AvroWithPartnerByStructureVisitor<org.apache.flink.table.types.logical.LogicalType,T>

arrayElementType

protected org.apache.flink.table.types.logical.LogicalType arrayElementType(org.apache.flink.table.types.logical.LogicalType arrayType)

Specified by:

arrayElementType in class AvroWithPartnerByStructureVisitor<org.apache.flink.table.types.logical.LogicalType,T>

mapKeyType

protected org.apache.flink.table.types.logical.LogicalType mapKeyType(org.apache.flink.table.types.logical.LogicalType mapType)

Specified by:

mapKeyType in class AvroWithPartnerByStructureVisitor<org.apache.flink.table.types.logical.LogicalType,T>

mapValueType

protected org.apache.flink.table.types.logical.LogicalType mapValueType(org.apache.flink.table.types.logical.LogicalType mapType)

Specified by:

mapValueType in class AvroWithPartnerByStructureVisitor<org.apache.flink.table.types.logical.LogicalType,T>

fieldNameAndType

protected Pair<String,org.apache.flink.table.types.logical.LogicalType> fieldNameAndType(org.apache.flink.table.types.logical.LogicalType structType,
 int pos)

Specified by:

fieldNameAndType in class AvroWithPartnerByStructureVisitor<org.apache.flink.table.types.logical.LogicalType,T>

nullType

protected org.apache.flink.table.types.logical.LogicalType nullType()

Specified by:

nullType in class AvroWithPartnerByStructureVisitor<org.apache.flink.table.types.logical.LogicalType,T>