Uses of Class
org.apache.flink.api.common.typeutils.TypeSerializer

Packages that use TypeSerializer

Package	Description
org.apache.flink.api.common.accumulators
org.apache.flink.api.common.functions
org.apache.flink.api.common.functions.util
org.apache.flink.api.common.operators.base
org.apache.flink.api.common.operators.util
org.apache.flink.api.common.serialization
org.apache.flink.api.common.state
org.apache.flink.api.common.typeinfo
org.apache.flink.api.common.typeutils
org.apache.flink.api.common.typeutils.base
org.apache.flink.api.common.typeutils.base.array
org.apache.flink.api.connector.sink2
org.apache.flink.api.java.typeutils
org.apache.flink.api.java.typeutils.runtime
org.apache.flink.api.java.typeutils.runtime.kryo
org.apache.flink.core.io
org.apache.flink.types
org.apache.flink.util

Uses of TypeSerializer in org.apache.flink.api.common.accumulators

Methods in org.apache.flink.api.common.accumulators with parameters of type TypeSerializer

Modifier and Type	Method	Description
void	SerializedListAccumulator.add(T value, TypeSerializer<T> serializer)
static <T> List<T>	SerializedListAccumulator.deserializeList(ArrayList<byte[]> data, TypeSerializer<T> serializer)

Uses of TypeSerializer in org.apache.flink.api.common.functions

Methods in org.apache.flink.api.common.functions that return TypeSerializer

Modifier and Type	Method	Description
<T> TypeSerializer<T>	RuntimeContext.createSerializer(TypeInformation<T> typeInformation)	Create a serializer for a given type.
<T> TypeSerializer<T>	SerializerFactory.createSerializer(TypeInformation<T> typeInformation)	Creates a serializer for the specified type of data.

Uses of TypeSerializer in org.apache.flink.api.common.functions.util

Methods in org.apache.flink.api.common.functions.util that return TypeSerializer

Modifier and Type	Method	Description
<T> TypeSerializer<T>	AbstractRuntimeUDFContext.createSerializer(TypeInformation<T> typeInformation)

Constructors in org.apache.flink.api.common.functions.util with parameters of type TypeSerializer

Constructor	Description
CopyingIterator(Iterator<E> source, TypeSerializer<E> serializer)
CopyingListCollector(List<T> list, TypeSerializer<T> serializer)

Uses of TypeSerializer in org.apache.flink.api.common.operators.base

Constructors in org.apache.flink.api.common.operators.base with parameters of type TypeSerializer

Constructor	Description
SimpleListIterable(List<IN> values, TypeComparator<IN> comparator, TypeSerializer<IN> serializer)
SimpleListIterator(List<IN> values, TypeSerializer<IN> serializer)

Uses of TypeSerializer in org.apache.flink.api.common.operators.util

Methods in org.apache.flink.api.common.operators.util that return TypeSerializer

Modifier and Type	Method	Description
TypeSerializer<BT>	JoinHashMap.getBuildSerializer()

Constructors in org.apache.flink.api.common.operators.util with parameters of type TypeSerializer

Constructor	Description
JoinHashMap(TypeSerializer<BT> buildSerializer, TypeComparator<BT> buildComparator)
ListKeyGroupedIterator(List<E> input, TypeSerializer<E> serializer, TypeComparator<E> comparator)	Initializes the ListKeyGroupedIterator..

Uses of TypeSerializer in org.apache.flink.api.common.serialization

Constructors in org.apache.flink.api.common.serialization with parameters of type TypeSerializer

Constructor	Description
TypeInformationSerializationSchema(TypeInformation<T> typeInfo, TypeSerializer<T> serializer)	Creates a new de-/serialization schema for the given type.

Uses of TypeSerializer in org.apache.flink.api.common.state

Methods in org.apache.flink.api.common.state that return TypeSerializer

Modifier and Type	Method	Description
TypeSerializer<T>	ListStateDescriptor.getElementSerializer()	Gets the serializer for the elements contained in the list.
TypeSerializer<UK>	MapStateDescriptor.getKeySerializer()	Gets the serializer for the keys in the state.
TypeSerializer<T>	StateDescriptor.getSerializer()	Returns the TypeSerializer that can be used to serialize the value in the state.
TypeSerializer<UV>	MapStateDescriptor.getValueSerializer()	Gets the serializer for the values in the state.

