Uses of Class
org.apache.flink.runtime.io.disk.iomanager.FileIOChannel.ID

Packages that use FileIOChannel.ID

Package	Description
org.apache.flink.runtime.io.disk
org.apache.flink.runtime.io.disk.iomanager
org.apache.flink.runtime.operators.hash
org.apache.flink.table.runtime.hashtable
org.apache.flink.table.runtime.io
org.apache.flink.table.runtime.operators.sort
org.apache.flink.table.runtime.util

Uses of FileIOChannel.ID in org.apache.flink.runtime.io.disk

Methods in org.apache.flink.runtime.io.disk that return FileIOChannel.ID

Modifier and Type	Method and Description
FileIOChannel.ID	FileChannelManagerImpl.createChannel()
FileIOChannel.ID	FileChannelManager.createChannel() Creates an ID identifying an underlying file channel and returns it.

Constructors in org.apache.flink.runtime.io.disk with parameters of type FileIOChannel.ID

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)

Uses of FileIOChannel.ID in org.apache.flink.runtime.io.disk.iomanager

Fields in org.apache.flink.runtime.io.disk.iomanager declared as FileIOChannel.ID

Modifier and Type	Field and Description
protected FileIOChannel.ID	AbstractFileIOChannel.id The ID of the underlying channel.

Methods in org.apache.flink.runtime.io.disk.iomanager that return FileIOChannel.ID

Modifier and Type	Method and Description
FileIOChannel.ID	IOManager.createChannel() Creates a new FileIOChannel.ID in one of the temp directories.
FileIOChannel.ID	FileIOChannel.getChannelID() Gets the channel ID of this I/O channel.
FileIOChannel.ID	AbstractFileIOChannel.getChannelID()
FileIOChannel.ID	FileIOChannel.Enumerator.next()

Methods in org.apache.flink.runtime.io.disk.iomanager with parameters of type FileIOChannel.ID

Modifier and Type	Method and Description
BlockChannelReader<MemorySegment>	IOManager.createBlockChannelReader(FileIOChannel.ID channelID) Creates a block channel reader that reads blocks from the given channel.
BlockChannelReader<MemorySegment>	IOManagerAsync.createBlockChannelReader(FileIOChannel.ID channelID, LinkedBlockingQueue<MemorySegment> returnQueue) Creates a block channel reader that reads blocks from the given channel.
abstract BlockChannelReader<MemorySegment>	IOManager.createBlockChannelReader(FileIOChannel.ID channelID, LinkedBlockingQueue<MemorySegment> returnQueue) Creates a block channel reader that reads blocks from the given channel.
BlockChannelWriter<MemorySegment>	IOManager.createBlockChannelWriter(FileIOChannel.ID channelID) Creates a block channel writer that writes to the given channel.
BlockChannelWriter<MemorySegment>	IOManagerAsync.createBlockChannelWriter(FileIOChannel.ID channelID, LinkedBlockingQueue<MemorySegment> returnQueue)
abstract BlockChannelWriter<MemorySegment>	IOManager.createBlockChannelWriter(FileIOChannel.ID channelID, LinkedBlockingQueue<MemorySegment> returnQueue) Creates a block channel writer that writes to the given channel.
BlockChannelWriterWithCallback<MemorySegment>	IOManagerAsync.createBlockChannelWriter(FileIOChannel.ID channelID, RequestDoneCallback<MemorySegment> callback)
abstract BlockChannelWriterWithCallback<MemorySegment>	IOManager.createBlockChannelWriter(FileIOChannel.ID channelID, RequestDoneCallback<MemorySegment> callback) Creates a block channel writer that writes to the given channel.
BufferFileReader	IOManagerAsync.createBufferFileReader(FileIOChannel.ID channelID, RequestDoneCallback<Buffer> callback)
abstract BufferFileReader	IOManager.createBufferFileReader(FileIOChannel.ID channelID, RequestDoneCallback<Buffer> callback)
BufferFileSegmentReader	IOManagerAsync.createBufferFileSegmentReader(FileIOChannel.ID channelID, RequestDoneCallback<FileSegment> callback)
abstract BufferFileSegmentReader	IOManager.createBufferFileSegmentReader(FileIOChannel.ID channelID, RequestDoneCallback<FileSegment> callback)
BufferFileWriter	IOManagerAsync.createBufferFileWriter(FileIOChannel.ID channelID)
abstract BufferFileWriter	IOManager.createBufferFileWriter(FileIOChannel.ID channelID)
BulkBlockChannelReader	IOManagerAsync.createBulkBlockChannelReader(FileIOChannel.ID channelID, List<MemorySegment> targetSegments, int numBlocks) Creates a block channel reader that reads all blocks from the given channel directly in one bulk.
abstract BulkBlockChannelReader	IOManager.createBulkBlockChannelReader(FileIOChannel.ID channelID, List<MemorySegment> targetSegments, int numBlocks) Creates a block channel reader that reads all blocks from the given channel directly in one bulk.
static void	IOManager.deleteChannel(FileIOChannel.ID channel) Deletes the file underlying the given channel.

