Uses of Class
org.apache.flink.runtime.jobgraph.tasks.AbstractInvokable

Packages that use AbstractInvokable

Package	Description
org.apache.flink.runtime.iterative.task
org.apache.flink.runtime.jobgraph
org.apache.flink.runtime.memorymanager
org.apache.flink.runtime.operators
org.apache.flink.runtime.operators.chaining
org.apache.flink.runtime.operators.hash
org.apache.flink.runtime.operators.resettable
org.apache.flink.runtime.operators.sort

Uses of AbstractInvokable in org.apache.flink.runtime.iterative.task

Subclasses of AbstractInvokable in org.apache.flink.runtime.iterative.task

Modifier and Type	Class and Description
class	AbstractIterativePactTask<S extends org.apache.flink.api.common.functions.Function,OT> The abstract base class for all tasks able to participate in an iteration.
class	IterationHeadPactTask<X,Y,S extends org.apache.flink.api.common.functions.Function,OT> The head is responsible for coordinating an iteration and can run a PactDriver inside.
class	IterationIntermediatePactTask<S extends org.apache.flink.api.common.functions.Function,OT> An intermediate iteration task, which runs a Driver}inside.
class	IterationSynchronizationSinkTask The task responsible for synchronizing all iteration heads, implemented as an output task.
class	IterationTailPactTask<S extends org.apache.flink.api.common.functions.Function,OT> An iteration tail, which runs a driver inside.

Uses of AbstractInvokable in org.apache.flink.runtime.jobgraph

Methods in org.apache.flink.runtime.jobgraph that return types with arguments of type AbstractInvokable

Modifier and Type	Method and Description
Class<? extends AbstractInvokable>	JobVertex.getInvokableClass(ClassLoader cl) Returns the invokable class which represents the task of this vertex

Method parameters in org.apache.flink.runtime.jobgraph with type arguments of type AbstractInvokable

Modifier and Type	Method and Description
void	JobVertex.setInvokableClass(Class<? extends AbstractInvokable> invokable)

Uses of AbstractInvokable in org.apache.flink.runtime.memorymanager

Methods in org.apache.flink.runtime.memorymanager with parameters of type AbstractInvokable

Modifier and Type	Method and Description
List<org.apache.flink.core.memory.MemorySegment>	MemoryManager.allocatePages(AbstractInvokable owner, int numPages)
List<org.apache.flink.core.memory.MemorySegment>	DefaultMemoryManager.allocatePages(AbstractInvokable owner, int numPages)
void	MemoryManager.allocatePages(AbstractInvokable owner, List<org.apache.flink.core.memory.MemorySegment> target, int numPages)
void	DefaultMemoryManager.allocatePages(AbstractInvokable owner, List<org.apache.flink.core.memory.MemorySegment> target, int numPages)
void	MemoryManager.releaseAll(AbstractInvokable task) Releases all memory segments for the given task.
void	DefaultMemoryManager.releaseAll(AbstractInvokable owner)

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

Subclasses of AbstractInvokable in org.apache.flink.runtime.operators

Modifier and Type	Class and Description
class	DataSinkTask<IT> DataSinkTask which is executed by a task manager.
class	DataSourceTask<OT> DataSourceTask which is executed by a task manager.
class	RegularPactTask<S extends org.apache.flink.api.common.functions.Function,OT> The base class for all tasks.

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

Modifier and Type	Method and Description
AbstractInvokable	RegularPactTask.getOwningNepheleTask()
AbstractInvokable	PactTaskContext.getOwningNepheleTask()

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

Modifier and Type	Method and Description
static void	RegularPactTask.closeChainedTasks(List<ChainedDriver<?,?>> tasks, AbstractInvokable parent) Closes all chained tasks, in the order as they are stored in the array.
static String	RegularPactTask.constructLogString(String message, String taskName, AbstractInvokable parent) Utility function that composes a string for logging purposes.
static <T> org.apache.flink.util.Collector<T>	RegularPactTask.getOutputCollector(AbstractInvokable task, TaskConfig config, ClassLoader cl, List<RecordWriter<?>> eventualOutputs, int outputOffset, int numOutputs) Creates the Collector for the given task, as described by the given configuration.
static <T> org.apache.flink.util.Collector<T>	RegularPactTask.initOutputs(AbstractInvokable nepheleTask, ClassLoader cl, TaskConfig config, List<ChainedDriver<?,?>> chainedTasksTarget, List<RecordWriter<?>> eventualOutputs, org.apache.flink.api.common.ExecutionConfig executionConfig) Creates a writer for each output.
static void	RegularPactTask.logAndThrowException(Exception ex, AbstractInvokable parent) Prints an error message and throws the given exception.
static void	RegularPactTask.openChainedTasks(List<ChainedDriver<?,?>> tasks, AbstractInvokable parent) Opens all chained tasks, in the order as they are stored in the array.

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

