org.apache.flink.api.common.typeutils.base

Class TypeSerializerSingleton<T>

java.lang.Object

org.apache.flink.api.common.typeutils.TypeSerializer<T>

org.apache.flink.api.common.typeutils.base.TypeSerializerSingleton<T>

All Implemented Interfaces:

Serializable

Direct Known Subclasses:

BigDecSerializer, BigDecSerializer, BigIntSerializer, BooleanPrimitiveArraySerializer, BooleanSerializer, BooleanValueSerializer, ByteArrayWrapperSerializer, BytePrimitiveArraySerializer, ByteSerializer, ByteValueSerializer, CharPrimitiveArraySerializer, CharSerializer, CharValueSerializer, CountWindow.Serializer, DateSerializer, DateSerializer, DeweyNumber.DeweyNumberSerializer, DoublePrimitiveArraySerializer, DoubleSerializer, DoubleValueSerializer, EventId.EventIdSerializer, FloatPrimitiveArraySerializer, FloatSerializer, FloatValueSerializer, GlobalWindow.Serializer, InstantSerializer, IntPrimitiveArraySerializer, IntSerializer, IntValueSerializer, JavaSerializer, LocalDateSerializer, LocalDateTimeSerializer, LocalTimeSerializer, LongPrimitiveArraySerializer, LongSerializer, LongValueSerializer, NFAStateSerializer, NodeId.NodeIdSerializer, NullSerializer, NullValueSerializer, SharedBufferEdge.SharedBufferEdgeSerializer, SharedBufferNode.SharedBufferNodeSerializer, SharedBufferNodeSerializer, ShortPrimitiveArraySerializer, ShortSerializer, ShortValueSerializer, SqlDateSerializer, SqlTimeSerializer, SqlTimestampSerializer, StringArraySerializer, StringDataSerializer, StringSerializer, StringSerializer, StringValueSerializer, TimeSerializer, TimestampSerializer, TimeWindow.Serializer, TimeWindow.Serializer, VoidNamespaceSerializer, VoidNamespaceSerializer, VoidSerializer

@Internal
public abstract class TypeSerializerSingleton<T>
extends TypeSerializer<T>

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
TypeSerializerSingleton()

Method Summary

Modifier and Type	Method and Description
TypeSerializerSingleton<T>	duplicate() Creates a deep copy of this serializer if it is necessary, i.e. if it is stateful.
boolean	equals(Object obj)
int	hashCode()

Methods inherited from class org.apache.flink.api.common.typeutils.TypeSerializer

copy, copy, copy, createInstance, deserialize, deserialize, getLength, isImmutableType, serialize, snapshotConfiguration

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TypeSerializerSingleton

public TypeSerializerSingleton()

Method Detail

duplicate

public TypeSerializerSingleton<T> duplicate()

Description copied from class: TypeSerializer

Creates a deep copy of this serializer if it is necessary, i.e. if it is stateful. This can return itself if the serializer is not stateful.

We need this because Serializers might be used in several threads. Stateless serializers are inherently thread-safe while stateful serializers might not be thread-safe.

Specified by:

duplicate in class TypeSerializer<T>

hashCode

public int hashCode()

Specified by:

hashCode in class TypeSerializer<T>

equals

public boolean equals(Object obj)

Specified by:

equals in class TypeSerializer<T>