Constructors in org.apache.flink.runtime.io.disk.iomanager with parameters of type FileIOChannel.ID

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)

Uses of FileIOChannel.ID in org.apache.flink.runtime.operators.hash

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

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.

Uses of FileIOChannel.ID in org.apache.flink.table.runtime.hashtable

Methods in org.apache.flink.table.runtime.hashtable with parameters of type FileIOChannel.ID

Modifier and Type	Method and Description
protected HeaderlessChannelReaderInputView	BaseHybridHashTable.createInputView(FileIOChannel.ID id, int blockCount, int lastSegmentLimit)
protected List<MemorySegment>	BaseHybridHashTable.readAllBuffers(FileIOChannel.ID id, int blockCount)

Uses of FileIOChannel.ID in org.apache.flink.table.runtime.io

Methods in org.apache.flink.table.runtime.io that return FileIOChannel.ID

Modifier and Type	Method and Description
FileIOChannel.ID	ChannelWithMeta.getChannel()
FileIOChannel.ID	CompressedBlockChannelWriter.getChannelID()
FileIOChannel.ID	CompressedBlockChannelReader.getChannelID()

Constructors in org.apache.flink.table.runtime.io with parameters of type FileIOChannel.ID

Constructor and Description
ChannelWithMeta(FileIOChannel.ID channel, int blockCount, int numBytesInLastBlock)
CompressedBlockChannelReader(IOManager ioManager, FileIOChannel.ID channel, LinkedBlockingQueue<MemorySegment> blockQueue, BlockCompressionFactory codecFactory, int preferBlockSize, int segmentSize)
CompressedBlockChannelWriter(IOManager ioManager, FileIOChannel.ID channel, LinkedBlockingQueue<MemorySegment> blockQueue, BlockCompressionFactory codecFactory, int preferBlockSize, int segmentSize)
CompressedHeaderlessChannelReaderInputView(FileIOChannel.ID id, IOManager ioManager, BlockCompressionFactory compressionCodecFactory, int compressionBlockSize, int numBlocks)

Uses of FileIOChannel.ID in org.apache.flink.table.runtime.operators.sort

Methods in org.apache.flink.table.runtime.operators.sort with parameters of type FileIOChannel.ID

Modifier and Type	Method and Description
void	SpillChannelManager.addChannel(FileIOChannel.ID id) Add a new File channel.
void	SpillChannelManager.removeChannel(FileIOChannel.ID id)

Uses of FileIOChannel.ID in org.apache.flink.table.runtime.util

Methods in org.apache.flink.table.runtime.util with parameters of type FileIOChannel.ID

Modifier and Type	Method and Description
static BlockChannelReader<MemorySegment>	FileChannelUtil.createBlockChannelReader(IOManager ioManager, FileIOChannel.ID channel, LinkedBlockingQueue<MemorySegment> bufferReturnQueue, boolean compressionEnable, BlockCompressionFactory compressionCodecFactory, int compressionBlockSize, int segmentSize)
static BlockChannelWriter<MemorySegment>	FileChannelUtil.createBlockChannelWriter(IOManager ioManager, FileIOChannel.ID channel, LinkedBlockingQueue<MemorySegment> bufferReturnQueue, boolean compressionEnable, BlockCompressionFactory compressionCodecFactory, int compressionBlockSize, int segmentSize)
static AbstractChannelWriterOutputView	FileChannelUtil.createOutputView(IOManager ioManager, FileIOChannel.ID channel, boolean compressionEnable, BlockCompressionFactory compressionCodecFactory, int compressionBlockSize, int segmentSize)