Package | Description |
---|---|
org.apache.paimon.table.source | |
org.apache.paimon.table.source.snapshot |
Modifier and Type | Method and Description |
---|---|
static TableScan.Plan |
DataFilePlan.fromResult(StartingScanner.Result result) |
Modifier and Type | Class and Description |
---|---|
static class |
StartingScanner.NextSnapshot
Return the next snapshot for followup scanning.
|
static class |
StartingScanner.NoSnapshot
Currently, there is no snapshot, need to wait for the snapshot to be generated.
|
static class |
StartingScanner.ScannedResult
Result with scanned snapshot.
|
Modifier and Type | Method and Description |
---|---|
StartingScanner.Result |
ContinuousLatestStartingScanner.scan(SnapshotReader snapshotReader) |
StartingScanner.Result |
IncrementalTagStartingScanner.scan(SnapshotReader reader) |
StartingScanner.Result |
ContinuousFromSnapshotStartingScanner.scan(SnapshotReader snapshotReader) |
StartingScanner.Result |
CompactedStartingScanner.scan(SnapshotReader snapshotReader) |
StartingScanner.Result |
StaticFromSnapshotStartingScanner.scan(SnapshotReader snapshotReader) |
StartingScanner.Result |
StartingScanner.scan(SnapshotReader snapshotReader) |
StartingScanner.Result |
ContinuousCompactorStartingScanner.scan(SnapshotReader snapshotReader) |
StartingScanner.Result |
FullStartingScanner.scan(SnapshotReader snapshotReader) |
StartingScanner.Result |
FullCompactedStartingScanner.scan(SnapshotReader snapshotReader) |
StartingScanner.Result |
StaticFromTimestampStartingScanner.scan(SnapshotReader snapshotReader) |
StartingScanner.Result |
StaticFromWatermarkStartingScanner.scan(SnapshotReader snapshotReader) |
StartingScanner.Result |
StaticFromTagStartingScanner.scan(SnapshotReader snapshotReader) |
StartingScanner.Result |
FileCreationTimeStartingScanner.scan(SnapshotReader snapshotReader) |
StartingScanner.Result |
ContinuousFromSnapshotFullStartingScanner.scan(SnapshotReader snapshotReader) |
StartingScanner.Result |
IncrementalTimeStampStartingScanner.scan(SnapshotReader reader) |
StartingScanner.Result |
IncrementalStartingScanner.scan(SnapshotReader reader) |
StartingScanner.Result |
ContinuousFromTimestampStartingScanner.scan(SnapshotReader snapshotReader) |
Modifier and Type | Method and Description |
---|---|
Optional<StartingScanner.Result> |
IncrementalStartingScanner.checkScanSnapshotIdValidity()
Check the validity of staring snapshotId early.
|
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.