Class MetaSqnInfoSerializer.MetaSqnInfoSerializerSnapshot

  • All Implemented Interfaces:
    org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<org.apache.flink.table.runtime.sequencedmultisetstate.linked.MetaSqnInfo>
    Enclosing class:
    MetaSqnInfoSerializer

    public static class MetaSqnInfoSerializer.MetaSqnInfoSerializerSnapshot
    extends org.apache.flink.api.common.typeutils.CompositeTypeSerializerSnapshot<org.apache.flink.table.runtime.sequencedmultisetstate.linked.MetaSqnInfo,​MetaSqnInfoSerializer>
    • Constructor Detail

      • MetaSqnInfoSerializerSnapshot

        public MetaSqnInfoSerializerSnapshot()
    • 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.MetaSqnInfo,​MetaSqnInfoSerializer>
      • getNestedSerializers

        protected org.apache.flink.api.common.typeutils.TypeSerializer<?>[] getNestedSerializers​(MetaSqnInfoSerializer outerSerializer)
        Specified by:
        getNestedSerializers in class org.apache.flink.api.common.typeutils.CompositeTypeSerializerSnapshot<org.apache.flink.table.runtime.sequencedmultisetstate.linked.MetaSqnInfo,​MetaSqnInfoSerializer>
      • createOuterSerializerWithNestedSerializers

        protected MetaSqnInfoSerializer 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.MetaSqnInfo,​MetaSqnInfoSerializer>