Package | Description |
---|---|
org.apache.paimon.append | |
org.apache.paimon.io | |
org.apache.paimon.utils |
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,
boolean statsDenseStore) |
Modifier and Type | Method and Description |
---|---|
DataFilePathFactory |
KeyValueFileWriterFactory.pathFactory(int level) |
Modifier and Type | Method and Description |
---|---|
List<Path> |
DataFileMeta.collectFiles(DataFilePathFactory pathFactory) |
static FileIndexResult |
FileIndexEvaluator.evaluate(FileIO fileIO,
TableSchema dataSchema,
List<Predicate> dataFilter,
DataFilePathFactory dataFilePathFactory,
DataFileMeta file) |
Constructor and Description |
---|
RowDataRollingFileWriter(FileIO fileIO,
long schemaId,
FileFormat fileFormat,
long targetFileSize,
RowType writeSchema,
DataFilePathFactory pathFactory,
LongCounter seqNumCounter,
String fileCompression,
SimpleColStatsCollector.Factory[] statsCollectors,
FileIndexOptions fileIndexOptions,
FileSource fileSource,
boolean asyncFileWrite,
boolean statsDenseStore) |
Modifier and Type | Method and Description |
---|---|
DataFilePathFactory |
FileStorePathFactory.createDataFilePathFactory(BinaryRow partition,
int bucket) |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.