Constructors in org.apache.flink.api.common.state with parameters of type TypeSerializer

Constructor	Description
AggregatingStateDescriptor(String name, AggregateFunction<IN,ACC,OUT> aggFunction, TypeSerializer<ACC> typeSerializer)	Creates a new ValueStateDescriptor with the given name and default value.
ListStateDescriptor(String name, TypeSerializer<T> typeSerializer)	Creates a new ListStateDescriptor with the given name and list element type.
MapStateDescriptor(String name, TypeSerializer<UK> keySerializer, TypeSerializer<UV> valueSerializer)	Create a new MapStateDescriptor with the given name and the given type serializers.
ReducingStateDescriptor(String name, ReduceFunction<T> reduceFunction, TypeSerializer<T> typeSerializer)	Creates a new ValueStateDescriptor with the given name and default value.
StateDescriptor(String name, TypeSerializer<T> serializer, T defaultValue)	Create a new StateDescriptor with the given name and the given type serializer.
ValueStateDescriptor(String name, TypeSerializer<T> typeSerializer)	Creates a new ValueStateDescriptor with the given name and the specific serializer.
ValueStateDescriptor(String name, TypeSerializer<T> typeSerializer, T defaultValue)	Deprecated. Use ValueStateDescriptor(String, TypeSerializer) instead and manually manage the default value by checking whether the contents of the state is null.

Uses of TypeSerializer in org.apache.flink.api.common.typeinfo

Methods in org.apache.flink.api.common.typeinfo that return TypeSerializer

Modifier and Type	Method	Description
TypeSerializer<T>	BasicArrayTypeInfo.createSerializer(ExecutionConfig config)	Deprecated.
TypeSerializer<T>	BasicArrayTypeInfo.createSerializer(SerializerConfig serializerConfig)
TypeSerializer<T>	BasicTypeInfo.createSerializer(ExecutionConfig config)	Deprecated.
TypeSerializer<T>	BasicTypeInfo.createSerializer(SerializerConfig serializerConfig)
TypeSerializer<T>	LocalTimeTypeInfo.createSerializer(ExecutionConfig config)
TypeSerializer<T>	LocalTimeTypeInfo.createSerializer(SerializerConfig serializerConfig)
TypeSerializer<Nothing>	NothingTypeInfo.createSerializer(ExecutionConfig config)	Deprecated.
TypeSerializer<Nothing>	NothingTypeInfo.createSerializer(SerializerConfig serializerConfig)
TypeSerializer<T>	PrimitiveArrayTypeInfo.createSerializer(ExecutionConfig config)
TypeSerializer<T>	PrimitiveArrayTypeInfo.createSerializer(SerializerConfig serializerConfig)
TypeSerializer<T>	SqlTimeTypeInfo.createSerializer(ExecutionConfig config)
TypeSerializer<T>	SqlTimeTypeInfo.createSerializer(SerializerConfig serializerConfig)
abstract TypeSerializer<T>	TypeInformation.createSerializer(ExecutionConfig config)	Deprecated. This method is deprecated since Flink 1.19 and will be removed in Flink 1.20.
TypeSerializer<T>	TypeInformation.createSerializer(SerializerConfig config)	Creates a serializer for the type.

Constructors in org.apache.flink.api.common.typeinfo with parameters of type TypeSerializer

Constructor	Description
BasicTypeInfo(Class<T> clazz, Class<?>[] possibleCastTargetTypes, TypeSerializer<T> serializer, Class<? extends TypeComparator<T>> comparatorClass)
FractionalTypeInfo(Class<T> clazz, Class<?>[] possibleCastTargetTypes, TypeSerializer<T> serializer, Class<? extends TypeComparator<T>> comparatorClass)
IntegerTypeInfo(Class<T> clazz, Class<?>[] possibleCastTargetTypes, TypeSerializer<T> serializer, Class<? extends TypeComparator<T>> comparatorClass)
LocalTimeTypeInfo(Class<T> clazz, TypeSerializer<T> serializer, Class<? extends TypeComparator<T>> comparatorClass)
NumericTypeInfo(Class<T> clazz, Class<?>[] possibleCastTargetTypes, TypeSerializer<T> serializer, Class<? extends TypeComparator<T>> comparatorClass)
SqlTimeTypeInfo(Class<T> clazz, TypeSerializer<T> serializer, Class<? extends TypeComparator<T>> comparatorClass)

