org.apache.paimon.operation

Interface FileStoreScan.Plan

Enclosing interface:

FileStoreScan

public static interface FileStoreScan.Plan

Result plan of this scan.

Method Summary

Modifier and Type	Method and Description
List<ManifestEntry>	files() Result ManifestEntry files.
default List<ManifestEntry>	files(FileKind kind) Result ManifestEntry files with specific file kind.
static Map<BinaryRow,Map<Integer,List<DataFileMeta>>>	groupByPartFiles(List<ManifestEntry> files) Return a map group by partition and bucket.
Snapshot	snapshot() Snapshot of this plan, return null if the table is empty or the manifest list is specified.
Long	watermark()

Method Detail

watermark

@Nullable
Long watermark()

snapshot

@Nullable
Snapshot snapshot()

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

files

List<ManifestEntry> files()

Result ManifestEntry files.

files

default List<ManifestEntry> files(FileKind kind)

Result ManifestEntry files with specific file kind.

groupByPartFiles

static Map<BinaryRow,Map<Integer,List<DataFileMeta>>> groupByPartFiles(List<ManifestEntry> files)

Return a map group by partition and bucket.