Uses of Interface
org.apache.flink.api.common.typeutils.TypeSerializerFactory

Packages that use TypeSerializerFactory

Package	Description
org.apache.flink.api.java.typeutils.runtime
org.apache.flink.optimizer.plan
org.apache.flink.runtime.broadcast
org.apache.flink.runtime.operators
org.apache.flink.runtime.operators.sort
org.apache.flink.runtime.operators.util

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

Classes in org.apache.flink.api.java.typeutils.runtime that implement TypeSerializerFactory

Modifier and Type	Class and Description
class	RuntimeSerializerFactory<T>

Uses of TypeSerializerFactory in org.apache.flink.optimizer.plan

Methods in org.apache.flink.optimizer.plan that return TypeSerializerFactory

Modifier and Type	Method and Description
TypeSerializerFactory<?>	Channel.getSerializer() Gets the serializer from this Channel.
TypeSerializerFactory<?>	SourcePlanNode.getSerializer() Gets the serializer from this PlanNode.
TypeSerializerFactory<?>	BulkIterationPlanNode.getSerializerForIterationChannel()
TypeSerializerFactory<?>	WorksetIterationPlanNode.getSerializerForIterationChannel()
TypeSerializerFactory<?>	WorksetIterationPlanNode.getSolutionSetSerializer()
TypeSerializerFactory<?>	WorksetIterationPlanNode.getWorksetSerializer()

Methods in org.apache.flink.optimizer.plan with parameters of type TypeSerializerFactory

Modifier and Type	Method and Description
void	Channel.setSerializer(TypeSerializerFactory<?> serializer) Sets the serializer for this Channel.
void	SourcePlanNode.setSerializer(TypeSerializerFactory<?> serializer) Sets the serializer for this PlanNode.
void	BulkIterationPlanNode.setSerializerForIterationChannel(TypeSerializerFactory<?> serializerForIterationChannel)
void	WorksetIterationPlanNode.setSerializerForIterationChannel(TypeSerializerFactory<?> serializerForIterationChannel)
void	WorksetIterationPlanNode.setSolutionSetSerializer(TypeSerializerFactory<?> solutionSetSerializer)
void	WorksetIterationPlanNode.setWorksetSerializer(TypeSerializerFactory<?> worksetSerializer)

Uses of TypeSerializerFactory in org.apache.flink.runtime.broadcast

Methods in org.apache.flink.runtime.broadcast with parameters of type TypeSerializerFactory

Modifier and Type	Method and Description
<T> BroadcastVariableMaterialization<T,?>	BroadcastVariableManager.materializeBroadcastVariable(String name, int superstep, BatchTask<?,?> holder, MutableReader<?> reader, TypeSerializerFactory<T> serializerFactory) Materializes the broadcast variable for the given name, scoped to the given task and its iteration superstep.
void	BroadcastVariableMaterialization.materializeVariable(MutableReader<?> reader, TypeSerializerFactory<?> serializerFactory, BatchTask<?,?> referenceHolder)

Uses of TypeSerializerFactory in org.apache.flink.runtime.operators

Fields in org.apache.flink.runtime.operators declared as TypeSerializerFactory

Modifier and Type	Field and Description
protected TypeSerializerFactory<?>[]	BatchTask.broadcastInputSerializers The serializers for the broadcast input data types.
protected TypeSerializerFactory<?>[]	BatchTask.inputSerializers The serializers for the input data type.

Methods in org.apache.flink.runtime.operators that return TypeSerializerFactory

Modifier and Type	Method and Description
<X> TypeSerializerFactory<X>	BatchTask.getInputSerializer(int index)
<X> TypeSerializerFactory<X>	TaskContext.getInputSerializer(int index)

Methods in org.apache.flink.runtime.operators with parameters of type TypeSerializerFactory

Modifier and Type	Method and Description
protected MutableObjectIterator<?>	BatchTask.createInputIterator(MutableReader<?> inputReader, TypeSerializerFactory<?> serializerFactory)

Constructors in org.apache.flink.runtime.operators with parameters of type TypeSerializerFactory

Constructor and Description
TempBarrier(AbstractInvokable owner, MutableObjectIterator<T> input, TypeSerializerFactory<T> serializerFactory, MemoryManager memManager, IOManager ioManager, int numPages)

Uses of TypeSerializerFactory in org.apache.flink.runtime.operators.sort

Methods in org.apache.flink.runtime.operators.sort with parameters of type TypeSerializerFactory

Modifier and Type	Method and Description
protected UnilateralSortMerger.ThreadBase<E>	UnilateralSortMerger.getSpillingThread(ExceptionHandler<IOException> exceptionHandler, UnilateralSortMerger.CircularQueues<E> queues, AbstractInvokable parentTask, MemoryManager memoryManager, IOManager ioManager, TypeSerializerFactory<E> serializerFactory, TypeComparator<E> comparator, List<MemorySegment> sortReadMemory, List<MemorySegment> writeMemory, int maxFileHandles)
protected UnilateralSortMerger.ThreadBase<E>	CombiningUnilateralSortMerger.getSpillingThread(ExceptionHandler<IOException> exceptionHandler, UnilateralSortMerger.CircularQueues<E> queues, AbstractInvokable parentTask, MemoryManager memoryManager, IOManager ioManager, TypeSerializerFactory<E> serializerFactory, TypeComparator<E> comparator, List<MemorySegment> sortReadMemory, List<MemorySegment> writeMemory, int maxFileHandles)

