org.apache.flink.table.runtime.typeutils

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:

LogicalTypeVisitor<FlinkFnApi.Schema.FieldType>

Enclosing class:

PythonTypeUtils

public static class PythonTypeUtils.LogicalTypeToProtoTypeConverter
extends LogicalTypeDefaultVisitor<FlinkFnApi.Schema.FieldType>

Converter That convert the logicalType to the related Prototype.

Constructor Summary

Constructors

Constructor and Description
LogicalTypeToProtoTypeConverter()

Method Summary

Modifier and Type	Method and Description
protected FlinkFnApi.Schema.FieldType	defaultMethod(LogicalType logicalType)
FlinkFnApi.Schema.FieldType	visit(ArrayType arrayType)
FlinkFnApi.Schema.FieldType	visit(BigIntType bigIntType)
FlinkFnApi.Schema.FieldType	visit(BinaryType binaryType)
FlinkFnApi.Schema.FieldType	visit(BooleanType booleanType)
FlinkFnApi.Schema.FieldType	visit(CharType charType)
FlinkFnApi.Schema.FieldType	visit(DateType dateType)
FlinkFnApi.Schema.FieldType	visit(DecimalType decimalType)
FlinkFnApi.Schema.FieldType	visit(DoubleType doubleType)
FlinkFnApi.Schema.FieldType	visit(FloatType floatType)
FlinkFnApi.Schema.FieldType	visit(IntType intType)
FlinkFnApi.Schema.FieldType	visit(LocalZonedTimestampType localZonedTimestampType)
FlinkFnApi.Schema.FieldType	visit(MapType mapType)
FlinkFnApi.Schema.FieldType	visit(RowType rowType)
FlinkFnApi.Schema.FieldType	visit(SmallIntType smallIntType)
FlinkFnApi.Schema.FieldType	visit(TimestampType timestampType)
FlinkFnApi.Schema.FieldType	visit(TimeType timeType)
FlinkFnApi.Schema.FieldType	visit(TinyIntType tinyIntType)
FlinkFnApi.Schema.FieldType	visit(VarBinaryType varBinaryType)
FlinkFnApi.Schema.FieldType	visit(VarCharType varCharType)

Methods inherited from class org.apache.flink.table.types.logical.utils.LogicalTypeDefaultVisitor

visit, visit, visit, visit, visit, visit, visit, visit, visit, visit

Methods inherited from class java.lang.Object

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

Constructor Detail

LogicalTypeToProtoTypeConverter

public LogicalTypeToProtoTypeConverter()

Method Detail

visit

public FlinkFnApi.Schema.FieldType visit(BooleanType booleanType)

Specified by:

visit in interface LogicalTypeVisitor<FlinkFnApi.Schema.FieldType>

Overrides:

visit in class LogicalTypeDefaultVisitor<FlinkFnApi.Schema.FieldType>

visit

public FlinkFnApi.Schema.FieldType visit(TinyIntType tinyIntType)

Specified by:

visit in interface LogicalTypeVisitor<FlinkFnApi.Schema.FieldType>

Overrides:

visit in class LogicalTypeDefaultVisitor<FlinkFnApi.Schema.FieldType>

visit

public FlinkFnApi.Schema.FieldType visit(SmallIntType smallIntType)

Specified by:

visit in interface LogicalTypeVisitor<FlinkFnApi.Schema.FieldType>

Overrides:

visit in class LogicalTypeDefaultVisitor<FlinkFnApi.Schema.FieldType>

visit

public FlinkFnApi.Schema.FieldType visit(IntType intType)

Specified by:

visit in interface LogicalTypeVisitor<FlinkFnApi.Schema.FieldType>

Overrides:

visit in class LogicalTypeDefaultVisitor<FlinkFnApi.Schema.FieldType>

visit

public FlinkFnApi.Schema.FieldType visit(BigIntType bigIntType)

Specified by:

visit in interface LogicalTypeVisitor<FlinkFnApi.Schema.FieldType>

Overrides:

visit in class LogicalTypeDefaultVisitor<FlinkFnApi.Schema.FieldType>

visit

public FlinkFnApi.Schema.FieldType visit(FloatType floatType)

Specified by:

visit in interface LogicalTypeVisitor<FlinkFnApi.Schema.FieldType>

Overrides:

