public class PlanImpl extends Object implements SnapshotReader.Plan
SnapshotReader.Plan
.Constructor and Description |
---|
PlanImpl(Long watermark,
Long snapshotId,
List<Split> splits) |
Modifier and Type | Method and Description |
---|---|
Long |
snapshotId()
Snapshot id of this plan, return null if the table is empty or the manifest list is
specified.
|
List<Split> |
splits()
Result splits.
|
Long |
watermark() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
dataSplits
@Nullable public Long watermark()
watermark
in interface SnapshotReader.Plan
@Nullable public Long snapshotId()
SnapshotReader.Plan
snapshotId
in interface SnapshotReader.Plan
public List<Split> splits()
SnapshotReader.Plan
splits
in interface SnapshotReader.Plan
splits
in interface TableScan.Plan
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.