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

Class NodeSerializer

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.Node>

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

All Implemented Interfaces:

Serializable

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

TypeSerializer for Node.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	NodeSerializer.NodeSerializerSnapshot	TypeSerializerSnapshot of NodeSerializer.NodeSerializerSnapshot.

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
protected	NodeSerializer(org.apache.flink.api.common.typeutils.CompositeSerializer.PrecomputedParameters precomputed, org.apache.flink.api.common.typeutils.TypeSerializer<?>[] originalSerializers)
	NodeSerializer(org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.RowData> serializer)

Method Summary

Modifier and Type	Method	Description
org.apache.flink.table.runtime.sequencedmultisetstate.linked.Node	createInstance(Object... values)
protected org.apache.flink.api.common.typeutils.CompositeSerializer<org.apache.flink.table.runtime.sequencedmultisetstate.linked.Node>	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.Node node, int index)
boolean	isImmutableType()
protected void	setField(org.apache.flink.table.runtime.sequencedmultisetstate.linked.Node value, int index, Object fieldValue)
org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<org.apache.flink.table.runtime.sequencedmultisetstate.linked.Node>	snapshotConfiguration()

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

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

Methods inherited from class java.lang.Object

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

Constructor Detail

NodeSerializer

public NodeSerializer(org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.RowData> serializer)

NodeSerializer

protected NodeSerializer(org.apache.flink.api.common.typeutils.CompositeSerializer.PrecomputedParameters precomputed,
                         org.apache.flink.api.common.typeutils.TypeSerializer<?>[] originalSerializers)

Method Detail

createInstance

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

Specified by:

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

isImmutableType

public boolean isImmutableType()

Overrides:

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

getField

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

Specified by:

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

createSerializerInstance

protected org.apache.flink.api.common.typeutils.CompositeSerializer<org.apache.flink.table.runtime.sequencedmultisetstate.linked.Node> 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.Node>

snapshotConfiguration

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

Specified by:

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

setField

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

Specified by:

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