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,BigIntSerializer,BooleanPrimitiveArraySerializer,BooleanSerializer,BooleanValueSerializer,BytePrimitiveArraySerializer,ByteSerializer,ByteValueSerializer,CharPrimitiveArraySerializer,CharSerializer,CharValueSerializer,DateSerializer,DoublePrimitiveArraySerializer,DoubleSerializer,DoubleValueSerializer,FloatPrimitiveArraySerializer,FloatSerializer,FloatValueSerializer,InstantSerializer,IntPrimitiveArraySerializer,IntSerializer,IntValueSerializer,LocalDateSerializer,LocalDateTimeSerializer,LocalTimeSerializer,LongPrimitiveArraySerializer,LongSerializer,LongValueSerializer,NullValueSerializer,ShortPrimitiveArraySerializer,ShortSerializer,ShortValueSerializer,SqlDateSerializer,SqlTimeSerializer,SqlTimestampSerializer,StringArraySerializer,StringSerializer,StringValueSerializer,VoidSerializer
@Internal public abstract class TypeSerializerSingleton<T> extends TypeSerializer<T>
- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description TypeSerializerSingleton()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description TypeSerializerSingleton<T>duplicate()Creates a deep copy of this serializer if it is necessary, i.e.booleanequals(Object obj)inthashCode()-
Methods inherited from class org.apache.flink.api.common.typeutils.TypeSerializer
copy, copy, copy, createInstance, deserialize, deserialize, getLength, isImmutableType, serialize, snapshotConfiguration
-
-
-
-
Method Detail
-
duplicate
public TypeSerializerSingleton<T> duplicate()
Description copied from class:TypeSerializerCreates 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:
duplicatein classTypeSerializer<T>
-
hashCode
public int hashCode()
- Specified by:
hashCodein classTypeSerializer<T>
-
equals
public boolean equals(Object obj)
- Specified by:
equalsin classTypeSerializer<T>
-
-