Package | Description |
---|---|
org.apache.flink.table.store.table.source.snapshot |
Modifier and Type | Class and Description |
---|---|
class |
CompactionChangelogFollowUpScanner
FollowUpScanner for CoreOptions.ChangelogProducer.FULL_COMPACTION changelog producer. |
class |
ContinuousCompactorFollowUpScanner
FollowUpScanner used internally for stand-alone streaming compact job sources. |
class |
DeltaFollowUpScanner
FollowUpScanner for CoreOptions.ChangelogProducer.NONE changelog producer. |
class |
InputChangelogFollowUpScanner
FollowUpScanner for CoreOptions.ChangelogProducer.INPUT changelog producer. |
Constructor and Description |
---|
ContinuousDataFileSnapshotEnumerator(org.apache.flink.core.fs.Path tablePath,
DataTableScan scan,
StartingScanner startingScanner,
FollowUpScanner followUpScanner,
Long nextSnapshotId) |
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.