Package org.apache.flink.table.data.util
Class DataFormatConverters
- java.lang.Object
-
- org.apache.flink.table.data.util.DataFormatConverters
-
public class DataFormatConverters extends Object
Converters between internal data format and java format.The following scenarios will use converter for java format to internal data format: In source, data from user define source to internal sql engine. In udx return value, User outputs java format data to the SQL engine.
The following scenarios will use converter for internal data format to java format: In udx method parameters, data from internal sql engine need to be provided to user udx. In sink, data from internal sql engine need to be provided to user define sink.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static classDataFormatConverters.AbstractRowDataConverter<E>Abstract converter for internal base row.static classDataFormatConverters.ArrayDataConverterConverter for ArrayData.static classDataFormatConverters.BigDecimalConverterConverter for BigDecimal.static classDataFormatConverters.BooleanConverterConverter for boolean.static classDataFormatConverters.ByteConverterConverter for byte.static classDataFormatConverters.CaseClassConverterConverter for case class.static classDataFormatConverters.DataFormatConverter<Internal,External>Converter between internal data format and java format.static classDataFormatConverters.DateConverterConverter for date.static classDataFormatConverters.DecimalDataConverterConverter for DecimalData.static classDataFormatConverters.DoubleConverterConverter for double.static classDataFormatConverters.FloatConverterConverter for float.static classDataFormatConverters.GenericConverter<T>Converter forRawValueData.static classDataFormatConverters.IdentityConverter<T>Identity converter.static classDataFormatConverters.InstantConverterConverter for Instant.static classDataFormatConverters.IntConverterConverter for int.static classDataFormatConverters.LocalDateConverterConverter for LocalDate.static classDataFormatConverters.LocalDateTimeConverterConverter for LocalDateTime.static classDataFormatConverters.LocalTimeConverterConverter for LocalTime.static classDataFormatConverters.LongConverterConverter for long.static classDataFormatConverters.LongTimestampDataConverterConverter for Long and TimestampData.static classDataFormatConverters.MapConverterConverter for map.static classDataFormatConverters.MapDataConverterConverter for MapData.static classDataFormatConverters.ObjectArrayConverter<T>Converter for object array.static classDataFormatConverters.PojoConverter<T>Converter for pojo.static classDataFormatConverters.PrimitiveBooleanArrayConverterConverter for primitive boolean array.static classDataFormatConverters.PrimitiveByteArrayConverterConverter for primitive byte array.static classDataFormatConverters.PrimitiveDoubleArrayConverterConverter for primitive double array.static classDataFormatConverters.PrimitiveFloatArrayConverterConverter for primitive float array.static classDataFormatConverters.PrimitiveIntArrayConverterConverter for primitive int array.static classDataFormatConverters.PrimitiveLongArrayConverterConverter for primitive long array.static classDataFormatConverters.PrimitiveShortArrayConverterConverter for primitive short array.static classDataFormatConverters.RawValueDataConverterConverter for RawValueData.static classDataFormatConverters.RowConverterConverter for row.static classDataFormatConverters.RowDataConverterConverter for base row.static classDataFormatConverters.ShortConverterConverter for short.static classDataFormatConverters.StringConverterConverter for String.static classDataFormatConverters.StringDataConverterConverter for StringData.static classDataFormatConverters.TimeConverterConverter for time.static classDataFormatConverters.TimestampConverterConverter for timestamp.static classDataFormatConverters.TimestampDataConverterConverter forTimestampDataclass.static classDataFormatConverters.TimestampLtzConverterConverter for timestamp which doesn't consider the time zone.static classDataFormatConverters.TupleConverterConverter for flink tuple.
-
Constructor Summary
Constructors Constructor Description DataFormatConverters()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static DataFormatConverters.DataFormatConvertergetConverterForDataType(org.apache.flink.table.types.DataType originDataType)GetDataFormatConverters.DataFormatConverterforDataType.
-
-
-
Method Detail
-
getConverterForDataType
public static DataFormatConverters.DataFormatConverter getConverterForDataType(org.apache.flink.table.types.DataType originDataType)
GetDataFormatConverters.DataFormatConverterforDataType.- Parameters:
originDataType- DataFormatConverter is oriented to Java format, while LogicalType has lost its specific Java format. Only DataType retains all its Java format information.
-
-