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

Class RowDataSerializer

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<org.apache.flink.table.data.RowData>

org.apache.flink.table.runtime.typeutils.RowDataSerializer

org.apache.flink.table.runtime.typeutils.serializers.python.RowDataSerializer

All Implemented Interfaces:

Serializable

@Internal
public class RowDataSerializer
extends org.apache.flink.table.runtime.typeutils.RowDataSerializer

A TypeSerializer for RowData. It should be noted that the row kind will be encoded as the first 2 bits instead of the first byte. Currently Python doesn't support RowData natively, so we can't use RowDataSerializer directly.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	RowDataSerializer.RowDataSerializerSnapshot	TypeSerializerSnapshot for RowDataSerializer.

Constructor Summary

Constructors

Constructor	Description
RowDataSerializer(org.apache.flink.table.types.logical.LogicalType[] types, org.apache.flink.api.common.typeutils.TypeSerializer[] fieldSerializers)

Method Summary

Modifier and Type	Method	Description
void	copy(org.apache.flink.core.memory.DataInputView source, org.apache.flink.core.memory.DataOutputView target)
org.apache.flink.table.data.RowData	deserialize(org.apache.flink.core.memory.DataInputView source)
org.apache.flink.table.data.RowData	deserialize(org.apache.flink.table.data.RowData reuse, org.apache.flink.core.memory.DataInputView source)
void	serialize(org.apache.flink.table.data.RowData row, org.apache.flink.core.memory.DataOutputView target)
org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<org.apache.flink.table.data.RowData>	snapshotConfiguration()

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

copy, copy, createInstance, deserializeFromPages, deserializeFromPages, duplicate, equals, getArity, getLength, hashCode, isImmutableType, mapFromPages, serializeToPages, skipRecordFromPages, toBinaryRow

Methods inherited from class java.lang.Object

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

Constructor Detail

RowDataSerializer

public RowDataSerializer(org.apache.flink.table.types.logical.LogicalType[] types,
                         org.apache.flink.api.common.typeutils.TypeSerializer[] fieldSerializers)

Method Detail

serialize

public void serialize(org.apache.flink.table.data.RowData row,
                      org.apache.flink.core.memory.DataOutputView target)
               throws IOException

Overrides:

serialize in class org.apache.flink.table.runtime.typeutils.RowDataSerializer

Throws:

IOException

deserialize

public org.apache.flink.table.data.RowData deserialize(org.apache.flink.core.memory.DataInputView source)
                                                throws IOException

Overrides:

deserialize in class org.apache.flink.table.runtime.typeutils.RowDataSerializer

Throws:

IOException

deserialize

public org.apache.flink.table.data.RowData deserialize(org.apache.flink.table.data.RowData reuse,
                                                       org.apache.flink.core.memory.DataInputView source)
                                                throws IOException

Overrides:

deserialize in class org.apache.flink.table.runtime.typeutils.RowDataSerializer

Throws:

IOException

copy

public void copy(org.apache.flink.core.memory.DataInputView source,
                 org.apache.flink.core.memory.DataOutputView target)
          throws IOException

Overrides:

copy in class org.apache.flink.table.runtime.typeutils.RowDataSerializer

Throws:

IOException

snapshotConfiguration

public org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<org.apache.flink.table.data.RowData> snapshotConfiguration()

Overrides:

snapshotConfiguration in class org.apache.flink.table.runtime.typeutils.RowDataSerializer