org.apache.paimon.table.source

Class PlanImpl

java.lang.Object

org.apache.paimon.table.source.PlanImpl

All Implemented Interfaces:

SnapshotReader.Plan, TableScan.Plan

public class PlanImpl
extends Object
implements SnapshotReader.Plan

An implementation of SnapshotReader.Plan.

Constructor Summary

Constructors

Constructor and Description
PlanImpl(Long watermark, Long snapshotId, List<Split> splits)

Method Summary

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()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.paimon.table.source.snapshot.SnapshotReader.Plan

dataSplits

Constructor Detail

PlanImpl

public PlanImpl(Long watermark,
                Long snapshotId,
                List<Split> splits)

Method Detail

watermark

@Nullable
public Long watermark()

Specified by:

watermark in interface SnapshotReader.Plan

snapshotId

@Nullable
public Long snapshotId()

Description copied from interface: SnapshotReader.Plan

Snapshot id of this plan, return null if the table is empty or the manifest list is specified.

Specified by:

snapshotId in interface SnapshotReader.Plan

splits

public List<Split> splits()

Description copied from interface: SnapshotReader.Plan

Result splits.

Specified by:

splits in interface SnapshotReader.Plan

Specified by:

splits in interface TableScan.Plan