Package | Description |
---|---|
org.apache.flink.table.store.file.manifest | |
org.apache.flink.table.store.file.operation |
Modifier and Type | Method and Description |
---|---|
ManifestEntry |
ManifestEntrySerializer.convertFrom(int version,
org.apache.flink.table.data.RowData row) |
Modifier and Type | Method and Description |
---|---|
static Collection<ManifestEntry> |
ManifestEntry.mergeEntries(List<ManifestEntry> entries) |
List<ManifestEntry> |
ManifestFile.read(String fileName) |
Modifier and Type | Method and Description |
---|---|
org.apache.flink.table.data.RowData |
ManifestEntrySerializer.convertTo(ManifestEntry entry) |
Modifier and Type | Method and Description |
---|---|
static void |
ManifestEntry.assertNoDelete(Collection<ManifestEntry> entries) |
static Collection<ManifestEntry> |
ManifestEntry.mergeEntries(List<ManifestEntry> entries) |
static void |
ManifestEntry.mergeEntries(List<ManifestEntry> entries,
Map<ManifestEntry.Identifier,ManifestEntry> map) |
static void |
ManifestEntry.mergeEntries(List<ManifestEntry> entries,
Map<ManifestEntry.Identifier,ManifestEntry> map) |
List<ManifestFileMeta> |
ManifestFile.write(List<ManifestEntry> entries)
Write several
ManifestEntry s into manifest files. |
Modifier and Type | Method and Description |
---|---|
List<ManifestEntry> |
FileStoreScan.Plan.files()
Result
ManifestEntry files. |
default List<ManifestEntry> |
FileStoreScan.Plan.files(FileKind kind)
Result
ManifestEntry files with specific file kind. |
Modifier and Type | Method and Description |
---|---|
protected boolean |
KeyValueFileStoreScan.filterByStats(ManifestEntry entry)
Note: Keep this thread-safe.
|
protected abstract boolean |
AbstractFileStoreScan.filterByStats(ManifestEntry entry)
Note: Keep this thread-safe.
|
protected boolean |
AppendOnlyFileStoreScan.filterByStats(ManifestEntry entry)
Note: Keep this thread-safe.
|
Modifier and Type | Method and Description |
---|---|
default Map<org.apache.flink.table.data.binary.BinaryRowData,Map<Integer,List<DataFileMeta>>> |
FileStoreScan.Plan.groupByPartFiles(List<ManifestEntry> files)
Return a map group by partition and bucket.
|
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.