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 |
ReadOnceTableScan.plan() |
TableScan.Plan |
DataTableBatchScan.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.