Package | Description |
---|---|
org.apache.paimon.table.source | |
org.apache.paimon.table.source.snapshot |
Modifier and Type | Class and Description |
---|---|
class |
PlanImpl
An implementation of
SnapshotReader.Plan . |
Modifier and Type | Method and Description |
---|---|
default SnapshotReader.Plan |
FollowUpScanner.getOverwriteChangesPlan(Snapshot snapshot,
SnapshotReader snapshotReader) |
SnapshotReader.Plan |
StartingScanner.ScannedResult.plan() |
SnapshotReader.Plan |
SnapshotReader.read()
Get splits plan from snapshot.
|
SnapshotReader.Plan |
SnapshotReaderImpl.read()
Get splits from
FileKind.ADD files. |
SnapshotReader.Plan |
SnapshotReader.readChanges()
Get splits plan from file changes.
|
SnapshotReader.Plan |
SnapshotReaderImpl.readChanges() |
SnapshotReader.Plan |
SnapshotReader.readIncrementalDiff(Snapshot before) |
SnapshotReader.Plan |
SnapshotReaderImpl.readIncrementalDiff(Snapshot before) |
SnapshotReader.Plan |
AllDeltaFollowUpScanner.scan(Snapshot snapshot,
SnapshotReader snapshotReader) |
SnapshotReader.Plan |
DeltaFollowUpScanner.scan(Snapshot snapshot,
SnapshotReader snapshotReader) |
SnapshotReader.Plan |
CompactionChangelogFollowUpScanner.scan(Snapshot snapshot,
SnapshotReader snapshotReader) |
SnapshotReader.Plan |
InputChangelogFollowUpScanner.scan(Snapshot snapshot,
SnapshotReader snapshotReader) |
SnapshotReader.Plan |
FollowUpScanner.scan(Snapshot snapshot,
SnapshotReader snapshotReader) |
Modifier and Type | Method and Description |
---|---|
static StartingScanner.ScannedResult |
StartingScanner.fromPlan(SnapshotReader.Plan plan) |
Constructor and Description |
---|
ScannedResult(SnapshotReader.Plan plan) |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.