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
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected org.apache.flink.table.types.logical.LogicalType
arrayElementType(org.apache.flink.table.types.logical.LogicalType arrayType)
protected Pair<java.lang.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()
-
-
-
Method Detail
-
isStringType
protected boolean isStringType(org.apache.flink.table.types.logical.LogicalType logicalType)
- Specified by:
isStringType
in classAvroWithPartnerByStructureVisitor<org.apache.flink.table.types.logical.LogicalType,T>
-
isMapType
protected boolean isMapType(org.apache.flink.table.types.logical.LogicalType logicalType)
- Specified by:
isMapType
in classAvroWithPartnerByStructureVisitor<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 classAvroWithPartnerByStructureVisitor<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 classAvroWithPartnerByStructureVisitor<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 classAvroWithPartnerByStructureVisitor<org.apache.flink.table.types.logical.LogicalType,T>
-
fieldNameAndType
protected Pair<java.lang.String,org.apache.flink.table.types.logical.LogicalType> fieldNameAndType(org.apache.flink.table.types.logical.LogicalType structType, int pos)
- Specified by:
fieldNameAndType
in classAvroWithPartnerByStructureVisitor<org.apache.flink.table.types.logical.LogicalType,T>
-
nullType
protected org.apache.flink.table.types.logical.LogicalType nullType()
- Specified by:
nullType
in classAvroWithPartnerByStructureVisitor<org.apache.flink.table.types.logical.LogicalType,T>
-
-