Uses of TypeSerializer in org.apache.flink.api.common.typeutils

Classes in org.apache.flink.api.common.typeutils with type parameters of type TypeSerializer

Modifier and Type	Class	Description
class	CompositeTypeSerializerSnapshot<T,S extends TypeSerializer<T>>	A CompositeTypeSerializerSnapshot is a convenient serializer snapshot class that can be used by simple serializers which 1) delegates its serialization to multiple nested serializers, and 2) may contain some extra static information that needs to be persisted as part of its snapshot.
class	GenericTypeSerializerSnapshot<T,S extends TypeSerializer>	Base TypeSerializerSnapshot for serializers for generic types.

Subclasses of TypeSerializer in org.apache.flink.api.common.typeutils

Modifier and Type	Class	Description
class	CompositeSerializer<T>	Base class for composite serializers.
class	SingleThreadAccessCheckingTypeSerializer<T>
class	UnloadableDummyTypeSerializer<T>	Dummy TypeSerializer to avoid that data is lost when checkpointing again a serializer for which we encountered a ClassNotFoundException or InvalidClassException.

Fields in org.apache.flink.api.common.typeutils declared as TypeSerializer

Modifier and Type	Field	Description
protected TypeSerializer<Object>[]	CompositeSerializer.fieldSerializers	Serializers for fields which constitute T.

Methods in org.apache.flink.api.common.typeutils that return TypeSerializer

Modifier and Type	Method	Description
protected abstract TypeSerializer<T>	GenericTypeSerializerSnapshot.createSerializer(Class<T> typeClass)	Create a serializer that is able to serialize the generic type typeClass.
TypeSerializer<T>	SingleThreadAccessCheckingTypeSerializer.duplicate()
abstract TypeSerializer<T>	TypeSerializer.duplicate()	Creates a deep copy of this serializer if it is necessary, i.e.
TypeSerializer<T>	UnloadableDummyTypeSerializer.duplicate()
protected abstract TypeSerializer<?>[]	CompositeTypeSerializerSnapshot.getNestedSerializers(S outerSerializer)	Gets the nested serializers from the outer serializer.
TypeSerializer<?>[]	CompositeTypeSerializerUtil.IntermediateCompatibilityResult.getNestedSerializers()
protected TypeSerializer<?>[]	SingleThreadAccessCheckingTypeSerializer.SingleThreadAccessCheckingTypeSerializerSnapshot.getNestedSerializers(SingleThreadAccessCheckingTypeSerializer<T> outerSerializer)
TypeSerializer<T>	TypeSerializerSchemaCompatibility.getReconfiguredSerializer()	Gets the reconfigured serializer.
<T> TypeSerializer<T>	NestedSerializersSnapshotDelegate.getRestoredNestedSerializer(int pos)	Creates the restore serializer from the pos-th config snapshot.
TypeSerializer<?>[]	NestedSerializersSnapshotDelegate.getRestoredNestedSerializers()	Produces a restore serializer from each contained serializer configuration snapshot.
TypeSerializer<T>	TypeSerializerFactory.getSerializer()
TypeSerializer<T>	CompositeTypeSerializerSnapshot.restoreSerializer()
TypeSerializer<T>	GenericTypeSerializerSnapshot.restoreSerializer()
TypeSerializer<T>	SimpleTypeSerializerSnapshot.restoreSerializer()
TypeSerializer<T>	TypeSerializerSnapshot.restoreSerializer()	Recreates a serializer instance from this snapshot.

Methods in org.apache.flink.api.common.typeutils with parameters of type TypeSerializer

