Package | Description |
---|---|
org.apache.paimon.io | |
org.apache.paimon.manifest |
Modifier and Type | Method and Description |
---|---|
Optional<FileSource> |
DataFileMeta.fileSource() |
Modifier and Type | Method and Description |
---|---|
RollingFileWriter<KeyValue,DataFileMeta> |
KeyValueFileWriterFactory.createRollingMergeTreeFileWriter(int level,
FileSource fileSource) |
static DataFileMeta |
DataFileMeta.forAppend(String fileName,
long fileSize,
long rowCount,
SimpleStats rowStats,
long minSequenceNumber,
long maxSequenceNumber,
long schemaId,
FileSource fileSource) |
static DataFileMeta |
DataFileMeta.forAppend(String fileName,
long fileSize,
long rowCount,
SimpleStats rowStats,
long minSequenceNumber,
long maxSequenceNumber,
long schemaId,
List<String> extraFiles,
byte[] embeddedIndex,
FileSource fileSource) |
Constructor and Description |
---|
DataFileMeta(String fileName,
long fileSize,
long rowCount,
BinaryRow minKey,
BinaryRow maxKey,
SimpleStats keyStats,
SimpleStats valueStats,
long minSequenceNumber,
long maxSequenceNumber,
long schemaId,
int level,
List<String> extraFiles,
Timestamp creationTime,
Long deleteRowCount,
byte[] embeddedIndex,
FileSource fileSource) |
DataFileMeta(String fileName,
long fileSize,
long rowCount,
BinaryRow minKey,
BinaryRow maxKey,
SimpleStats keyStats,
SimpleStats valueStats,
long minSequenceNumber,
long maxSequenceNumber,
long schemaId,
int level,
Long deleteRowCount,
byte[] embeddedIndex,
FileSource fileSource) |
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) |
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) |
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) |
Modifier and Type | Method and Description |
---|---|
static FileSource |
FileSource.fromByteValue(byte value) |
static FileSource |
FileSource.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static FileSource[] |
FileSource.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.