| Package | Description |
|---|---|
| org.apache.paimon.flink.source | |
| org.apache.paimon.table.source | |
| org.apache.paimon.table.source.snapshot |
| Modifier and Type | Method and Description |
|---|---|
TableScan.Plan |
ContinuousFileSplitEnumerator.PlanWithNextSnapshotId.plan() |
| Modifier and Type | Method and Description |
|---|---|
List<FileStoreSourceSplit> |
FileStoreSourceSplitGenerator.createSplits(TableScan.Plan plan) |
| Constructor and Description |
|---|
PlanWithNextSnapshotId(TableScan.Plan plan,
Long nextSnapshotId) |
| Modifier and Type | Class and Description |
|---|---|
class |
DataFilePlan
Scanning plan containing snapshot ID and input splits.
|
class |
PlanImpl
An implementation of
SnapshotReader.Plan. |
class |
SnapshotNotExistPlan
This is used to distinguish the case where the snapshot does not exist and the plan is empty.
|
| Modifier and Type | Method and Description |
|---|---|
static TableScan.Plan |
DataFilePlan.fromResult(StartingScanner.Result result) |
protected abstract TableScan.Plan |
ReadOnceTableScan.innerPlan() |
TableScan.Plan |
TableScan.plan()
Plan splits, throws
EndOfScanException if the scan is ended. |
TableScan.Plan |
DataTableStreamScan.plan() |
TableScan.Plan |
DataTableBatchScan.plan() |
TableScan.Plan |
ReadOnceTableScan.plan() |
| Modifier and Type | Method and Description |
|---|---|
default RecordReader<InternalRow> |
TableRead.createReader(TableScan.Plan plan) |
| Modifier and Type | Interface and Description |
|---|---|
static interface |
SnapshotReader.Plan
Result plan of this scan.
|
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.