Package org.apache.flink.cdc.common.converter

Class JavaClassConverter

java.lang.Object

org.apache.flink.cdc.common.converter.JavaClassConverter

All Implemented Interfaces:

DataTypeVisitor<Class<?>>

public class JavaClassConverter
extends Object
implements DataTypeVisitor<Class<?>>

Converts a DataType to its Java representation that could be used in UDF manipulation.

Field Summary

Fields

Modifier and Type	Field	Description
static JavaClassConverter	INSTANCE

Method Summary

Modifier and Type	Method	Description
static Class<?>	toJavaClass(DataType dataType)
Class<?>	visit(ArrayType arrayType)
Class<?>	visit(BigIntType bigIntType)
Class<?>	visit(BinaryType binaryType)
Class<?>	visit(BooleanType booleanType)
Class<?>	visit(CharType charType)
Class<?>	visit(DateType dateType)
Class<?>	visit(DecimalType decimalType)
Class<?>	visit(DoubleType doubleType)
Class<?>	visit(FloatType floatType)
Class<?>	visit(IntType intType)
Class<?>	visit(LocalZonedTimestampType localZonedTimestampType)
Class<?>	visit(MapType mapType)
Class<?>	visit(RowType rowType)
Class<?>	visit(SmallIntType smallIntType)
Class<?>	visit(TimestampType timestampType)
Class<?>	visit(TimeType timeType)
Class<?>	visit(TinyIntType tinyIntType)
Class<?>	visit(VarBinaryType varBinaryType)
Class<?>	visit(VarCharType varCharType)
Class<?>	visit(VariantType variantType)
Class<?>	visit(ZonedTimestampType zonedTimestampType)

Methods inherited from class java.lang.Object

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

Field Detail

INSTANCE

public static final JavaClassConverter INSTANCE

Method Detail

toJavaClass

public static Class<?> toJavaClass(DataType dataType)

visit

public Class<?> visit(CharType charType)

Specified by:

visit in interface DataTypeVisitor<Class<?>>

visit

public Class<?> visit(VarCharType varCharType)

Specified by:

visit in interface DataTypeVisitor<Class<?>>

visit

public Class<?> visit(BooleanType booleanType)

Specified by:

visit in interface DataTypeVisitor<Class<?>>

visit

public Class<?> visit(BinaryType binaryType)

Specified by:

visit in interface DataTypeVisitor<Class<?>>

visit

public Class<?> visit(VarBinaryType varBinaryType)

Specified by:

visit in interface DataTypeVisitor<Class<?>>

visit

public Class<?> visit(DecimalType decimalType)

Specified by:

visit in interface DataTypeVisitor<Class<?>>

visit

public Class<?> visit(TinyIntType tinyIntType)

Specified by:

visit in interface DataTypeVisitor<Class<?>>

visit

public Class<?> visit(SmallIntType smallIntType)

Specified by:

visit in interface DataTypeVisitor<Class<?>>

visit

public Class<?> visit(IntType intType)

Specified by:

visit in interface DataTypeVisitor<Class<?>>

visit

public Class<?> visit(BigIntType bigIntType)

Specified by:

visit in interface DataTypeVisitor<Class<?>>

visit

public Class<?> visit(FloatType floatType)

Specified by:

visit in interface DataTypeVisitor<Class<?>>

visit

public Class<?> visit(DoubleType doubleType)

Specified by:

visit in interface DataTypeVisitor<Class<?>>

visit

public Class<?> visit(DateType dateType)

Specified by:

visit in interface DataTypeVisitor<Class<?>>

visit

public Class<?> visit(TimeType timeType)

Specified by:

visit in interface DataTypeVisitor<Class<?>>

visit

public Class<?> visit(TimestampType timestampType)

Specified by:

visit in interface DataTypeVisitor<Class<?>>

visit

public Class<?> visit(ZonedTimestampType zonedTimestampType)

Specified by:

visit in interface DataTypeVisitor<Class<?>>

visit

public Class<?> visit(LocalZonedTimestampType localZonedTimestampType)

Specified by:

visit in interface DataTypeVisitor<Class<?>>

visit

public Class<?> visit(ArrayType arrayType)

Specified by:

visit in interface DataTypeVisitor<Class<?>>

visit

public Class<?> visit(MapType mapType)

Specified by:

visit in interface DataTypeVisitor<Class<?>>

visit

public Class<?> visit(RowType rowType)

Specified by:

visit in interface DataTypeVisitor<Class<?>>

visit

public Class<?> visit(VariantType variantType)

Specified by:

visit in interface DataTypeVisitor<Class<?>>