Constructor and Description
TempBarrier(AbstractInvokable owner, org.apache.flink.util.MutableObjectIterator<T> input, org.apache.flink.api.common.typeutils.TypeSerializerFactory<T> serializerFactory, MemoryManager memManager, IOManager ioManager, int numPages)

Uses of AbstractInvokable in org.apache.flink.runtime.operators.chaining

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

Modifier and Type	Method and Description
void	SynchronousChainedCombineDriver.setup(AbstractInvokable parent)
abstract void	ChainedDriver.setup(AbstractInvokable parent)
void	ChainedAllReduceDriver.setup(AbstractInvokable parent)
void	ChainedMapDriver.setup(AbstractInvokable parent)
void	ChainedCollectorMapDriver.setup(AbstractInvokable parent)
void	ChainedTerminationCriterionDriver.setup(AbstractInvokable parent)
void	ChainedFlatMapDriver.setup(AbstractInvokable parent)
void	GroupCombineChainedDriver.setup(AbstractInvokable parent)
void	ChainedDriver.setup(TaskConfig config, String taskName, org.apache.flink.util.Collector<OT> outputCollector, AbstractInvokable parent, ClassLoader userCodeClassLoader, org.apache.flink.api.common.ExecutionConfig executionConfig)

Uses of AbstractInvokable in org.apache.flink.runtime.operators.hash

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

Modifier and Type	Method and Description
<BT,PT> MutableHashTable<BT,PT>	ReusingBuildSecondReOpenableHashMatchIterator.getHashJoin(org.apache.flink.api.common.typeutils.TypeSerializer<BT> buildSideSerializer, org.apache.flink.api.common.typeutils.TypeComparator<BT> buildSideComparator, org.apache.flink.api.common.typeutils.TypeSerializer<PT> probeSideSerializer, org.apache.flink.api.common.typeutils.TypeComparator<PT> probeSideComparator, org.apache.flink.api.common.typeutils.TypePairComparator<PT,BT> pairComparator, MemoryManager memManager, IOManager ioManager, AbstractInvokable ownerTask, double memoryFraction)
<BT,PT> MutableHashTable<BT,PT>	NonReusingBuildFirstReOpenableHashMatchIterator.getHashJoin(org.apache.flink.api.common.typeutils.TypeSerializer<BT> buildSideSerializer, org.apache.flink.api.common.typeutils.TypeComparator<BT> buildSideComparator, org.apache.flink.api.common.typeutils.TypeSerializer<PT> probeSideSerializer, org.apache.flink.api.common.typeutils.TypeComparator<PT> probeSideComparator, org.apache.flink.api.common.typeutils.TypePairComparator<PT,BT> pairComparator, MemoryManager memManager, IOManager ioManager, AbstractInvokable ownerTask, double memoryFraction)
<BT,PT> MutableHashTable<BT,PT>	HashMatchIteratorBase.getHashJoin(org.apache.flink.api.common.typeutils.TypeSerializer<BT> buildSideSerializer, org.apache.flink.api.common.typeutils.TypeComparator<BT> buildSideComparator, org.apache.flink.api.common.typeutils.TypeSerializer<PT> probeSideSerializer, org.apache.flink.api.common.typeutils.TypeComparator<PT> probeSideComparator, org.apache.flink.api.common.typeutils.TypePairComparator<PT,BT> pairComparator, MemoryManager memManager, IOManager ioManager, AbstractInvokable ownerTask, double memoryFraction)
<BT,PT> MutableHashTable<BT,PT>	ReusingBuildFirstReOpenableHashMatchIterator.getHashJoin(org.apache.flink.api.common.typeutils.TypeSerializer<BT> buildSideSerializer, org.apache.flink.api.common.typeutils.TypeComparator<BT> buildSideComparator, org.apache.flink.api.common.typeutils.TypeSerializer<PT> probeSideSerializer, org.apache.flink.api.common.typeutils.TypeComparator<PT> probeSideComparator, org.apache.flink.api.common.typeutils.TypePairComparator<PT,BT> pairComparator, MemoryManager memManager, IOManager ioManager, AbstractInvokable ownerTask, double memoryFraction)
<BT,PT> MutableHashTable<BT,PT>	NonReusingBuildSecondReOpenableHashMatchIterator.getHashJoin(org.apache.flink.api.common.typeutils.TypeSerializer<BT> buildSideSerializer, org.apache.flink.api.common.typeutils.TypeComparator<BT> buildSideComparator, org.apache.flink.api.common.typeutils.TypeSerializer<PT> probeSideSerializer, org.apache.flink.api.common.typeutils.TypeComparator<PT> probeSideComparator, org.apache.flink.api.common.typeutils.TypePairComparator<PT,BT> pairComparator, MemoryManager memManager, IOManager ioManager, AbstractInvokable ownerTask, double memoryFraction)

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

