Package org.apache.flink.table.runtime.sequencedmultisetstate.linked

Class RowSqnInfoSerializer

java.lang.Object

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

org.apache.flink.api.common.typeutils.CompositeSerializer<org.apache.flink.table.runtime.sequencedmultisetstate.linked.RowSqnInfo>

org.apache.flink.table.runtime.sequencedmultisetstate.linked.RowSqnInfoSerializer

All Implemented Interfaces:

Serializable

public class RowSqnInfoSerializer
extends org.apache.flink.api.common.typeutils.CompositeSerializer<org.apache.flink.table.runtime.sequencedmultisetstate.linked.RowSqnInfo>

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	RowSqnInfoSerializer.RowSqnInfoSerializerSnapshot

Nested classes/interfaces inherited from class org.apache.flink.api.common.typeutils.CompositeSerializer

org.apache.flink.api.common.typeutils.CompositeSerializer.PrecomputedParameters

Field Summary

Fields inherited from class org.apache.flink.api.common.typeutils.CompositeSerializer

fieldSerializers

Constructor Summary

Constructors

Modifier	Constructor	Description
	RowSqnInfoSerializer()
protected	RowSqnInfoSerializer(org.apache.flink.api.common.typeutils.CompositeSerializer.PrecomputedParameters precomputed, org.apache.flink.api.common.typeutils.TypeSerializer<?>... fieldSerializers)

Method Summary

Modifier and Type	Method	Description
org.apache.flink.table.runtime.sequencedmultisetstate.linked.RowSqnInfo	createInstance(Object... values)
protected org.apache.flink.api.common.typeutils.CompositeSerializer<org.apache.flink.table.runtime.sequencedmultisetstate.linked.RowSqnInfo>	createSerializerInstance(org.apache.flink.api.common.typeutils.CompositeSerializer.PrecomputedParameters precomputed, org.apache.flink.api.common.typeutils.TypeSerializer<?>... originalSerializers)
protected Object	getField(org.apache.flink.table.runtime.sequencedmultisetstate.linked.RowSqnInfo value, int index)
protected void	setField(org.apache.flink.table.runtime.sequencedmultisetstate.linked.RowSqnInfo sqnInfo, int index, Object fieldValue)
org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<org.apache.flink.table.runtime.sequencedmultisetstate.linked.RowSqnInfo>	snapshotConfiguration()

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

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

Methods inherited from class java.lang.Object

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

Constructor Detail

RowSqnInfoSerializer

public RowSqnInfoSerializer()

RowSqnInfoSerializer

protected RowSqnInfoSerializer(org.apache.flink.api.common.typeutils.CompositeSerializer.PrecomputedParameters precomputed,
                               org.apache.flink.api.common.typeutils.TypeSerializer<?>... fieldSerializers)

Method Detail

createInstance

public org.apache.flink.table.runtime.sequencedmultisetstate.linked.RowSqnInfo createInstance(Object... values)

Specified by:

createInstance in class org.apache.flink.api.common.typeutils.CompositeSerializer<org.apache.flink.table.runtime.sequencedmultisetstate.linked.RowSqnInfo>

setField

protected void setField(org.apache.flink.table.runtime.sequencedmultisetstate.linked.RowSqnInfo sqnInfo,
                        int index,
                        Object fieldValue)

Specified by:

setField in class org.apache.flink.api.common.typeutils.CompositeSerializer<org.apache.flink.table.runtime.sequencedmultisetstate.linked.RowSqnInfo>

getField

protected Object getField(org.apache.flink.table.runtime.sequencedmultisetstate.linked.RowSqnInfo value,
                          int index)

Specified by:

getField in class org.apache.flink.api.common.typeutils.CompositeSerializer<org.apache.flink.table.runtime.sequencedmultisetstate.linked.RowSqnInfo>

createSerializerInstance

protected org.apache.flink.api.common.typeutils.CompositeSerializer<org.apache.flink.table.runtime.sequencedmultisetstate.linked.RowSqnInfo> createSerializerInstance(org.apache.flink.api.common.typeutils.CompositeSerializer.PrecomputedParameters precomputed,
                                                                                                                                                                      org.apache.flink.api.common.typeutils.TypeSerializer<?>... originalSerializers)

Specified by:

createSerializerInstance in class org.apache.flink.api.common.typeutils.CompositeSerializer<org.apache.flink.table.runtime.sequencedmultisetstate.linked.RowSqnInfo>

snapshotConfiguration

public org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<org.apache.flink.table.runtime.sequencedmultisetstate.linked.RowSqnInfo> snapshotConfiguration()

Specified by:

snapshotConfiguration in class org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.runtime.sequencedmultisetstate.linked.RowSqnInfo>