Class RowRowConverter
- java.lang.Object
-
- org.apache.flink.table.data.conversion.RowRowConverter
-
- All Implemented Interfaces:
Serializable,DataStructureConverter<org.apache.flink.table.data.RowData,org.apache.flink.types.Row>
@Internal public class RowRowConverter extends Object implements DataStructureConverter<org.apache.flink.table.data.RowData,org.apache.flink.types.Row>
Converter forRowTypeofRowexternal type.- See Also:
- Serialized Form
-
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static RowRowConvertercreate(org.apache.flink.table.types.DataType dataType)org.apache.flink.types.RowcreateEmptyRow()Used in code generation e.g. for generating emptyRowstate with named positions.voidopen(ClassLoader classLoader)org.apache.flink.types.RowtoExternal(org.apache.flink.table.data.RowData internal)Converts to external data structure.org.apache.flink.table.data.RowDatatoInternal(org.apache.flink.types.Row external)Converts to internal data structure.-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface org.apache.flink.table.data.conversion.DataStructureConverter
isIdentityConversion, toExternalOrNull, toInternalOrNull
-
-
-
-
Method Detail
-
open
public void open(ClassLoader classLoader)
- Specified by:
openin interfaceDataStructureConverter<org.apache.flink.table.data.RowData,org.apache.flink.types.Row>
-
toInternal
public org.apache.flink.table.data.RowData toInternal(org.apache.flink.types.Row external)
Description copied from interface:DataStructureConverterConverts to internal data structure.Note: Parameter must not be null. Output must not be null.
- Specified by:
toInternalin interfaceDataStructureConverter<org.apache.flink.table.data.RowData,org.apache.flink.types.Row>
-
toExternal
public org.apache.flink.types.Row toExternal(org.apache.flink.table.data.RowData internal)
Description copied from interface:DataStructureConverterConverts to external data structure.Note: Parameter must not be null. Output must not be null.
- Specified by:
toExternalin interfaceDataStructureConverter<org.apache.flink.table.data.RowData,org.apache.flink.types.Row>
-
createEmptyRow
public org.apache.flink.types.Row createEmptyRow()
Used in code generation e.g. for generating emptyRowstate with named positions.
-
create
public static RowRowConverter create(org.apache.flink.table.types.DataType dataType)
-
-