Class PythonTypeUtils.LogicalTypeToProtoTypeConverter
- java.lang.Object
-
- org.apache.flink.table.types.logical.utils.LogicalTypeDefaultVisitor<FlinkFnApi.Schema.FieldType>
-
- org.apache.flink.table.runtime.typeutils.PythonTypeUtils.LogicalTypeToProtoTypeConverter
-
- All Implemented Interfaces:
org.apache.flink.table.types.logical.LogicalTypeVisitor<FlinkFnApi.Schema.FieldType>
- Enclosing class:
- PythonTypeUtils
public static class PythonTypeUtils.LogicalTypeToProtoTypeConverter extends org.apache.flink.table.types.logical.utils.LogicalTypeDefaultVisitor<FlinkFnApi.Schema.FieldType>
Converter That convert the logicalType to the related Prototype.
-
-
Constructor Summary
Constructors Constructor Description LogicalTypeToProtoTypeConverter()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected FlinkFnApi.Schema.FieldTypedefaultMethod(org.apache.flink.table.types.logical.LogicalType logicalType)FlinkFnApi.Schema.FieldTypevisit(org.apache.flink.table.types.logical.ArrayType arrayType)FlinkFnApi.Schema.FieldTypevisit(org.apache.flink.table.types.logical.BigIntType bigIntType)FlinkFnApi.Schema.FieldTypevisit(org.apache.flink.table.types.logical.BinaryType binaryType)FlinkFnApi.Schema.FieldTypevisit(org.apache.flink.table.types.logical.BooleanType booleanType)FlinkFnApi.Schema.FieldTypevisit(org.apache.flink.table.types.logical.CharType charType)FlinkFnApi.Schema.FieldTypevisit(org.apache.flink.table.types.logical.DateType dateType)FlinkFnApi.Schema.FieldTypevisit(org.apache.flink.table.types.logical.DecimalType decimalType)FlinkFnApi.Schema.FieldTypevisit(org.apache.flink.table.types.logical.DoubleType doubleType)FlinkFnApi.Schema.FieldTypevisit(org.apache.flink.table.types.logical.FloatType floatType)FlinkFnApi.Schema.FieldTypevisit(org.apache.flink.table.types.logical.IntType intType)FlinkFnApi.Schema.FieldTypevisit(org.apache.flink.table.types.logical.LocalZonedTimestampType localZonedTimestampType)FlinkFnApi.Schema.FieldTypevisit(org.apache.flink.table.types.logical.MapType mapType)FlinkFnApi.Schema.FieldTypevisit(org.apache.flink.table.types.logical.RowType rowType)FlinkFnApi.Schema.FieldTypevisit(org.apache.flink.table.types.logical.SmallIntType smallIntType)FlinkFnApi.Schema.FieldTypevisit(org.apache.flink.table.types.logical.TimestampType timestampType)FlinkFnApi.Schema.FieldTypevisit(org.apache.flink.table.types.logical.TimeType timeType)FlinkFnApi.Schema.FieldTypevisit(org.apache.flink.table.types.logical.TinyIntType tinyIntType)FlinkFnApi.Schema.FieldTypevisit(org.apache.flink.table.types.logical.VarBinaryType varBinaryType)FlinkFnApi.Schema.FieldTypevisit(org.apache.flink.table.types.logical.VarCharType varCharType)-
Methods inherited from class org.apache.flink.table.types.logical.utils.LogicalTypeDefaultVisitor
visit, visit, visit, visit, visit, visit, visit, visit, visit, visit
-
-
-
-
Method Detail
-
visit
public FlinkFnApi.Schema.FieldType visit(org.apache.flink.table.types.logical.BooleanType booleanType)
- Specified by:
visitin interfaceorg.apache.flink.table.types.logical.LogicalTypeVisitor<FlinkFnApi.Schema.FieldType>- Overrides:
visitin classorg.apache.flink.table.types.logical.utils.LogicalTypeDefaultVisitor<FlinkFnApi.Schema.FieldType>
-
visit
public FlinkFnApi.Schema.FieldType visit(org.apache.flink.table.types.logical.TinyIntType tinyIntType)
- Specified by:
visitin interfaceorg.apache.flink.table.types.logical.LogicalTypeVisitor<FlinkFnApi.Schema.FieldType>- Overrides:
visitin classorg.apache.flink.table.types.logical.utils.LogicalTypeDefaultVisitor<FlinkFnApi.Schema.FieldType>
-
visit
public FlinkFnApi.Schema.FieldType visit(org.apache.flink.table.types.logical.SmallIntType smallIntType)
- Specified by:
visitin interfaceorg.apache.flink.table.types.logical.LogicalTypeVisitor<FlinkFnApi.Schema.FieldType>- Overrides:
visitin classorg.apache.flink.table.types.logical.utils.LogicalTypeDefaultVisitor<FlinkFnApi.Schema.FieldType>
-
visit
public FlinkFnApi.Schema.FieldType visit(org.apache.flink.table.types.logical.IntType intType)
- Specified by:
visitin interfaceorg.apache.flink.table.types.logical.LogicalTypeVisitor<FlinkFnApi.Schema.FieldType>- Overrides:
visitin classorg.apache.flink.table.types.logical.utils.LogicalTypeDefaultVisitor<FlinkFnApi.Schema.FieldType>
-
visit
public FlinkFnApi.Schema.FieldType visit(org.apache.flink.table.types.logical.BigIntType bigIntType)
- Specified by:
visitin interfaceorg.apache.flink.table.types.logical.LogicalTypeVisitor<FlinkFnApi.Schema.FieldType>- Overrides:
visitin classorg.apache.flink.table.types.logical.utils.LogicalTypeDefaultVisitor<FlinkFnApi.Schema.FieldType>
-
visit
public FlinkFnApi.Schema.FieldType visit(org.apache.flink.table.types.logical.FloatType floatType)
- Specified by:
visitin interfaceorg.apache.flink.table.types.logical.LogicalTypeVisitor<FlinkFnApi.Schema.FieldType>- Overrides:
visitin classorg.apache.flink.table.types.logical.utils.LogicalTypeDefaultVisitor<FlinkFnApi.Schema.FieldType>
-
visit
public FlinkFnApi.Schema.FieldType visit(org.apache.flink.table.types.logical.DoubleType doubleType)
- Specified by:
visitin interfaceorg.apache.flink.table.types.logical.LogicalTypeVisitor<FlinkFnApi.Schema.FieldType>- Overrides:
visitin classorg.apache.flink.table.types.logical.utils.LogicalTypeDefaultVisitor<FlinkFnApi.Schema.FieldType>
-
visit
public FlinkFnApi.Schema.FieldType visit(org.apache.flink.table.types.logical.BinaryType binaryType)
- Specified by:
visitin interfaceorg.apache.flink.table.types.logical.LogicalTypeVisitor<FlinkFnApi.Schema.FieldType>- Overrides:
visitin classorg.apache.flink.table.types.logical.utils.LogicalTypeDefaultVisitor<FlinkFnApi.Schema.FieldType>
-
visit
public FlinkFnApi.Schema.FieldType visit(org.apache.flink.table.types.logical.VarBinaryType varBinaryType)
- Specified by:
visitin interfaceorg.apache.flink.table.types.logical.LogicalTypeVisitor<FlinkFnApi.Schema.FieldType>- Overrides:
visitin classorg.apache.flink.table.types.logical.utils.LogicalTypeDefaultVisitor<FlinkFnApi.Schema.FieldType>
-
visit
public FlinkFnApi.Schema.FieldType visit(org.apache.flink.table.types.logical.CharType charType)
- Specified by:
visitin interfaceorg.apache.flink.table.types.logical.LogicalTypeVisitor<FlinkFnApi.Schema.FieldType>- Overrides:
visitin classorg.apache.flink.table.types.logical.utils.LogicalTypeDefaultVisitor<FlinkFnApi.Schema.FieldType>
-
visit
public FlinkFnApi.Schema.FieldType visit(org.apache.flink.table.types.logical.VarCharType varCharType)
- Specified by:
visitin interfaceorg.apache.flink.table.types.logical.LogicalTypeVisitor<FlinkFnApi.Schema.FieldType>- Overrides:
visitin classorg.apache.flink.table.types.logical.utils.LogicalTypeDefaultVisitor<FlinkFnApi.Schema.FieldType>
-
visit
public FlinkFnApi.Schema.FieldType visit(org.apache.flink.table.types.logical.DateType dateType)
- Specified by:
visitin interfaceorg.apache.flink.table.types.logical.LogicalTypeVisitor<FlinkFnApi.Schema.FieldType>- Overrides:
visitin classorg.apache.flink.table.types.logical.utils.LogicalTypeDefaultVisitor<FlinkFnApi.Schema.FieldType>
-
visit
public FlinkFnApi.Schema.FieldType visit(org.apache.flink.table.types.logical.TimeType timeType)
- Specified by:
visitin interfaceorg.apache.flink.table.types.logical.LogicalTypeVisitor<FlinkFnApi.Schema.FieldType>- Overrides:
visitin classorg.apache.flink.table.types.logical.utils.LogicalTypeDefaultVisitor<FlinkFnApi.Schema.FieldType>
-
visit
public FlinkFnApi.Schema.FieldType visit(org.apache.flink.table.types.logical.TimestampType timestampType)
- Specified by:
visitin interfaceorg.apache.flink.table.types.logical.LogicalTypeVisitor<FlinkFnApi.Schema.FieldType>- Overrides:
visitin classorg.apache.flink.table.types.logical.utils.LogicalTypeDefaultVisitor<FlinkFnApi.Schema.FieldType>
-
visit
public FlinkFnApi.Schema.FieldType visit(org.apache.flink.table.types.logical.LocalZonedTimestampType localZonedTimestampType)
- Specified by:
visitin interfaceorg.apache.flink.table.types.logical.LogicalTypeVisitor<FlinkFnApi.Schema.FieldType>- Overrides:
visitin classorg.apache.flink.table.types.logical.utils.LogicalTypeDefaultVisitor<FlinkFnApi.Schema.FieldType>
-
visit
public FlinkFnApi.Schema.FieldType visit(org.apache.flink.table.types.logical.DecimalType decimalType)
- Specified by:
visitin interfaceorg.apache.flink.table.types.logical.LogicalTypeVisitor<FlinkFnApi.Schema.FieldType>- Overrides:
visitin classorg.apache.flink.table.types.logical.utils.LogicalTypeDefaultVisitor<FlinkFnApi.Schema.FieldType>
-
visit
public FlinkFnApi.Schema.FieldType visit(org.apache.flink.table.types.logical.ArrayType arrayType)
- Specified by:
visitin interfaceorg.apache.flink.table.types.logical.LogicalTypeVisitor<FlinkFnApi.Schema.FieldType>- Overrides:
visitin classorg.apache.flink.table.types.logical.utils.LogicalTypeDefaultVisitor<FlinkFnApi.Schema.FieldType>
-
visit
public FlinkFnApi.Schema.FieldType visit(org.apache.flink.table.types.logical.MapType mapType)
- Specified by:
visitin interfaceorg.apache.flink.table.types.logical.LogicalTypeVisitor<FlinkFnApi.Schema.FieldType>- Overrides:
visitin classorg.apache.flink.table.types.logical.utils.LogicalTypeDefaultVisitor<FlinkFnApi.Schema.FieldType>
-
visit
public FlinkFnApi.Schema.FieldType visit(org.apache.flink.table.types.logical.RowType rowType)
- Specified by:
visitin interfaceorg.apache.flink.table.types.logical.LogicalTypeVisitor<FlinkFnApi.Schema.FieldType>- Overrides:
visitin classorg.apache.flink.table.types.logical.utils.LogicalTypeDefaultVisitor<FlinkFnApi.Schema.FieldType>
-
defaultMethod
protected FlinkFnApi.Schema.FieldType defaultMethod(org.apache.flink.table.types.logical.LogicalType logicalType)
- Specified by:
defaultMethodin classorg.apache.flink.table.types.logical.utils.LogicalTypeDefaultVisitor<FlinkFnApi.Schema.FieldType>
-
-