Uses of Interface
org.apache.flink.runtime.io.disk.iomanager.BlockChannelWriter

Packages that use BlockChannelWriter

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.io
org.apache.flink.table.runtime.util

Uses of BlockChannelWriter in org.apache.flink.runtime.io.disk

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

Constructor and Description
FileChannelOutputView(BlockChannelWriter<MemorySegment> writer, MemoryManager memManager, List<MemorySegment> memory, int segmentSize)

Uses of BlockChannelWriter in org.apache.flink.runtime.io.disk.iomanager

Classes in org.apache.flink.runtime.io.disk.iomanager that implement BlockChannelWriter

Modifier and Type	Class and Description
class	AsynchronousBlockWriter

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

Modifier and Type	Method and Description
BlockChannelWriter<MemorySegment>	IOManager.createBlockChannelWriter(FileIOChannel.ID channelID) Creates a block channel writer that writes to the given channel.
abstract BlockChannelWriter<MemorySegment>	IOManager.createBlockChannelWriter(FileIOChannel.ID channelID, LinkedBlockingQueue<MemorySegment> returnQueue) Creates a block channel writer that writes to the given channel.
BlockChannelWriter<MemorySegment>	IOManagerAsync.createBlockChannelWriter(FileIOChannel.ID channelID, LinkedBlockingQueue<MemorySegment> returnQueue)

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

Constructor and Description
ChannelWriterOutputView(BlockChannelWriter<MemorySegment> writer, int segmentSize) Creates an new ChannelWriterOutputView that writes to the given channel.
ChannelWriterOutputView(BlockChannelWriter<MemorySegment> writer, List<MemorySegment> memory, int segmentSize) Creates an new ChannelWriterOutputView that writes to the given channel and buffers data in the given memory segments.

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

Fields in org.apache.flink.runtime.operators.hash declared as BlockChannelWriter

Modifier and Type	Field and Description
protected BlockChannelWriter<MemorySegment>	HashPartition.probeSideChannel

Methods in org.apache.flink.runtime.operators.hash that return BlockChannelWriter

Modifier and Type	Method and Description
BlockChannelWriter<MemorySegment>	HashPartition.getBuildSideChannel()
BlockChannelWriter<MemorySegment>	HashPartition.getProbeSideChannel()

Uses of BlockChannelWriter in org.apache.flink.table.runtime.io

Classes in org.apache.flink.table.runtime.io that implement BlockChannelWriter

Modifier and Type	Class and Description
class	CompressedBlockChannelWriter Compressed block channel writer provides a scenario where MemorySegment must be maintained.

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

Constructor and Description
HeaderlessChannelWriterOutputView(BlockChannelWriter<MemorySegment> writer, List<MemorySegment> memory, int segmentSize)

Uses of BlockChannelWriter in org.apache.flink.table.runtime.util

Methods in org.apache.flink.table.runtime.util that return BlockChannelWriter

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