public abstract class AvroWithFlinkSchemaVisitor<T> extends AvroWithPartnerByStructureVisitor<org.apache.flink.table.types.logical.LogicalType,T>
Constructor and Description |
---|
AvroWithFlinkSchemaVisitor() |
Modifier and Type | Method and 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() |
protected boolean isStringType(org.apache.flink.table.types.logical.LogicalType logicalType)
isStringType
in class AvroWithPartnerByStructureVisitor<org.apache.flink.table.types.logical.LogicalType,T>
protected boolean isMapType(org.apache.flink.table.types.logical.LogicalType logicalType)
isMapType
in class AvroWithPartnerByStructureVisitor<org.apache.flink.table.types.logical.LogicalType,T>
protected org.apache.flink.table.types.logical.LogicalType arrayElementType(org.apache.flink.table.types.logical.LogicalType arrayType)
arrayElementType
in class AvroWithPartnerByStructureVisitor<org.apache.flink.table.types.logical.LogicalType,T>
protected org.apache.flink.table.types.logical.LogicalType mapKeyType(org.apache.flink.table.types.logical.LogicalType mapType)
mapKeyType
in class AvroWithPartnerByStructureVisitor<org.apache.flink.table.types.logical.LogicalType,T>
protected org.apache.flink.table.types.logical.LogicalType mapValueType(org.apache.flink.table.types.logical.LogicalType mapType)
mapValueType
in class AvroWithPartnerByStructureVisitor<org.apache.flink.table.types.logical.LogicalType,T>
protected Pair<java.lang.String,org.apache.flink.table.types.logical.LogicalType> fieldNameAndType(org.apache.flink.table.types.logical.LogicalType structType, int pos)
fieldNameAndType
in class AvroWithPartnerByStructureVisitor<org.apache.flink.table.types.logical.LogicalType,T>
protected org.apache.flink.table.types.logical.LogicalType nullType()
nullType
in class AvroWithPartnerByStructureVisitor<org.apache.flink.table.types.logical.LogicalType,T>