Class Lockable.LockableTypeSerializer<E>
- java.lang.Object
-
- org.apache.flink.api.common.typeutils.TypeSerializer<Lockable<E>>
-
- org.apache.flink.cep.nfa.sharedbuffer.Lockable.LockableTypeSerializer<E>
-
- All Implemented Interfaces:
Serializable,org.apache.flink.api.common.typeutils.LegacySerializerSnapshotTransformer<Lockable<E>>
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 forLockable.- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description LockableTypeSerializer(org.apache.flink.api.common.typeutils.TypeSerializer<E> elementSerializer)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Lockable<E>copy(Lockable<E> from)Lockable<E>copy(Lockable<E> from, Lockable<E> reuse)voidcopy(org.apache.flink.core.memory.DataInputView source, org.apache.flink.core.memory.DataOutputView target)Lockable<E>createInstance()Lockable<E>deserialize(Lockable<E> reuse, org.apache.flink.core.memory.DataInputView source)Lockable<E>deserialize(org.apache.flink.core.memory.DataInputView source)Lockable.LockableTypeSerializer<E>duplicate()booleanequals(Object o)intgetLength()inthashCode()booleanisImmutableType()voidserialize(Lockable<E> record, org.apache.flink.core.memory.DataOutputView target)org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<Lockable<E>>snapshotConfiguration()<U> org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<Lockable<E>>transformLegacySerializerSnapshot(org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<U> legacySnapshot)
-
-
-
Constructor Detail
-
LockableTypeSerializer
public LockableTypeSerializer(org.apache.flink.api.common.typeutils.TypeSerializer<E> elementSerializer)
-
-
Method Detail
-
isImmutableType
public boolean isImmutableType()
-
duplicate
public Lockable.LockableTypeSerializer<E> duplicate()
-
getLength
public int getLength()
-
serialize
public void serialize(Lockable<E> record, org.apache.flink.core.memory.DataOutputView target) throws IOException
- Specified by:
serializein classorg.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:
deserializein classorg.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:
deserializein classorg.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:
copyin classorg.apache.flink.api.common.typeutils.TypeSerializer<Lockable<E>>- Throws:
IOException
-
equals
public boolean equals(Object o)
-
hashCode
public int hashCode()
-
snapshotConfiguration
public org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<Lockable<E>> snapshotConfiguration()
-
transformLegacySerializerSnapshot
public <U> org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<Lockable<E>> transformLegacySerializerSnapshot(org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<U> legacySnapshot)
- Specified by:
transformLegacySerializerSnapshotin interfaceorg.apache.flink.api.common.typeutils.LegacySerializerSnapshotTransformer<E>
-
-