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>