public static interface FileStoreScan.Plan
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. |
default Map<org.apache.flink.table.data.binary.BinaryRowData,Map<Integer,List<DataFileMeta>>> |
groupByPartFiles(List<ManifestEntry> files)
Return a map group by partition and bucket.
|
Long |
snapshotId()
Snapshot id of this plan, return null if the table is empty or the manifest list is
specified.
|
@Nullable Long snapshotId()
List<ManifestEntry> files()
ManifestEntry
files.default List<ManifestEntry> files(FileKind kind)
ManifestEntry
files with specific file kind.default Map<org.apache.flink.table.data.binary.BinaryRowData,Map<Integer,List<DataFileMeta>>> groupByPartFiles(List<ManifestEntry> files)
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.