Class Lockable.LockableTypeSerializer<E>

  • All Implemented Interfaces:
    Serializable, org.apache.flink.api.common.typeutils.LegacySerializerSnapshotTransformer<Lockable<E>>
    Enclosing class:
    Lockable<T>

    public static class Lockable.LockableTypeSerializer<E>
    extends org.apache.flink.api.common.typeutils.TypeSerializer<Lockable<E>>
    implements org.apache.flink.api.common.typeutils.LegacySerializerSnapshotTransformer<Lockable<E>>
    Serializer for Lockable.
    See Also:
    Serialized Form
    • Constructor Detail

      • LockableTypeSerializer

        public LockableTypeSerializer​(org.apache.flink.api.common.typeutils.TypeSerializer<E> elementSerializer)
    • Method Detail

      • isImmutableType

        public boolean isImmutableType()
        Specified by:
        isImmutableType in class org.apache.flink.api.common.typeutils.TypeSerializer<Lockable<E>>
      • createInstance

        public Lockable<E> createInstance()
        Specified by:
        createInstance in class org.apache.flink.api.common.typeutils.TypeSerializer<Lockable<E>>
      • copy

        public Lockable<E> copy​(Lockable<E> from)
        Specified by:
        copy in class org.apache.flink.api.common.typeutils.TypeSerializer<Lockable<E>>
      • getLength

        public int getLength()
        Specified by:
        getLength in class org.apache.flink.api.common.typeutils.TypeSerializer<Lockable<E>>
      • serialize

        public void serialize​(Lockable<E> record,
                              org.apache.flink.core.memory.DataOutputView target)
                       throws IOException
        Specified by:
        serialize in class org.apache.flink.api.common.typeutils.TypeSerializer<Lockable<E>>
        Throws:
        IOException
      • deserialize

        public Lockable<E> deserialize​(org.apache.flink.core.memory.DataInputView source)
                                throws IOException
        Specified by:
        deserialize in class org.apache.flink.api.common.typeutils.TypeSerializer<Lockable<E>>
        Throws:
        IOException
      • deserialize

        public Lockable<E> deserialize​(Lockable<E> reuse,
                                       org.apache.flink.core.memory.DataInputView source)
                                throws IOException
        Specified by:
        deserialize in class org.apache.flink.api.common.typeutils.TypeSerializer<Lockable<E>>
        Throws:
        IOException
      • copy

        public void copy​(org.apache.flink.core.memory.DataInputView source,
                         org.apache.flink.core.memory.DataOutputView target)
                  throws IOException
        Specified by:
        copy in class org.apache.flink.api.common.typeutils.TypeSerializer<Lockable<E>>
        Throws:
        IOException
      • equals

        public boolean equals​(Object o)
        Specified by:
        equals in class org.apache.flink.api.common.typeutils.TypeSerializer<Lockable<E>>
      • hashCode

        public int hashCode()
        Specified by:
        hashCode in class org.apache.flink.api.common.typeutils.TypeSerializer<Lockable<E>>
      • snapshotConfiguration

        public org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<Lockable<E>> snapshotConfiguration()
        Specified by:
        snapshotConfiguration in class org.apache.flink.api.common.typeutils.TypeSerializer<Lockable<E>>
      • transformLegacySerializerSnapshot

        public <U> org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<Lockable<E>> transformLegacySerializerSnapshot​(org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<U> legacySnapshot)
        Specified by:
        transformLegacySerializerSnapshot in interface org.apache.flink.api.common.typeutils.LegacySerializerSnapshotTransformer<E>