Constructor and Description
NonReusingBuildFirstHashMatchIterator(org.apache.flink.util.MutableObjectIterator<V1> firstInput, org.apache.flink.util.MutableObjectIterator<V2> secondInput, org.apache.flink.api.common.typeutils.TypeSerializer<V1> serializer1, org.apache.flink.api.common.typeutils.TypeComparator<V1> comparator1, org.apache.flink.api.common.typeutils.TypeSerializer<V2> serializer2, org.apache.flink.api.common.typeutils.TypeComparator<V2> comparator2, org.apache.flink.api.common.typeutils.TypePairComparator<V2,V1> pairComparator, MemoryManager memManager, IOManager ioManager, AbstractInvokable ownerTask, double memoryFraction)
NonReusingBuildFirstReOpenableHashMatchIterator(org.apache.flink.util.MutableObjectIterator<V1> firstInput, org.apache.flink.util.MutableObjectIterator<V2> secondInput, org.apache.flink.api.common.typeutils.TypeSerializer<V1> serializer1, org.apache.flink.api.common.typeutils.TypeComparator<V1> comparator1, org.apache.flink.api.common.typeutils.TypeSerializer<V2> serializer2, org.apache.flink.api.common.typeutils.TypeComparator<V2> comparator2, org.apache.flink.api.common.typeutils.TypePairComparator<V2,V1> pairComparator, MemoryManager memManager, IOManager ioManager, AbstractInvokable ownerTask, double memoryFraction)
NonReusingBuildSecondHashMatchIterator(org.apache.flink.util.MutableObjectIterator<V1> firstInput, org.apache.flink.util.MutableObjectIterator<V2> secondInput, org.apache.flink.api.common.typeutils.TypeSerializer<V1> serializer1, org.apache.flink.api.common.typeutils.TypeComparator<V1> comparator1, org.apache.flink.api.common.typeutils.TypeSerializer<V2> serializer2, org.apache.flink.api.common.typeutils.TypeComparator<V2> comparator2, org.apache.flink.api.common.typeutils.TypePairComparator<V1,V2> pairComparator, MemoryManager memManager, IOManager ioManager, AbstractInvokable ownerTask, double memoryFraction)
NonReusingBuildSecondReOpenableHashMatchIterator(org.apache.flink.util.MutableObjectIterator<V1> firstInput, org.apache.flink.util.MutableObjectIterator<V2> secondInput, org.apache.flink.api.common.typeutils.TypeSerializer<V1> serializer1, org.apache.flink.api.common.typeutils.TypeComparator<V1> comparator1, org.apache.flink.api.common.typeutils.TypeSerializer<V2> serializer2, org.apache.flink.api.common.typeutils.TypeComparator<V2> comparator2, org.apache.flink.api.common.typeutils.TypePairComparator<V1,V2> pairComparator, MemoryManager memManager, IOManager ioManager, AbstractInvokable ownerTask, double memoryFraction)
ReusingBuildFirstHashMatchIterator(org.apache.flink.util.MutableObjectIterator<V1> firstInput, org.apache.flink.util.MutableObjectIterator<V2> secondInput, org.apache.flink.api.common.typeutils.TypeSerializer<V1> serializer1, org.apache.flink.api.common.typeutils.TypeComparator<V1> comparator1, org.apache.flink.api.common.typeutils.TypeSerializer<V2> serializer2, org.apache.flink.api.common.typeutils.TypeComparator<V2> comparator2, org.apache.flink.api.common.typeutils.TypePairComparator<V2,V1> pairComparator, MemoryManager memManager, IOManager ioManager, AbstractInvokable ownerTask, double memoryFraction)
ReusingBuildFirstReOpenableHashMatchIterator(org.apache.flink.util.MutableObjectIterator<V1> firstInput, org.apache.flink.util.MutableObjectIterator<V2> secondInput, org.apache.flink.api.common.typeutils.TypeSerializer<V1> serializer1, org.apache.flink.api.common.typeutils.TypeComparator<V1> comparator1, org.apache.flink.api.common.typeutils.TypeSerializer<V2> serializer2, org.apache.flink.api.common.typeutils.TypeComparator<V2> comparator2, org.apache.flink.api.common.typeutils.TypePairComparator<V2,V1> pairComparator, MemoryManager memManager, IOManager ioManager, AbstractInvokable ownerTask, double memoryFraction)
ReusingBuildSecondHashMatchIterator(org.apache.flink.util.MutableObjectIterator<V1> firstInput, org.apache.flink.util.MutableObjectIterator<V2> secondInput, org.apache.flink.api.common.typeutils.TypeSerializer<V1> serializer1, org.apache.flink.api.common.typeutils.TypeComparator<V1> comparator1, org.apache.flink.api.common.typeutils.TypeSerializer<V2> serializer2, org.apache.flink.api.common.typeutils.TypeComparator<V2> comparator2, org.apache.flink.api.common.typeutils.TypePairComparator<V1,V2> pairComparator, MemoryManager memManager, IOManager ioManager, AbstractInvokable ownerTask, double memoryFraction)
ReusingBuildSecondReOpenableHashMatchIterator(org.apache.flink.util.MutableObjectIterator<V1> firstInput, org.apache.flink.util.MutableObjectIterator<V2> secondInput, org.apache.flink.api.common.typeutils.TypeSerializer<V1> serializer1, org.apache.flink.api.common.typeutils.TypeComparator<V1> comparator1, org.apache.flink.api.common.typeutils.TypeSerializer<V2> serializer2, org.apache.flink.api.common.typeutils.TypeComparator<V2> comparator2, org.apache.flink.api.common.typeutils.TypePairComparator<V1,V2> pairComparator, MemoryManager memManager, IOManager ioManager, AbstractInvokable ownerTask, double memoryFraction)

