Modifier and Type | Class and Description |
---|---|
class |
AppendOnlyCompactManager
Compact manager for
AppendOnlyFileStore . |
Constructor and Description |
---|
AppendOnlyWriter(long schemaId,
FileFormat fileFormat,
long targetFileSize,
org.apache.flink.table.types.logical.RowType writeSchema,
long maxSequenceNumber,
CompactManager compactManager,
boolean forceCompact,
DataFilePathFactory pathFactory) |
Modifier and Type | Class and Description |
---|---|
class |
CompactFutureManager
Base implementation of
CompactManager which runs compaction in a separate thread. |
class |
NoopCompactManager
A
CompactManager which never compacts. |
Constructor and Description |
---|
MergeTreeWriter(boolean writeBufferSpillable,
int sortMaxFan,
org.apache.flink.runtime.io.disk.iomanager.IOManager ioManager,
CompactManager compactManager,
long maxSequenceNumber,
Comparator<org.apache.flink.table.data.RowData> keyComparator,
MergeFunction<KeyValue> mergeFunction,
KeyValueFileWriterFactory writerFactory,
boolean commitForceCompact,
CoreOptions.ChangelogProducer changelogProducer) |
Modifier and Type | Class and Description |
---|---|
class |
MergeTreeCompactManager
Compact manager for
KeyValueFileStore . |
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.