Uses of Interface
org.apache.paimon.disk.IOManager

Packages that use IOManager

Package	Description
org.apache.paimon.append
org.apache.paimon.crosspartition
org.apache.paimon.disk
org.apache.paimon.flink.source
org.apache.paimon.flink.source.align
org.apache.paimon.lookup
org.apache.paimon.mergetree
org.apache.paimon.operation
org.apache.paimon.sort
org.apache.paimon.spark
org.apache.paimon.table.query
org.apache.paimon.table.sink
org.apache.paimon.table.source
org.apache.paimon.table.source.splitread
org.apache.paimon.table.system

Uses of IOManager in org.apache.paimon.append

Constructors in org.apache.paimon.append with parameters of type IOManager

Constructor and Description

AppendOnlyWriter(FileIO fileIO, IOManager ioManager, long schemaId, FileFormat fileFormat, long targetFileSize, RowType writeSchema, long maxSequenceNumber, CompactManager compactManager, IOFunction<List<DataFileMeta>,RecordReaderIterator<InternalRow>> bucketFileRead, boolean forceCompact, DataFilePathFactory pathFactory, CommitIncrement increment, boolean useWriteBuffer, boolean spillable, String fileCompression, CompressOptions spillCompression, SimpleColStatsCollector.Factory[] statsCollectors, MemorySize maxDiskSize, FileIndexOptions fileIndexOptions, boolean asyncFileWrite)

Uses of IOManager in org.apache.paimon.crosspartition

Methods in org.apache.paimon.crosspartition with parameters of type IOManager

Modifier and Type	Method and Description
void	GlobalIndexAssigner.open(long offHeapMemory, IOManager ioManager, int numAssigners, int assignId, java.util.function.BiConsumer<InternalRow,Integer> collector)

Uses of IOManager in org.apache.paimon.disk

Classes in org.apache.paimon.disk that implement IOManager

Modifier and Type	Class and Description
class	IOManagerImpl The facade for the provided I/O manager services.

Methods in org.apache.paimon.disk that return IOManager

Modifier and Type	Method and Description
static IOManager	IOManager.create(String tempDir)
static IOManager	IOManager.create(String[] tempDirs)

Methods in org.apache.paimon.disk with parameters of type IOManager

Modifier and Type	Method and Description
static ChannelReaderInputView	FileChannelUtil.createInputView(IOManager ioManager, ChannelWithMeta channel, List<FileIOChannel> channels, BlockCompressionFactory compressionCodecFactory, int compressionBlockSize)
static ChannelWriterOutputView	FileChannelUtil.createOutputView(IOManager ioManager, FileIOChannel.ID channel, BlockCompressionFactory compressionCodecFactory, int compressionBlockSize)
static RowBuffer	RowBuffer.getBuffer(IOManager ioManager, MemorySegmentPool memoryPool, AbstractRowDataSerializer<InternalRow> serializer, boolean spillable, MemorySize maxDiskSize, CompressOptions compression)

Constructors in org.apache.paimon.disk with parameters of type IOManager

Constructor and Description
ChannelReaderInputView(FileIOChannel.ID id, IOManager ioManager, BlockCompressionFactory compressionCodecFactory, int compressionBlockSize, int numBlocks)

Uses of IOManager in org.apache.paimon.flink.source

Constructors in org.apache.paimon.flink.source with parameters of type IOManager

Constructor and Description
FileStoreSourceReader(org.apache.flink.api.connector.source.SourceReaderContext readerContext, TableRead tableRead, FileStoreSourceReaderMetrics metrics, IOManager ioManager, Long limit)
FileStoreSourceReader(org.apache.flink.api.connector.source.SourceReaderContext readerContext, TableRead tableRead, FileStoreSourceReaderMetrics metrics, IOManager ioManager, Long limit, org.apache.flink.connector.base.source.reader.synchronization.FutureCompletingBlockingQueue<org.apache.flink.connector.base.source.reader.RecordsWithSplitIds<org.apache.flink.connector.file.src.reader.BulkFormat.RecordIterator<org.apache.flink.table.data.RowData>>> elementsQueue)

Uses of IOManager in org.apache.paimon.flink.source.align

Constructors in org.apache.paimon.flink.source.align with parameters of type IOManager

Constructor and Description

AlignedSourceReader(org.apache.flink.api.connector.source.SourceReaderContext readerContext, TableRead tableRead, FileStoreSourceReaderMetrics metrics, IOManager ioManager, Long limit, org.apache.flink.connector.base.source.reader.synchronization.FutureCompletingBlockingQueue<org.apache.flink.connector.base.source.reader.RecordsWithSplitIds<org.apache.flink.connector.file.src.reader.BulkFormat.RecordIterator<org.apache.flink.table.data.RowData>>> elementsQueue)

Uses of IOManager in org.apache.paimon.lookup

Methods in org.apache.paimon.lookup with parameters of type IOManager

Modifier and Type	Method and Description
static BinaryExternalSortBuffer	RocksDBState.createBulkLoadSorter(IOManager ioManager, CoreOptions options)

Uses of IOManager in org.apache.paimon.mergetree

Methods in org.apache.paimon.mergetree with parameters of type IOManager

