Package | Description |
---|---|
org.apache.flink.runtime.io.disk | |
org.apache.flink.runtime.io.disk.iomanager | |
org.apache.flink.runtime.operators.hash | |
org.apache.flink.runtime.operators.sort |
Constructor and Description |
---|
ChannelReaderInputViewIterator(IOManager ioAccess,
FileIOChannel.ID channel,
LinkedBlockingQueue<MemorySegment> returnQueue,
List<MemorySegment> segments,
List<MemorySegment> freeMemTarget,
TypeSerializer<E> accessors,
int numBlocks) |
ChannelReaderInputViewIterator(IOManager ioAccess,
FileIOChannel.ID channel,
List<MemorySegment> segments,
List<MemorySegment> freeMemTarget,
TypeSerializer<E> accessors,
int numBlocks) |
SeekableFileChannelInputView(IOManager ioManager,
FileIOChannel.ID channelId,
MemoryManager memManager,
List<MemorySegment> memory,
int sizeOfLastBlock) |
Modifier and Type | Field and Description |
---|---|
protected FileIOChannel.ID |
AbstractFileIOChannel.id
The ID of the underlying channel.
|
Modifier and Type | Method and Description |
---|---|
FileIOChannel.ID |
IOManager.createChannel()
Creates a new
FileIOChannel.ID in one of the temp directories. |
FileIOChannel.ID |
AbstractFileIOChannel.getChannelID() |
FileIOChannel.ID |
FileIOChannel.getChannelID()
Gets the channel ID of this I/O channel.
|
FileIOChannel.ID |
FileIOChannel.Enumerator.next() |
Constructor and Description |
---|
AbstractFileIOChannel(FileIOChannel.ID channelID,
boolean writeEnabled)
Creates a new channel to the path indicated by the given ID.
|
AsynchronousBlockReader(FileIOChannel.ID channelID,
RequestQueue<org.apache.flink.runtime.io.disk.iomanager.ReadRequest> requestQueue,
LinkedBlockingQueue<MemorySegment> returnSegments)
Creates a new block channel reader for the given channel.
|
AsynchronousBlockWriter(FileIOChannel.ID channelID,
RequestQueue<org.apache.flink.runtime.io.disk.iomanager.WriteRequest> requestQueue,
LinkedBlockingQueue<MemorySegment> returnSegments)
Creates a new block channel writer for the given channel.
|
AsynchronousBlockWriterWithCallback(FileIOChannel.ID channelID,
RequestQueue<org.apache.flink.runtime.io.disk.iomanager.WriteRequest> requestQueue,
RequestDoneCallback<MemorySegment> callback)
Creates a new asynchronous block writer for the given channel.
|
AsynchronousBufferFileReader(FileIOChannel.ID channelID,
RequestQueue<org.apache.flink.runtime.io.disk.iomanager.ReadRequest> requestQueue,
RequestDoneCallback<Buffer> callback) |
AsynchronousBufferFileSegmentReader(FileIOChannel.ID channelID,
RequestQueue<org.apache.flink.runtime.io.disk.iomanager.ReadRequest> requestQueue,
RequestDoneCallback<FileSegment> callback) |
AsynchronousBufferFileWriter(FileIOChannel.ID channelID,
RequestQueue<org.apache.flink.runtime.io.disk.iomanager.WriteRequest> requestQueue) |
AsynchronousBulkBlockReader(FileIOChannel.ID channelID,
RequestQueue<org.apache.flink.runtime.io.disk.iomanager.ReadRequest> requestQueue,
List<MemorySegment> sourceSegments,
int numBlocks) |
AsynchronousFileIOChannel(FileIOChannel.ID channelID,
RequestQueue<R> requestQueue,
RequestDoneCallback<T> callback,
boolean writeEnabled)
Creates a new channel access to the path indicated by the given ID.
|
SynchronousBufferFileReader(FileIOChannel.ID channelID,
boolean writeEnabled) |
SynchronousFileIOChannel(FileIOChannel.ID channelID,
boolean writeEnabled) |
Modifier and Type | Method and Description |
---|---|
int |
HashPartition.spillPartition(List<MemorySegment> target,
IOManager ioAccess,
FileIOChannel.ID targetChannel,
LinkedBlockingQueue<MemorySegment> bufferReturnQueue)
Spills this partition to disk and sets it up such that it continues spilling records that are added to
it.
|
Modifier and Type | Method and Description |
---|---|
FileIOChannel.ID |
UnilateralSortMerger.ChannelWithBlockCount.getChannel() |
Modifier and Type | Method and Description |
---|---|
protected void |
UnilateralSortMerger.SpillingThread.registerChannelToBeRemovedAtShudown(FileIOChannel.ID channel)
Adds a channel to the list of channels that are to be removed at shutdown.
|
protected void |
UnilateralSortMerger.SpillingThread.unregisterChannelToBeRemovedAtShudown(FileIOChannel.ID channel)
Removes a channel from the list of channels that are to be removed at shutdown.
|
Constructor and Description |
---|
ChannelWithBlockCount(FileIOChannel.ID channel,
int blockCount) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.