Package | Description |
---|---|
org.apache.flink.table.store.file.append | |
org.apache.flink.table.store.file.io | |
org.apache.flink.table.store.file.utils |
Constructor and Description |
---|
AppendOnlyCompactManager(ExecutorService executor,
LinkedList<DataFileMeta> toCompact,
int minFileNum,
int maxFileNum,
long targetFileSize,
AppendOnlyCompactManager.CompactRewriter rewriter,
DataFilePathFactory pathFactory) |
AppendOnlyWriter(long schemaId,
FileFormat fileFormat,
long targetFileSize,
org.apache.flink.table.types.logical.RowType writeSchema,
long maxSequenceNumber,
CompactManager compactManager,
boolean forceCompact,
DataFilePathFactory pathFactory) |
IterativeCompactTask(List<DataFileMeta> inputs,
long targetFileSize,
int minFileNum,
int maxFileNum,
AppendOnlyCompactManager.CompactRewriter rewriter,
DataFilePathFactory factory) |
Modifier and Type | Method and Description |
---|---|
DataFilePathFactory |
KeyValueFileWriterFactory.pathFactory() |
Constructor and Description |
---|
RowDataRollingFileWriter(long schemaId,
FileFormat fileFormat,
long targetFileSize,
org.apache.flink.table.types.logical.RowType writeSchema,
DataFilePathFactory pathFactory,
org.apache.flink.api.common.accumulators.LongCounter seqNumCounter) |
Modifier and Type | Method and Description |
---|---|
DataFilePathFactory |
FileStorePathFactory.createDataFilePathFactory(org.apache.flink.table.data.binary.BinaryRowData partition,
int bucket) |
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.