Package org.apache.flink.table.runtime.typeutils

Class AbstractRowDataSerializer<T extends org.apache.flink.table.data.RowData>

java.lang.Object

org.apache.flink.api.common.typeutils.TypeSerializer<T>

org.apache.flink.table.runtime.typeutils.PagedTypeSerializer<T>

org.apache.flink.table.runtime.typeutils.AbstractRowDataSerializer<T>

All Implemented Interfaces:

Serializable

Direct Known Subclasses:

BinaryRowDataSerializer, RowDataSerializer

@Internal
public abstract class AbstractRowDataSerializer<T extends org.apache.flink.table.data.RowData>
extends PagedTypeSerializer<T>

Row serializer, provided paged serialize paged method.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
AbstractRowDataSerializer()

Method Summary

Modifier and Type	Method	Description
abstract int	getArity()	Get the number of fields.
abstract org.apache.flink.table.data.binary.BinaryRowData	toBinaryRow(T rowData)	Convert a RowData to a BinaryRowData.

Methods inherited from class org.apache.flink.table.runtime.typeutils.PagedTypeSerializer

deserializeFromPages, deserializeFromPages, mapFromPages, serializeToPages, skipRecordFromPages

Methods inherited from class org.apache.flink.api.common.typeutils.TypeSerializer

copy, copy, copy, createInstance, deserialize, deserialize, duplicate, equals, getLength, hashCode, isImmutableType, serialize, snapshotConfiguration

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractRowDataSerializer

public AbstractRowDataSerializer()

Method Detail

getArity

public abstract int getArity()

Get the number of fields.

toBinaryRow

public abstract org.apache.flink.table.data.binary.BinaryRowData toBinaryRow(T rowData)
                                                                      throws IOException

Convert a RowData to a BinaryRowData.

Throws:

IOException