Package | Description |
---|---|
org.apache.paimon.flink.lookup | |
org.apache.paimon.table.source | |
org.apache.paimon.table.source.snapshot |
Modifier and Type | Class and Description |
---|---|
class |
CompactionDiffFollowUpScanner
FollowUpScanner for read all changed files after compact. |
Modifier and Type | Method and Description |
---|---|
protected FollowUpScanner |
LookupDataTableScan.createFollowUpScanner() |
Modifier and Type | Method and Description |
---|---|
protected FollowUpScanner |
DataTableStreamScan.createFollowUpScanner() |
Modifier and Type | Class and Description |
---|---|
class |
AllDeltaFollowUpScanner
FollowUpScanner for read all file changes. |
class |
CompactionChangelogFollowUpScanner
FollowUpScanner for CoreOptions.ChangelogProducer#FULL_COMPACTION changelog
producer. |
class |
DeltaFollowUpScanner
FollowUpScanner for CoreOptions.ChangelogProducer#NONE changelog producer. |
class |
InputChangelogFollowUpScanner
FollowUpScanner for CoreOptions.ChangelogProducer#INPUT changelog producer. |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.