Uses of AbstractInvokable in org.apache.flink.runtime.operators.resettable

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

Constructor and Description
BlockResettableMutableObjectIterator(MemoryManager memoryManager, org.apache.flink.util.MutableObjectIterator<T> input, org.apache.flink.api.common.typeutils.TypeSerializer<T> serializer, int numMemoryPages, AbstractInvokable ownerTask)
NonReusingBlockResettableIterator(MemoryManager memoryManager, Iterator<T> input, org.apache.flink.api.common.typeutils.TypeSerializer<T> serializer, int numPages, AbstractInvokable ownerTask)
NonReusingBlockResettableIterator(MemoryManager memoryManager, org.apache.flink.api.common.typeutils.TypeSerializer<T> serializer, int numPages, AbstractInvokable ownerTask)
ReusingBlockResettableIterator(MemoryManager memoryManager, Iterator<T> input, org.apache.flink.api.common.typeutils.TypeSerializer<T> serializer, int numPages, AbstractInvokable ownerTask)
ReusingBlockResettableIterator(MemoryManager memoryManager, org.apache.flink.api.common.typeutils.TypeSerializer<T> serializer, int numPages, AbstractInvokable ownerTask)
SpillingResettableIterator(Iterator<T> input, org.apache.flink.api.common.typeutils.TypeSerializer<T> serializer, MemoryManager memoryManager, IOManager ioManager, int numPages, AbstractInvokable parentTask)
SpillingResettableMutableObjectIterator(org.apache.flink.util.MutableObjectIterator<T> input, org.apache.flink.api.common.typeutils.TypeSerializer<T> serializer, MemoryManager memoryManager, IOManager ioManager, int numPages, AbstractInvokable parentTask)

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

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

