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 class
DataFormatConverters.AbstractRowDataConverter<E>
Abstract converter for internal base row.static class
DataFormatConverters.ArrayDataConverter
Converter for ArrayData.static class
DataFormatConverters.BigDecimalConverter
Converter for BigDecimal.static class
DataFormatConverters.BooleanConverter
Converter for boolean.static class
DataFormatConverters.ByteConverter
Converter for byte.static class
DataFormatConverters.CaseClassConverter
Converter for case class.static class
DataFormatConverters.DataFormatConverter<Internal,External>
Converter between internal data format and java format.static class
DataFormatConverters.DateConverter
Converter for date.static class
DataFormatConverters.DecimalDataConverter
Converter for DecimalData.static class
DataFormatConverters.DoubleConverter
Converter for double.static class
DataFormatConverters.FloatConverter
Converter for float.static class
DataFormatConverters.GenericConverter<T>
Converter forRawValueData
.static class
DataFormatConverters.IdentityConverter<T>
Identity converter.static class
DataFormatConverters.InstantConverter
Converter for Instant.static class
DataFormatConverters.IntConverter
Converter for int.static class
DataFormatConverters.LocalDateConverter
Converter for LocalDate.static class
DataFormatConverters.LocalDateTimeConverter
Converter for LocalDateTime.static class
DataFormatConverters.LocalTimeConverter
Converter for LocalTime.static class
DataFormatConverters.LongConverter
Converter for long.static class
DataFormatConverters.LongTimestampDataConverter
Converter for Long and TimestampData.static class
DataFormatConverters.MapConverter
Converter for map.static class
DataFormatConverters.MapDataConverter
Converter for MapData.static class
DataFormatConverters.ObjectArrayConverter<T>
Converter for object array.static class
DataFormatConverters.PojoConverter<T>
Converter for pojo.static class
DataFormatConverters.PrimitiveBooleanArrayConverter
Converter for primitive boolean array.static class
DataFormatConverters.PrimitiveByteArrayConverter
Converter for primitive byte array.static class
DataFormatConverters.PrimitiveDoubleArrayConverter
Converter for primitive double array.static class
DataFormatConverters.PrimitiveFloatArrayConverter
Converter for primitive float array.static class
DataFormatConverters.PrimitiveIntArrayConverter
Converter for primitive int array.static class
DataFormatConverters.PrimitiveLongArrayConverter
Converter for primitive long array.static class
DataFormatConverters.PrimitiveShortArrayConverter
Converter for primitive short array.static class
DataFormatConverters.RawValueDataConverter
Converter for RawValueData.static class
DataFormatConverters.RowConverter
Converter for row.static class
DataFormatConverters.RowDataConverter
Converter for base row.static class
DataFormatConverters.ShortConverter
Converter for short.static class
DataFormatConverters.StringConverter
Converter for String.static class
DataFormatConverters.StringDataConverter
Converter for StringData.static class
DataFormatConverters.TimeConverter
Converter for time.static class
DataFormatConverters.TimestampConverter
Converter for timestamp.static class
DataFormatConverters.TimestampDataConverter
Converter forTimestampData
class.static class
DataFormatConverters.TimestampLtzConverter
Converter for timestamp which doesn't consider the time zone.static class
DataFormatConverters.TupleConverter
Converter for flink tuple.
-
Constructor Summary
Constructors Constructor Description DataFormatConverters()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static DataFormatConverters.DataFormatConverter
getConverterForDataType(DataType originDataType)
-
-
-
Method Detail
-
getConverterForDataType
public static DataFormatConverters.DataFormatConverter getConverterForDataType(DataType originDataType)
- Parameters:
originDataType
- DataFormatConverter is oriented to Java format, while LogicalType has lost its specific Java format. Only DataType retains all its Java format information.
-
-