Modifier and Type	Method	Description
static <T> TypeSerializerSchemaCompatibility<T>	TypeSerializerSchemaCompatibility.compatibleWithReconfiguredSerializer(TypeSerializer<T> reconfiguredSerializer)	Returns a result that indicates a reconfigured version of the new serializer is compatible, and should be used instead of the original new serializer.
protected abstract S	CompositeTypeSerializerSnapshot.createOuterSerializerWithNestedSerializers(TypeSerializer<?>[] nestedSerializers)	Creates an instance of the outer serializer with a given array of its nested serializers.
protected SingleThreadAccessCheckingTypeSerializer<T>	SingleThreadAccessCheckingTypeSerializer.SingleThreadAccessCheckingTypeSerializerSnapshot.createOuterSerializerWithNestedSerializers(TypeSerializer<?>[] nestedSerializers)
protected abstract CompositeSerializer<T>	CompositeSerializer.createSerializerInstance(CompositeSerializer.PrecomputedParameters precomputed, TypeSerializer<?>... originalSerializers)	Factory for concrete serializer.
default TypeSerializerSchemaCompatibility<T>	TypeSerializerSnapshot.resolveSchemaCompatibility(TypeSerializer<T> newSerializer)	Deprecated. This method has been replaced by #resolveSchemaCompatibility(TypeSerializerSnapshot) and will be removed in the future release.
static TypeSerializerSnapshot<?>[]	TypeSerializerUtils.snapshot(TypeSerializer<?>... originatingSerializers)	Takes snapshots of the given serializers.

Method parameters in org.apache.flink.api.common.typeutils with type arguments of type TypeSerializer

Modifier and Type	Method	Description
static <T> TypeSerializerSchemaCompatibility<T>	CompositeTypeSerializerUtil.delegateCompatibilityCheckToNewSnapshot(TypeSerializerSnapshot<T> legacySerializerSnapshot, CompositeTypeSerializerSnapshot<T,? extends TypeSerializer<T>> newCompositeSnapshot, TypeSerializerSnapshot<?>... legacyNestedSnapshots)	Delegates compatibility checks to a CompositeTypeSerializerSnapshot instance.

Constructors in org.apache.flink.api.common.typeutils with parameters of type TypeSerializer

Constructor	Description
CompositeSerializer(boolean immutableTargetType, TypeSerializer<?>... fieldSerializers)	Can be used for user facing constructor.
CompositeSerializer(CompositeSerializer.PrecomputedParameters precomputed, TypeSerializer<?>... fieldSerializers)	Can be used in createSerializerInstance for internal operations.
NestedSerializersSnapshotDelegate(TypeSerializer<?>... serializers)	Constructor to create a snapshot for writing.
SingleThreadAccessCheckingTypeSerializer(TypeSerializer<T> originalSerializer)

Constructor parameters in org.apache.flink.api.common.typeutils with type arguments of type TypeSerializer

Constructor	Description
CompositeTypeSerializerSnapshot(Class<? extends TypeSerializer> correspondingSerializerClass)	Deprecated. correspondingSerializerClass is not used to resolve and cast after FLIP-263, please use CompositeTypeSerializerSnapshot() instead.
SimpleTypeSerializerSnapshot(java.util.function.Supplier<? extends TypeSerializer<T>> serializerSupplier)	Constructor to create snapshot from serializer (writing the snapshot).

Uses of TypeSerializer in org.apache.flink.api.common.typeutils.base

Subclasses of TypeSerializer in org.apache.flink.api.common.typeutils.base