Modifier and Type	Method and Description
void	MergeSorter.setIOManager(IOManager ioManager)

Constructors in org.apache.paimon.mergetree with parameters of type IOManager

Constructor and Description
MergeSorter(CoreOptions options, RowType keyType, RowType valueType, IOManager ioManager)
MergeTreeWriter(boolean writeBufferSpillable, MemorySize maxDiskSize, int sortMaxFan, CompressOptions sortCompression, IOManager ioManager, CompactManager compactManager, long maxSequenceNumber, Comparator<InternalRow> keyComparator, MergeFunction<KeyValue> mergeFunction, KeyValueFileWriterFactory writerFactory, boolean commitForceCompact, CoreOptions.ChangelogProducer changelogProducer, CommitIncrement increment, FieldsComparator userDefinedSeqComparator)
SortBufferWriteBuffer(RowType keyType, RowType valueType, FieldsComparator userDefinedSeqComparator, MemorySegmentPool memoryPool, boolean spillable, MemorySize maxDiskSize, int sortMaxFan, CompressOptions compression, IOManager ioManager)

Uses of IOManager in org.apache.paimon.operation

Fields in org.apache.paimon.operation declared as IOManager

Modifier and Type	Field and Description
protected IOManager	AbstractFileStoreWrite.ioManager

Methods in org.apache.paimon.operation with parameters of type IOManager

Modifier and Type	Method and Description
MergeFileSplitRead	MergeFileSplitRead.withIOManager(IOManager ioManager)
SplitRead<InternalRow>	RawFileSplitRead.withIOManager(IOManager ioManager)
FileStoreWrite<T>	FileStoreWrite.withIOManager(IOManager ioManager)
SplitRead<T>	SplitRead.withIOManager(IOManager ioManager)
FileStoreWrite<T>	AbstractFileStoreWrite.withIOManager(IOManager ioManager)

Uses of IOManager in org.apache.paimon.sort

Fields in org.apache.paimon.sort declared as IOManager

Modifier and Type	Field and Description
protected IOManager	AbstractBinaryExternalMerger.ioManager

Methods in org.apache.paimon.sort with parameters of type IOManager

Modifier and Type	Method and Description
static BinaryExternalSortBuffer	BinaryExternalSortBuffer.create(IOManager ioManager, RowType rowType, int[] keyFields, long bufferSize, int pageSize, int maxNumFileHandles, CompressOptions compression, MemorySize maxDiskSize)
static BinaryExternalSortBuffer	BinaryExternalSortBuffer.create(IOManager ioManager, RowType rowType, int[] keyFields, MemorySegmentPool pool, int maxNumFileHandles, CompressOptions compression, MemorySize maxDiskSize)

Constructors in org.apache.paimon.sort with parameters of type IOManager

Constructor and Description
AbstractBinaryExternalMerger(IOManager ioManager, int pageSize, int maxFanIn, SpillChannelManager channelManager, BlockCompressionFactory compressionCodecFactory, int compressionBlockSize)
BinaryExternalMerger(IOManager ioManager, int pageSize, int maxFanIn, SpillChannelManager channelManager, BinaryRowSerializer serializer, RecordComparator comparator, BlockCompressionFactory compressionCodecFactory, int compressionBlockSize)
BinaryExternalSortBuffer(BinaryRowSerializer serializer, RecordComparator comparator, int pageSize, BinaryInMemorySortBuffer inMemorySortBuffer, IOManager ioManager, int maxNumFileHandles, CompressOptions compression, MemorySize maxDiskSize)

Uses of IOManager in org.apache.paimon.spark

Methods in org.apache.paimon.spark that return IOManager

Modifier and Type	Method and Description
static IOManager	SparkUtils.createIOManager()

Uses of IOManager in org.apache.paimon.table.query

Methods in org.apache.paimon.table.query with parameters of type IOManager

Modifier and Type	Method and Description
LocalTableQuery	LocalTableQuery.withIOManager(IOManager ioManager)

Uses of IOManager in org.apache.paimon.table.sink

Methods in org.apache.paimon.table.sink with parameters of type IOManager

Modifier and Type	Method and Description
TableWrite	TableWrite.withIOManager(IOManager ioManager) With IOManager, this is needed if 'write-buffer-spillable' is set to true.
TableWriteImpl<T>	TableWriteImpl.withIOManager(IOManager ioManager)

Uses of IOManager in org.apache.paimon.table.source

Methods in org.apache.paimon.table.source with parameters of type IOManager

Modifier and Type	Method and Description
TableRead	KeyValueTableRead.withIOManager(IOManager ioManager)
TableRead	AbstractDataTableRead.withIOManager(IOManager ioManager)
TableRead	TableRead.withIOManager(IOManager ioManager)

Uses of IOManager in org.apache.paimon.table.source.splitread

Methods in org.apache.paimon.table.source.splitread with parameters of type IOManager

Modifier and Type	Method and Description
SplitRead<InternalRow>	IncrementalDiffSplitRead.withIOManager(IOManager ioManager)

Uses of IOManager in org.apache.paimon.table.system

Methods in org.apache.paimon.table.system with parameters of type IOManager

Modifier and Type	Method and Description
TableRead	TableLineageTable.TableLineageRead.withIOManager(IOManager ioManager)