visit in class LogicalTypeDefaultVisitor<FlinkFnApi.Schema.FieldType>

visit

public FlinkFnApi.Schema.FieldType visit(DoubleType doubleType)

Specified by:

visit in interface LogicalTypeVisitor<FlinkFnApi.Schema.FieldType>

Overrides:

visit in class LogicalTypeDefaultVisitor<FlinkFnApi.Schema.FieldType>

visit

public FlinkFnApi.Schema.FieldType visit(BinaryType binaryType)

Specified by:

visit in interface LogicalTypeVisitor<FlinkFnApi.Schema.FieldType>

Overrides:

visit in class LogicalTypeDefaultVisitor<FlinkFnApi.Schema.FieldType>

visit

public FlinkFnApi.Schema.FieldType visit(VarBinaryType varBinaryType)

Specified by:

visit in interface LogicalTypeVisitor<FlinkFnApi.Schema.FieldType>

Overrides:

visit in class LogicalTypeDefaultVisitor<FlinkFnApi.Schema.FieldType>

visit

public FlinkFnApi.Schema.FieldType visit(CharType charType)

Specified by:

visit in interface LogicalTypeVisitor<FlinkFnApi.Schema.FieldType>

Overrides:

visit in class LogicalTypeDefaultVisitor<FlinkFnApi.Schema.FieldType>

visit

public FlinkFnApi.Schema.FieldType visit(VarCharType varCharType)

Specified by:

visit in interface LogicalTypeVisitor<FlinkFnApi.Schema.FieldType>

Overrides:

visit in class LogicalTypeDefaultVisitor<FlinkFnApi.Schema.FieldType>

visit

public FlinkFnApi.Schema.FieldType visit(DateType dateType)

Specified by:

visit in interface LogicalTypeVisitor<FlinkFnApi.Schema.FieldType>

Overrides:

visit in class LogicalTypeDefaultVisitor<FlinkFnApi.Schema.FieldType>

visit

public FlinkFnApi.Schema.FieldType visit(TimeType timeType)

Specified by:

visit in interface LogicalTypeVisitor<FlinkFnApi.Schema.FieldType>

Overrides:

visit in class LogicalTypeDefaultVisitor<FlinkFnApi.Schema.FieldType>

visit

public FlinkFnApi.Schema.FieldType visit(TimestampType timestampType)

Specified by:

visit in interface LogicalTypeVisitor<FlinkFnApi.Schema.FieldType>

Overrides:

visit in class LogicalTypeDefaultVisitor<FlinkFnApi.Schema.FieldType>

visit

public FlinkFnApi.Schema.FieldType visit(LocalZonedTimestampType localZonedTimestampType)

Specified by:

visit in interface LogicalTypeVisitor<FlinkFnApi.Schema.FieldType>

Overrides:

visit in class LogicalTypeDefaultVisitor<FlinkFnApi.Schema.FieldType>

visit

public FlinkFnApi.Schema.FieldType visit(DecimalType decimalType)

Specified by:

visit in interface LogicalTypeVisitor<FlinkFnApi.Schema.FieldType>

Overrides:

visit in class LogicalTypeDefaultVisitor<FlinkFnApi.Schema.FieldType>

visit

public FlinkFnApi.Schema.FieldType visit(ArrayType arrayType)

Specified by:

visit in interface LogicalTypeVisitor<FlinkFnApi.Schema.FieldType>

Overrides:

visit in class LogicalTypeDefaultVisitor<FlinkFnApi.Schema.FieldType>

visit

public FlinkFnApi.Schema.FieldType visit(MapType mapType)

Specified by:

visit in interface LogicalTypeVisitor<FlinkFnApi.Schema.FieldType>

Overrides:

visit in class LogicalTypeDefaultVisitor<FlinkFnApi.Schema.FieldType>

visit

public FlinkFnApi.Schema.FieldType visit(RowType rowType)

Specified by:

visit in interface LogicalTypeVisitor<FlinkFnApi.Schema.FieldType>

Overrides:

visit in class LogicalTypeDefaultVisitor<FlinkFnApi.Schema.FieldType>

defaultMethod

protected FlinkFnApi.Schema.FieldType defaultMethod(LogicalType logicalType)

Specified by:

defaultMethod in class LogicalTypeDefaultVisitor<FlinkFnApi.Schema.FieldType>