Modifier and Type	Class	Description
class	BigDecSerializer	Serializer for serializing/deserializing BigDecimal values including null values.
class	BigIntSerializer	Serializer for serializing/deserializing BigInteger values including null values.
class	BooleanSerializer	Type serializer for Boolean.
class	BooleanValueSerializer
class	ByteSerializer	Type serializer for Byte.
class	ByteValueSerializer
class	CharSerializer	Type serializer for Character.
class	CharValueSerializer
class	DateSerializer
class	DoubleSerializer	Type serializer for Double.
class	DoubleValueSerializer
class	EnumSerializer<T extends Enum<T>>	TypeSerializer for Java enums.
class	FloatSerializer	Type serializer for Float.
class	FloatValueSerializer
class	GenericArraySerializer<C>	A serializer for arrays of objects.
class	InstantSerializer	Serializer for serializing/deserializing Instant values including null values.
class	IntSerializer	Type serializer for Integer (and int, via auto-boxing).
class	IntValueSerializer
class	ListSerializer<T>	A serializer for Lists.
class	LocalDateSerializer
class	LocalDateTimeSerializer
class	LocalTimeSerializer
class	LongSerializer	Type serializer for Long.
class	LongValueSerializer
class	MapSerializer<K,V>	A serializer for Map.
class	NullValueSerializer
class	ShortSerializer	Type serializer for Byte.
class	ShortValueSerializer
class	SqlDateSerializer
class	SqlTimeSerializer
class	SqlTimestampSerializer
class	StringSerializer	Type serializer for String.
class	StringValueSerializer
class	TypeSerializerSingleton<T>
class	VoidSerializer	Serializer for Void.

Methods in org.apache.flink.api.common.typeutils.base that return TypeSerializer

Modifier and Type	Method	Description
TypeSerializer<List<T>>	ListSerializer.duplicate()
TypeSerializer<Map<K,V>>	MapSerializer.duplicate()
TypeSerializer<C>	GenericArraySerializer.getComponentSerializer()
TypeSerializer<T>	ListSerializer.getElementSerializer()	Gets the serializer for the elements of the list.
TypeSerializer<K>	MapSerializer.getKeySerializer()
protected TypeSerializer<?>[]	GenericArraySerializerSnapshot.getNestedSerializers(GenericArraySerializer<C> outerSerializer)
protected TypeSerializer<?>[]	ListSerializerSnapshot.getNestedSerializers(ListSerializer<T> outerSerializer)
protected TypeSerializer<?>[]	MapSerializerSnapshot.getNestedSerializers(MapSerializer<K,V> outerSerializer)
TypeSerializer<V>	MapSerializer.getValueSerializer()
TypeSerializer<T>	EnumSerializer.EnumSerializerSnapshot.restoreSerializer()

Methods in org.apache.flink.api.common.typeutils.base with parameters of type TypeSerializer

Modifier and Type	Method	Description
protected GenericArraySerializer<C>	GenericArraySerializerSnapshot.createOuterSerializerWithNestedSerializers(TypeSerializer<?>[] nestedSerializers)
protected ListSerializer<T>	ListSerializerSnapshot.createOuterSerializerWithNestedSerializers(TypeSerializer<?>[] nestedSerializers)
protected MapSerializer<K,V>	MapSerializerSnapshot.createOuterSerializerWithNestedSerializers(TypeSerializer<?>[] nestedSerializers)

Constructors in org.apache.flink.api.common.typeutils.base with parameters of type TypeSerializer

Constructor	Description
GenericArraySerializer(Class<C> componentClass, TypeSerializer<C> componentSerializer)
ListSerializer(TypeSerializer<T> elementSerializer)	Creates a list serializer that uses the given serializer to serialize the list's elements.
MapSerializer(TypeSerializer<K> keySerializer, TypeSerializer<V> valueSerializer)	Creates a map serializer that uses the given serializers to serialize the key-value pairs in the map.

Uses of TypeSerializer in org.apache.flink.api.common.typeutils.base.array

Subclasses of TypeSerializer in org.apache.flink.api.common.typeutils.base.array

Modifier and Type	Class	Description
class	BooleanPrimitiveArraySerializer	A serializer for boolean arrays.
class	BytePrimitiveArraySerializer	A serializer for byte arrays.
class	CharPrimitiveArraySerializer	A serializer for char arrays.
class	DoublePrimitiveArraySerializer	A serializer for double arrays.
class	FloatPrimitiveArraySerializer	A serializer for float arrays.
class	IntPrimitiveArraySerializer	A serializer for int arrays.
class	LongPrimitiveArraySerializer	A serializer for long arrays.
class	ShortPrimitiveArraySerializer	A serializer for short arrays.
class	StringArraySerializer	A serializer for String arrays.

Uses of TypeSerializer in org.apache.flink.api.connector.sink2