Constructors in org.apache.flink.runtime.operators.sort with parameters of type TypeSerializerFactory

Constructor and Description
CombiningUnilateralSortMerger(GroupCombineFunction<E,E> combineStub, MemoryManager memoryManager, IOManager ioManager, MutableObjectIterator<E> input, AbstractInvokable parentTask, TypeSerializerFactory<E> serializerFactory, TypeComparator<E> comparator, double memoryFraction, int maxNumFileHandles, float startSpillingFraction, boolean handleLargeRecords, boolean objectReuseEnabled) Creates a new sorter that reads the data from a given reader and provides an iterator returning that data in a sorted manner.
CombiningUnilateralSortMerger(GroupCombineFunction<E,E> combineStub, MemoryManager memoryManager, IOManager ioManager, MutableObjectIterator<E> input, AbstractInvokable parentTask, TypeSerializerFactory<E> serializerFactory, TypeComparator<E> comparator, double memoryFraction, int numSortBuffers, int maxNumFileHandles, float startSpillingFraction, boolean handleLargeRecords, boolean objectReuseEnabled) Creates a new sorter that reads the data from a given reader and provides an iterator returning that data in a sorted manner.
UnilateralSortMerger(MemoryManager memoryManager, IOManager ioManager, MutableObjectIterator<E> input, AbstractInvokable parentTask, TypeSerializerFactory<E> serializerFactory, TypeComparator<E> comparator, double memoryFraction, int maxNumFileHandles, float startSpillingFraction, boolean handleLargeRecords, boolean objectReuseEnabled)
UnilateralSortMerger(MemoryManager memoryManager, IOManager ioManager, MutableObjectIterator<E> input, AbstractInvokable parentTask, TypeSerializerFactory<E> serializerFactory, TypeComparator<E> comparator, double memoryFraction, int numSortBuffers, int maxNumFileHandles, float startSpillingFraction, boolean handleLargeRecords, boolean objectReuseEnabled)
UnilateralSortMerger(MemoryManager memoryManager, IOManager ioManager, MutableObjectIterator<E> input, AbstractInvokable parentTask, TypeSerializerFactory<E> serializerFactory, TypeComparator<E> comparator, double memoryFraction, int numSortBuffers, int maxNumFileHandles, float startSpillingFraction, boolean noSpillingMemory, boolean handleLargeRecords, boolean objectReuseEnabled)
UnilateralSortMerger(MemoryManager memoryManager, List<MemorySegment> memory, IOManager ioManager, MutableObjectIterator<E> input, AbstractInvokable parentTask, TypeSerializerFactory<E> serializerFactory, TypeComparator<E> comparator, int numSortBuffers, int maxNumFileHandles, float startSpillingFraction, boolean handleLargeRecords, boolean objectReuseEnabled)
UnilateralSortMerger(MemoryManager memoryManager, List<MemorySegment> memory, IOManager ioManager, MutableObjectIterator<E> input, AbstractInvokable parentTask, TypeSerializerFactory<E> serializerFactory, TypeComparator<E> comparator, int numSortBuffers, int maxNumFileHandles, float startSpillingFraction, boolean noSpillingMemory, boolean handleLargeRecords, boolean objectReuseEnabled)
UnilateralSortMerger(MemoryManager memoryManager, List<MemorySegment> memory, IOManager ioManager, MutableObjectIterator<E> input, AbstractInvokable parentTask, TypeSerializerFactory<E> serializerFactory, TypeComparator<E> comparator, int numSortBuffers, int maxNumFileHandles, float startSpillingFraction, boolean noSpillingMemory, boolean handleLargeRecords, boolean objectReuseEnabled, InMemorySorterFactory<E> inMemorySorterFactory)

Uses of TypeSerializerFactory in org.apache.flink.runtime.operators.util

Methods in org.apache.flink.runtime.operators.util that return TypeSerializerFactory

Modifier and Type	Method and Description
<T> TypeSerializerFactory<T>	TaskConfig.getBroadcastInputSerializer(int inputNum, ClassLoader cl)
<T> TypeSerializerFactory<T>	TaskConfig.getInputSerializer(int inputNum, ClassLoader cl)
<T> TypeSerializerFactory<T>	TaskConfig.getOutputSerializer(ClassLoader cl)
<T> TypeSerializerFactory<T>	TaskConfig.getSolutionSetSerializer(ClassLoader cl)

Methods in org.apache.flink.runtime.operators.util with parameters of type TypeSerializerFactory

Modifier and Type	Method and Description
void	TaskConfig.setBroadcastInputSerializer(TypeSerializerFactory<?> factory, int inputNum)
void	TaskConfig.setInputSerializer(TypeSerializerFactory<?> factory, int inputNum)
void	TaskConfig.setOutputSerializer(TypeSerializerFactory<?> factory)
void	TaskConfig.setSolutionSetSerializer(TypeSerializerFactory<?> factory)