Package | Description |
---|---|
org.apache.paimon | |
org.apache.paimon.append | |
org.apache.paimon.io |
Modifier and Type | Method and Description |
---|---|
FileIndexOptions |
CoreOptions.indexColumnsOptions() |
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 |
---|---|
static DataFileIndexWriter |
DataFileIndexWriter.create(FileIO fileIO,
Path path,
RowType rowType,
FileIndexOptions fileIndexOptions) |
static DataFileIndexWriter |
DataFileIndexWriter.create(FileIO fileIO,
Path path,
RowType rowType,
FileIndexOptions fileIndexOptions,
Map<String,String> colNameMapping) |
Constructor and Description |
---|
DataFileIndexWriter(FileIO fileIO,
Path path,
RowType rowType,
FileIndexOptions fileIndexOptions,
Map<String,String> colNameMapping) |
KeyValueDataFileWriter(FileIO fileIO,
FormatWriterFactory factory,
Path path,
java.util.function.Function<KeyValue,InternalRow> converter,
RowType keyType,
RowType valueType,
SimpleStatsExtractor simpleStatsExtractor,
long schemaId,
int level,
String compression,
CoreOptions options,
FileSource fileSource,
FileIndexOptions fileIndexOptions) |
RowDataFileWriter(FileIO fileIO,
FormatWriterFactory factory,
Path path,
RowType writeSchema,
SimpleStatsExtractor simpleStatsExtractor,
long schemaId,
LongCounter seqNumCounter,
String fileCompression,
SimpleColStatsCollector.Factory[] statsCollectors,
FileIndexOptions fileIndexOptions,
FileSource fileSource,
boolean asyncFileWrite,
boolean statsDenseStore) |
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) |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.