Methods in org.apache.flink.api.connector.sink2 that return TypeSerializer

Modifier and Type	Method	Description
<IN> TypeSerializer<IN>	Sink.InitContext.createInputSerializer()	Deprecated. Creates a serializer for the type of sink's input.
<IN> TypeSerializer<IN>	Sink.InitContextWrapper.createInputSerializer()	Deprecated.
<IN> TypeSerializer<IN>	WriterInitContext.createInputSerializer()	Creates a serializer for the type of sink's input.

Uses of TypeSerializer in org.apache.flink.api.java.typeutils

Methods in org.apache.flink.api.java.typeutils that return TypeSerializer

Modifier and Type	Method	Description
abstract <T> TypeSerializer<T>	AvroUtils.createAvroSerializer(Class<T> type)	Creates an AvroSerializer if flink-avro is present, otherwise throws an exception.
TypeSerializer<Row>	RowTypeInfo.createLegacySerializer(SerializerConfig config)	Deprecated.
TypeSerializer<Either<L,R>>	EitherTypeInfo.createSerializer(ExecutionConfig config)	Deprecated.
TypeSerializer<Either<L,R>>	EitherTypeInfo.createSerializer(SerializerConfig config)
TypeSerializer<T>	EnumTypeInfo.createSerializer(ExecutionConfig config)	Deprecated.
TypeSerializer<T>	EnumTypeInfo.createSerializer(SerializerConfig serializerConfig)
TypeSerializer<T>	GenericTypeInfo.createSerializer(ExecutionConfig config)	Deprecated.
TypeSerializer<T>	GenericTypeInfo.createSerializer(SerializerConfig config)
TypeSerializer<List<T>>	ListTypeInfo.createSerializer(ExecutionConfig config)
TypeSerializer<List<T>>	ListTypeInfo.createSerializer(SerializerConfig config)
TypeSerializer<Map<K,V>>	MapTypeInfo.createSerializer(ExecutionConfig config)
TypeSerializer<Map<K,V>>	MapTypeInfo.createSerializer(SerializerConfig config)
TypeSerializer<InvalidTypesException>	MissingTypeInfo.createSerializer(ExecutionConfig config)
TypeSerializer<InvalidTypesException>	MissingTypeInfo.createSerializer(SerializerConfig serializerConfig)
TypeSerializer<T>	ObjectArrayTypeInfo.createSerializer(ExecutionConfig config)	Deprecated.
TypeSerializer<T>	ObjectArrayTypeInfo.createSerializer(SerializerConfig serializerConfig)
TypeSerializer<T>	PojoTypeInfo.createSerializer(ExecutionConfig config)	Deprecated.
TypeSerializer<T>	PojoTypeInfo.createSerializer(SerializerConfig config)
TypeSerializer<Row>	RowTypeInfo.createSerializer(ExecutionConfig config)
TypeSerializer<Row>	RowTypeInfo.createSerializer(SerializerConfig config)
TypeSerializer<T>	TupleTypeInfo.createSerializer(ExecutionConfig config)	Deprecated.
TypeSerializer<T>	ValueTypeInfo.createSerializer(ExecutionConfig config)	Deprecated.
TypeSerializer<T>	ValueTypeInfo.createSerializer(SerializerConfig serializerConfig)

Uses of TypeSerializer in org.apache.flink.api.java.typeutils.runtime

Subclasses of TypeSerializer in org.apache.flink.api.java.typeutils.runtime

Modifier and Type	Class	Description
class	CopyableValueSerializer<T extends CopyableValue<T>>
class	EitherSerializer<L,R>	A TypeSerializer for the Either type of the Java class.
class	NullableSerializer<T>	Serializer wrapper to add support of null value serialization.
class	PojoSerializer<T>
class	RowSerializer	Serializer for Row.
class	Tuple0Serializer
class	TupleSerializer<T extends Tuple>
class	TupleSerializerBase<T>
class	ValueSerializer<T extends Value>	Serializer for Value types.

Fields in org.apache.flink.api.java.typeutils.runtime declared as TypeSerializer

