| 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.
|
| Modifier and Type | Method and Description |
|---|---|
Class<? extends AbstractInvokable> |
JobVertex.getInvokableClass(ClassLoader cl)
Returns the invokable class which represents the task of this vertex
|
| Modifier and Type | Method and Description |
|---|---|
void |
JobVertex.setInvokableClass(Class<? extends AbstractInvokable> invokable) |
| 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) |
| 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.
|
| Modifier and Type | Method and Description |
|---|---|
AbstractInvokable |
RegularPactTask.getOwningNepheleTask() |
AbstractInvokable |
PactTaskContext.getOwningNepheleTask() |
| 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.
|
| 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) |
| 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) |
| 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) |
| 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) |
| 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) |
| 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) |
| 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) |
Copyright © 2014–2015 The Apache Software Foundation. All rights reserved.