Package | Description |
---|---|
org.apache.paimon.disk | |
org.apache.paimon.sort |
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() |
FileIOChannel.ID |
FileChannelManagerImpl.createChannel() |
FileIOChannel.ID |
IOManagerImpl.createChannel() |
FileIOChannel.ID |
FileChannelManager.createChannel()
Creates an ID identifying an underlying file channel and returns it.
|
FileIOChannel.ID |
IOManager.createChannel(String prefix) |
FileIOChannel.ID |
FileChannelManagerImpl.createChannel(String prefix) |
FileIOChannel.ID |
IOManagerImpl.createChannel(String prefix) |
FileIOChannel.ID |
FileChannelManager.createChannel(String prefix)
Creates an ID identifying an underlying file channel and returns it.
|
FileIOChannel.ID |
ChannelWithMeta.getChannel() |
FileIOChannel.ID |
AbstractFileIOChannel.getChannelID() |
FileIOChannel.ID |
FileIOChannel.getChannelID()
Gets the channel ID of this I/O channel.
|
FileIOChannel.ID |
FileIOChannel.Enumerator.next() |
Modifier and Type | Method and Description |
---|---|
BufferFileReader |
IOManager.createBufferFileReader(FileIOChannel.ID channelID) |
BufferFileReader |
IOManagerImpl.createBufferFileReader(FileIOChannel.ID channelID) |
BufferFileWriter |
IOManager.createBufferFileWriter(FileIOChannel.ID channelID) |
BufferFileWriter |
IOManagerImpl.createBufferFileWriter(FileIOChannel.ID channelID) |
static ChannelWriterOutputView |
FileChannelUtil.createOutputView(IOManager ioManager,
FileIOChannel.ID channel,
BlockCompressionFactory compressionCodecFactory,
int compressionBlockSize) |
static void |
IOManagerImpl.deleteChannel(FileIOChannel.ID channel)
Deletes the file underlying the given channel.
|
Constructor and Description |
---|
AbstractFileIOChannel(FileIOChannel.ID channelID,
boolean writeEnabled)
Creates a new channel to the path indicated by the given ID.
|
BufferFileReaderImpl(FileIOChannel.ID channelID) |
BufferFileWriterImpl(FileIOChannel.ID channelID) |
ChannelReaderInputView(FileIOChannel.ID id,
IOManager ioManager,
BlockCompressionFactory compressionCodecFactory,
int compressionBlockSize,
int numBlocks) |
ChannelWithMeta(FileIOChannel.ID channel,
int blockCount,
long numEstimatedBytes) |
Modifier and Type | Method and Description |
---|---|
void |
SpillChannelManager.addChannel(FileIOChannel.ID id)
Add a new File channel.
|
void |
SpillChannelManager.removeChannel(FileIOChannel.ID id) |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.