Modifier and Type	Field	Description
protected TypeSerializer<Object>[]	TupleSerializerBase.fieldSerializers
protected TypeSerializer[]	TupleComparatorBase.serializers	serializers to deserialize the first n fields for comparison

Methods in org.apache.flink.api.java.typeutils.runtime that return TypeSerializer

Modifier and Type	Method	Description
protected TypeSerializer<T>	CopyableValueSerializer.CopyableValueSerializerSnapshot.createSerializer(Class<T> typeClass)
protected TypeSerializer<T>	ValueSerializer.ValueSerializerSnapshot.createSerializer(Class<T> typeClass)
TypeSerializer<Either<L,R>>	EitherSerializer.duplicate()
TypeSerializer<T>	NullableSerializer.duplicate()
TypeSerializer<Row>	RowSerializer.duplicate()
TypeSerializer<Object>[]	TupleSerializerBase.getFieldSerializers()
TypeSerializer<L>	EitherSerializer.getLeftSerializer()
protected TypeSerializer<?>[]	JavaEitherSerializerSnapshot.getNestedSerializers(EitherSerializer<L,R> outerSerializer)
protected TypeSerializer<?>[]	NullableSerializer.NullableSerializerSnapshot.getNestedSerializers(NullableSerializer<T> outerSerializer)
protected TypeSerializer<?>[]	RowSerializer.RowSerializerSnapshot.getNestedSerializers(RowSerializer outerSerializer)
protected TypeSerializer<?>[]	TupleSerializerSnapshot.getNestedSerializers(TupleSerializer<T> outerSerializer)
TypeSerializer<R>	EitherSerializer.getRightSerializer()
TypeSerializer<T>	RuntimeSerializerFactory.getSerializer()
TypeSerializer<T>	PojoSerializerSnapshot.restoreSerializer()
static <T> TypeSerializer<T>	NullableSerializer.wrap(TypeSerializer<T> originalSerializer, boolean padNullValueIfFixedLen)	This method wraps the originalSerializer with the NullableSerializer if not already wrapped.
static <T> TypeSerializer<T>	NullableSerializer.wrapIfNullIsNotSupported(TypeSerializer<T> originalSerializer, boolean padNullValueIfFixedLen)	This method tries to serialize null value with the originalSerializer and wraps it in case of NullPointerException, otherwise it returns the originalSerializer.

Methods in org.apache.flink.api.java.typeutils.runtime with parameters of type TypeSerializer

Modifier and Type	Method	Description
static <T> boolean	NullableSerializer.checkIfNullSupported(TypeSerializer<T> serializer)	This method checks if serializer supports null value.
static <T> T	KryoUtils.copy(T from, com.esotericsoftware.kryo.Kryo kryo, TypeSerializer<T> serializer)	Tries to copy the given record from using the provided Kryo instance.
static <T> T	KryoUtils.copy(T from, T reuse, com.esotericsoftware.kryo.Kryo kryo, TypeSerializer<T> serializer)	Tries to copy the given record from using the provided Kryo instance.
protected EitherSerializer<L,R>	JavaEitherSerializerSnapshot.createOuterSerializerWithNestedSerializers(TypeSerializer<?>[] nestedSerializers)
protected NullableSerializer<T>	NullableSerializer.NullableSerializerSnapshot.createOuterSerializerWithNestedSerializers(TypeSerializer<?>[] nestedSerializers)
protected RowSerializer	RowSerializer.RowSerializerSnapshot.createOuterSerializerWithNestedSerializers(TypeSerializer<?>[] nestedSerializers)
protected TupleSerializer<T>	TupleSerializerSnapshot.createOuterSerializerWithNestedSerializers(TypeSerializer<?>[] nestedSerializers)
static <T> TypeSerializer<T>	NullableSerializer.wrap(TypeSerializer<T> originalSerializer, boolean padNullValueIfFixedLen)	This method wraps the originalSerializer with the NullableSerializer if not already wrapped.
static <T> TypeSerializer<T>	NullableSerializer.wrapIfNullIsNotSupported(TypeSerializer<T> originalSerializer, boolean padNullValueIfFixedLen)	This method tries to serialize null value with the originalSerializer and wraps it in case of NullPointerException, otherwise it returns the originalSerializer.

