Package org.apache.iceberg.flink.data

Class AvroWithFlinkSchemaVisitor<T>

    • 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()  

      • Methods inherited from class java.lang.Object

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

    • Constructor Detail

      • AvroWithFlinkSchemaVisitor

        public AvroWithFlinkSchemaVisitor()

    • Method Detail

      • 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<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 class AvroWithPartnerByStructureVisitor<org.apache.flink.table.types.logical.LogicalType,​T>