org.apache.flink.table.runtime.util

Class FileChannelUtil

java.lang.Object

org.apache.flink.table.runtime.util.FileChannelUtil

public class FileChannelUtil
extends Object

File channel util for runtime.

Constructor Summary

Constructors

Constructor and Description
FileChannelUtil()

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

FileChannelUtil

public FileChannelUtil()

Method Detail

createInputView

public static AbstractChannelReaderInputView createInputView(IOManager ioManager,
                                                             ChannelWithMeta channel,
                                                             List<FileIOChannel> channels,
                                                             boolean compressionEnabled,
                                                             BlockCompressionFactory compressionCodecFactory,
                                                             int compressionBlockSize,
                                                             int segmentSize)
                                                      throws IOException

Throws:

IOException

createOutputView

public static AbstractChannelWriterOutputView createOutputView(IOManager ioManager,
                                                               FileIOChannel.ID channel,
                                                               boolean compressionEnabled,
                                                               BlockCompressionFactory compressionCodecFactory,
                                                               int compressionBlockSize,
                                                               int segmentSize)
                                                        throws IOException

Throws:

IOException

createBlockChannelWriter

public static BlockChannelWriter<MemorySegment> createBlockChannelWriter(IOManager ioManager,
                                                                         FileIOChannel.ID channel,
                                                                         LinkedBlockingQueue<MemorySegment> bufferReturnQueue,
                                                                         boolean compressionEnable,
                                                                         BlockCompressionFactory compressionCodecFactory,
                                                                         int compressionBlockSize,
                                                                         int segmentSize)
                                                                  throws IOException

Throws:

IOException

createBlockChannelReader

public static BlockChannelReader<MemorySegment> createBlockChannelReader(IOManager ioManager,
                                                                         FileIOChannel.ID channel,
                                                                         LinkedBlockingQueue<MemorySegment> bufferReturnQueue,
                                                                         boolean compressionEnable,
                                                                         BlockCompressionFactory compressionCodecFactory,
                                                                         int compressionBlockSize,
                                                                         int segmentSize)
                                                                  throws IOException

Throws:

IOException