Class NodeSerializer.NodeSerializerSnapshot
- java.lang.Object
-
- org.apache.flink.api.common.typeutils.CompositeTypeSerializerSnapshot<org.apache.flink.table.runtime.sequencedmultisetstate.linked.Node,NodeSerializer>
-
- org.apache.flink.table.runtime.sequencedmultisetstate.linked.NodeSerializer.NodeSerializerSnapshot
-
- All Implemented Interfaces:
org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<org.apache.flink.table.runtime.sequencedmultisetstate.linked.Node>
- Enclosing class:
- NodeSerializer
public static class NodeSerializer.NodeSerializerSnapshot extends org.apache.flink.api.common.typeutils.CompositeTypeSerializerSnapshot<org.apache.flink.table.runtime.sequencedmultisetstate.linked.Node,NodeSerializer>
TypeSerializerSnapshotofNodeSerializer.NodeSerializerSnapshot.
-
-
Constructor Summary
Constructors Constructor Description NodeSerializerSnapshot()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected NodeSerializercreateOuterSerializerWithNestedSerializers(org.apache.flink.api.common.typeutils.TypeSerializer<?>[] nestedSerializers)protected intgetCurrentOuterSnapshotVersion()protected org.apache.flink.api.common.typeutils.TypeSerializer<?>[]getNestedSerializers(NodeSerializer outerSerializer)-
Methods inherited from class org.apache.flink.api.common.typeutils.CompositeTypeSerializerSnapshot
getCurrentVersion, getNestedSerializerSnapshots, isOuterSnapshotCompatible, readOuterSnapshot, readSnapshot, resolveOuterSchemaCompatibility, resolveOuterSchemaCompatibility, resolveSchemaCompatibility, restoreSerializer, writeOuterSnapshot, writeSnapshot
-
-
-
-
Method Detail
-
getCurrentOuterSnapshotVersion
protected int getCurrentOuterSnapshotVersion()
- Specified by:
getCurrentOuterSnapshotVersionin classorg.apache.flink.api.common.typeutils.CompositeTypeSerializerSnapshot<org.apache.flink.table.runtime.sequencedmultisetstate.linked.Node,NodeSerializer>
-
getNestedSerializers
protected org.apache.flink.api.common.typeutils.TypeSerializer<?>[] getNestedSerializers(NodeSerializer outerSerializer)
- Specified by:
getNestedSerializersin classorg.apache.flink.api.common.typeutils.CompositeTypeSerializerSnapshot<org.apache.flink.table.runtime.sequencedmultisetstate.linked.Node,NodeSerializer>
-
createOuterSerializerWithNestedSerializers
protected NodeSerializer createOuterSerializerWithNestedSerializers(org.apache.flink.api.common.typeutils.TypeSerializer<?>[] nestedSerializers)
- Specified by:
createOuterSerializerWithNestedSerializersin classorg.apache.flink.api.common.typeutils.CompositeTypeSerializerSnapshot<org.apache.flink.table.runtime.sequencedmultisetstate.linked.Node,NodeSerializer>
-
-