Class 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>
    TypeSerializerSnapshot of NodeSerializer.NodeSerializerSnapshot.
    • Constructor Detail

      • NodeSerializerSnapshot

        public NodeSerializerSnapshot()
    • Method Detail

      • getCurrentOuterSnapshotVersion

        protected int getCurrentOuterSnapshotVersion()
        Specified by:
        getCurrentOuterSnapshotVersion in class org.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:
        getNestedSerializers in class org.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:
        createOuterSerializerWithNestedSerializers in class org.apache.flink.api.common.typeutils.CompositeTypeSerializerSnapshot<org.apache.flink.table.runtime.sequencedmultisetstate.linked.Node,​NodeSerializer>