Modifier and Type	Method and Description
protected UnilateralSortMerger.ThreadBase<E>	UnilateralSortMerger.getReadingThread(ExceptionHandler<IOException> exceptionHandler, org.apache.flink.util.MutableObjectIterator<E> reader, UnilateralSortMerger.CircularQueues<E> queues, LargeRecordHandler<E> largeRecordHandler, AbstractInvokable parentTask, org.apache.flink.api.common.typeutils.TypeSerializer<E> serializer, long startSpillingBytes) Creates the reading thread.
protected UnilateralSortMerger.ThreadBase<E>	UnilateralSortMerger.getSortingThread(ExceptionHandler<IOException> exceptionHandler, UnilateralSortMerger.CircularQueues<E> queues, AbstractInvokable parentTask)
protected UnilateralSortMerger.ThreadBase<E>	CombiningUnilateralSortMerger.getSpillingThread(ExceptionHandler<IOException> exceptionHandler, UnilateralSortMerger.CircularQueues<E> queues, AbstractInvokable parentTask, MemoryManager memoryManager, IOManager ioManager, org.apache.flink.api.common.typeutils.TypeSerializerFactory<E> serializerFactory, org.apache.flink.api.common.typeutils.TypeComparator<E> comparator, List<org.apache.flink.core.memory.MemorySegment> sortReadMemory, List<org.apache.flink.core.memory.MemorySegment> writeMemory, int maxFileHandles)
protected UnilateralSortMerger.ThreadBase<E>	UnilateralSortMerger.getSpillingThread(ExceptionHandler<IOException> exceptionHandler, UnilateralSortMerger.CircularQueues<E> queues, AbstractInvokable parentTask, MemoryManager memoryManager, IOManager ioManager, org.apache.flink.api.common.typeutils.TypeSerializerFactory<E> serializerFactory, org.apache.flink.api.common.typeutils.TypeComparator<E> comparator, List<org.apache.flink.core.memory.MemorySegment> sortReadMemory, List<org.apache.flink.core.memory.MemorySegment> writeMemory, int maxFileHandles)

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