Constructors in org.apache.flink.api.java.typeutils.runtime with parameters of type TypeSerializer

Constructor	Description
EitherSerializer(TypeSerializer<L> leftSerializer, TypeSerializer<R> rightSerializer)
EitherSerializerSnapshot(TypeSerializer<L> leftSerializer, TypeSerializer<R> rightSerializer)	Deprecated. Constructor to create the snapshot for writing.
GenericTypeComparator(boolean ascending, TypeSerializer<T> serializer, Class<T> type)
PojoComparator(Field[] keyFields, TypeComparator<?>[] comparators, TypeSerializer<T> serializer, Class<T> type)
PojoSerializer(Class<T> clazz, TypeSerializer<?>[] fieldSerializers, Field[] fields, SerializerConfig serializerConfig)	Constructor to create a new PojoSerializer.
RowComparator(int arity, int[] keyPositions, TypeComparator<Object>[] comparators, TypeSerializer<Object>[] serializers, boolean[] orders)	General constructor for RowComparator.
RowSerializer(TypeSerializer<?>[] fieldSerializers)
RowSerializer(TypeSerializer<?>[] fieldSerializers, LinkedHashMap<String,Integer> positionByName)
RowSerializer(TypeSerializer<?>[] fieldSerializers, LinkedHashMap<String,Integer> positionByName, boolean supportsRowKind)
RuntimeSerializerFactory(TypeSerializer<T> serializer, Class<T> clazz)
TupleComparator(int[] keyPositions, TypeComparator<?>[] comparators, TypeSerializer<?>[] serializers)
TupleComparatorBase(int[] keyPositions, TypeComparator<?>[] comparators, TypeSerializer<?>[] serializers)
TupleSerializer(Class<T> tupleClass, TypeSerializer<?>[] fieldSerializers)
TupleSerializerBase(Class<T> tupleClass, TypeSerializer<?>[] fieldSerializers)

Uses of TypeSerializer in org.apache.flink.api.java.typeutils.runtime.kryo

Subclasses of TypeSerializer in org.apache.flink.api.java.typeutils.runtime.kryo

Modifier and Type	Class	Description
class	KryoSerializer<T>	A type serializer that serializes its type using the Kryo serialization framework (https://github.com/EsotericSoftware/kryo).

Methods in org.apache.flink.api.java.typeutils.runtime.kryo that return TypeSerializer

Modifier and Type	Method	Description
TypeSerializer<T>	KryoSerializerSnapshot.restoreSerializer()

Uses of TypeSerializer in org.apache.flink.core.io

Subclasses of TypeSerializer in org.apache.flink.core.io

Modifier and Type	Class	Description
class	SimpleVersionedSerializerTypeSerializerProxy<T>	A TypeSerializer that delegates to an underlying SimpleVersionedSerializer.

Methods in org.apache.flink.core.io that return TypeSerializer

Modifier and Type	Method	Description
TypeSerializer<T>	SimpleVersionedSerializerTypeSerializerProxy.duplicate()

Uses of TypeSerializer in org.apache.flink.types

Methods in org.apache.flink.types with parameters of type TypeSerializer

Modifier and Type	Method	Description
static <L,R> Either.Left<L,R>	Either.obtainLeft(Either<L,R> input, TypeSerializer<L> leftSerializer)	Utility function for EitherSerializer to support object reuse.
static <L,R> Either.Right<L,R>	Either.obtainRight(Either<L,R> input, TypeSerializer<R> rightSerializer)	Utility function for EitherSerializer to support object reuse.

Uses of TypeSerializer in org.apache.flink.util

Methods in org.apache.flink.util with parameters of type TypeSerializer

Modifier and Type	Method	Description
static <T> T	InstantiationUtil.deserializeFromByteArray(TypeSerializer<T> serializer, byte[] buf)
static <T> T	InstantiationUtil.deserializeFromByteArray(TypeSerializer<T> serializer, T reuse, byte[] buf)
static <T> byte[]	InstantiationUtil.serializeToByteArray(TypeSerializer<T> serializer, T record)