Class DataStructureConverters
- java.lang.Object
-
- org.apache.flink.table.data.conversion.DataStructureConverters
-
@Internal public final class DataStructureConverters extends Object
Registry of available data structure converters.Data structure converters are used at the edges for the API for converting between internal structures (see
RowData
) and external structures (seeDataType.getConversionClass()
).This is useful for UDFs, sources, sinks, or exposing data in the API (e.g. via a
collect()
).Note: It is NOT the responsibility of a converter to normalize the data. Thus, a converter does neither change the precision of a timestamp nor prune/expand strings to their defined length. This might be the responsibility of data classes that are called transitively.
-
-
Constructor Summary
Constructors Constructor Description DataStructureConverters()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static DataStructureConverter<Object,Object>
getConverter(DataType dataType)
Returns a converter for the givenDataType
.
-
-
-
Method Detail
-
getConverter
public static DataStructureConverter<Object,Object> getConverter(DataType dataType)
Returns a converter for the givenDataType
.
-
-