Constructor and Description
CombiningSpillingThread(ExceptionHandler<IOException> exceptionHandler, UnilateralSortMerger.CircularQueues<E> queues, AbstractInvokable parentTask, MemoryManager memManager, IOManager ioManager, org.apache.flink.api.common.typeutils.TypeSerializer<E> serializer, org.apache.flink.api.common.typeutils.TypeComparator<E> comparator, List<org.apache.flink.core.memory.MemorySegment> sortReadMemory, List<org.apache.flink.core.memory.MemorySegment> writeMemory, int maxNumFileHandles)
CombiningUnilateralSortMerger(org.apache.flink.api.common.functions.GroupCombineFunction<E,E> combineStub, MemoryManager memoryManager, IOManager ioManager, org.apache.flink.util.MutableObjectIterator<E> input, AbstractInvokable parentTask, org.apache.flink.api.common.typeutils.TypeSerializerFactory<E> serializerFactory, org.apache.flink.api.common.typeutils.TypeComparator<E> comparator, double memoryFraction, int maxNumFileHandles, float startSpillingFraction) Creates a new sorter that reads the data from a given reader and provides an iterator returning that data in a sorted manner.
CombiningUnilateralSortMerger(org.apache.flink.api.common.functions.GroupCombineFunction<E,E> combineStub, MemoryManager memoryManager, IOManager ioManager, org.apache.flink.util.MutableObjectIterator<E> input, AbstractInvokable parentTask, org.apache.flink.api.common.typeutils.TypeSerializerFactory<E> serializerFactory, org.apache.flink.api.common.typeutils.TypeComparator<E> comparator, double memoryFraction, int numSortBuffers, int maxNumFileHandles, float startSpillingFraction) Creates a new sorter that reads the data from a given reader and provides an iterator returning that data in a sorted manner.
LargeRecordHandler(org.apache.flink.api.common.typeutils.TypeSerializer<T> serializer, org.apache.flink.api.common.typeutils.TypeComparator<T> comparator, IOManager ioManager, MemoryManager memManager, List<org.apache.flink.core.memory.MemorySegment> memory, AbstractInvokable memoryOwner, int maxFilehandles)
NonReusingMergeMatchIterator(org.apache.flink.util.MutableObjectIterator<T1> input1, org.apache.flink.util.MutableObjectIterator<T2> input2, org.apache.flink.api.common.typeutils.TypeSerializer<T1> serializer1, org.apache.flink.api.common.typeutils.TypeComparator<T1> comparator1, org.apache.flink.api.common.typeutils.TypeSerializer<T2> serializer2, org.apache.flink.api.common.typeutils.TypeComparator<T2> comparator2, org.apache.flink.api.common.typeutils.TypePairComparator<T1,T2> pairComparator, MemoryManager memoryManager, IOManager ioManager, int numMemoryPages, AbstractInvokable parentTask)
ReadingThread(ExceptionHandler<IOException> exceptionHandler, org.apache.flink.util.MutableObjectIterator<E> reader, UnilateralSortMerger.CircularQueues<E> queues, LargeRecordHandler<E> largeRecordsHandler, E readTarget, AbstractInvokable parentTask, long startSpillingBytes) Creates a new reading thread.
ReusingMergeMatchIterator(org.apache.flink.util.MutableObjectIterator<T1> input1, org.apache.flink.util.MutableObjectIterator<T2> input2, org.apache.flink.api.common.typeutils.TypeSerializer<T1> serializer1, org.apache.flink.api.common.typeutils.TypeComparator<T1> comparator1, org.apache.flink.api.common.typeutils.TypeSerializer<T2> serializer2, org.apache.flink.api.common.typeutils.TypeComparator<T2> comparator2, org.apache.flink.api.common.typeutils.TypePairComparator<T1,T2> pairComparator, MemoryManager memoryManager, IOManager ioManager, int numMemoryPages, AbstractInvokable parentTask)
SortingThread(ExceptionHandler<IOException> exceptionHandler, UnilateralSortMerger.CircularQueues<E> queues, AbstractInvokable parentTask) Creates a new sorting thread.
SpillingThread(ExceptionHandler<IOException> exceptionHandler, UnilateralSortMerger.CircularQueues<E> queues, AbstractInvokable parentTask, MemoryManager memManager, IOManager ioManager, org.apache.flink.api.common.typeutils.TypeSerializer<E> serializer, org.apache.flink.api.common.typeutils.TypeComparator<E> comparator, List<org.apache.flink.core.memory.MemorySegment> sortReadMemory, List<org.apache.flink.core.memory.MemorySegment> writeMemory, int maxNumFileHandles) Creates the spilling thread.
ThreadBase(ExceptionHandler<IOException> exceptionHandler, String name, UnilateralSortMerger.CircularQueues<E> queues, AbstractInvokable parentTask) Creates a new thread.
UnilateralSortMerger(MemoryManager memoryManager, IOManager ioManager, org.apache.flink.util.MutableObjectIterator<E> input, AbstractInvokable parentTask, org.apache.flink.api.common.typeutils.TypeSerializerFactory<E> serializerFactory, org.apache.flink.api.common.typeutils.TypeComparator<E> comparator, double memoryFraction, int maxNumFileHandles, float startSpillingFraction)
UnilateralSortMerger(MemoryManager memoryManager, IOManager ioManager, org.apache.flink.util.MutableObjectIterator<E> input, AbstractInvokable parentTask, org.apache.flink.api.common.typeutils.TypeSerializerFactory<E> serializerFactory, org.apache.flink.api.common.typeutils.TypeComparator<E> comparator, double memoryFraction, int numSortBuffers, int maxNumFileHandles, float startSpillingFraction)
UnilateralSortMerger(MemoryManager memoryManager, IOManager ioManager, org.apache.flink.util.MutableObjectIterator<E> input, AbstractInvokable parentTask, org.apache.flink.api.common.typeutils.TypeSerializerFactory<E> serializerFactory, org.apache.flink.api.common.typeutils.TypeComparator<E> comparator, double memoryFraction, int numSortBuffers, int maxNumFileHandles, float startSpillingFraction, boolean noSpillingMemory, boolean handleLargeRecords)
UnilateralSortMerger(MemoryManager memoryManager, List<org.apache.flink.core.memory.MemorySegment> memory, IOManager ioManager, org.apache.flink.util.MutableObjectIterator<E> input, AbstractInvokable parentTask, org.apache.flink.api.common.typeutils.TypeSerializerFactory<E> serializerFactory, org.apache.flink.api.common.typeutils.TypeComparator<E> comparator, int numSortBuffers, int maxNumFileHandles, float startSpillingFraction, boolean handleLargeRecords)
UnilateralSortMerger(MemoryManager memoryManager, List<org.apache.flink.core.memory.MemorySegment> memory, IOManager ioManager, org.apache.flink.util.MutableObjectIterator<E> input, AbstractInvokable parentTask, org.apache.flink.api.common.typeutils.TypeSerializerFactory<E> serializerFactory, org.apache.flink.api.common.typeutils.TypeComparator<E> comparator, int numSortBuffers, int maxNumFileHandles, float startSpillingFraction, boolean noSpillingMemory, boolean handleLargeRecords)