Package org.apache.flink.runtime.operators.sort

Class LargeRecordHandler<T>

java.lang.Object

org.apache.flink.runtime.operators.sort.LargeRecordHandler<T>

public class LargeRecordHandler<T>
extends Object

Constructor Summary

Constructors

Constructor	Description
LargeRecordHandler(TypeSerializer<T> serializer, TypeComparator<T> comparator, IOManager ioManager, MemoryManager memManager, List<MemorySegment> memory, TaskInvokable memoryOwner, int maxFilehandles, ExecutionConfig executionConfig)

Method Summary

Modifier and Type	Method	Description
long	addRecord(T record)
void	close()	Closes all structures and deletes all temporary files.
MutableObjectIterator<T>	finishWriteAndSortKeys(List<MemorySegment> memory)
boolean	hasData()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

LargeRecordHandler

public LargeRecordHandler(TypeSerializer<T> serializer,
                          TypeComparator<T> comparator,
                          IOManager ioManager,
                          MemoryManager memManager,
                          List<MemorySegment> memory,
                          TaskInvokable memoryOwner,
                          int maxFilehandles,
                          ExecutionConfig executionConfig)

Method Detail

addRecord

public long addRecord(T record)
               throws IOException

Throws:

IOException

finishWriteAndSortKeys

public MutableObjectIterator<T> finishWriteAndSortKeys(List<MemorySegment> memory)
                                                throws IOException

Throws:

IOException

close

public void close()
           throws IOException

Closes all structures and deletes all temporary files. Even in the presence of failures, this method will try and continue closing files and deleting temporary files.

Throws:

IOException - Thrown if an error occurred while closing/deleting the files.

hasData

public boolean hasData()