Package | Description |
---|---|
org.apache.flink.table.store.file | |
org.apache.flink.table.store.file.manifest | |
org.apache.flink.table.store.file.operation |
Modifier and Type | Method and Description |
---|---|
List<ManifestFileMeta> |
Snapshot.readAllDataManifests(ManifestList manifestList) |
Modifier and Type | Method and Description |
---|---|
ManifestFileMeta |
ManifestFileMetaSerializer.convertFrom(int version,
org.apache.flink.table.data.RowData row) |
Modifier and Type | Method and Description |
---|---|
static List<ManifestFileMeta> |
ManifestFileMeta.merge(List<ManifestFileMeta> metas,
ManifestFile manifestFile,
long suggestedMetaSize,
int suggestedMinMetaCount)
Merge several
ManifestFileMeta s. |
List<ManifestFileMeta> |
ManifestList.read(String fileName) |
List<ManifestFileMeta> |
ManifestFile.write(List<ManifestEntry> entries)
Write several
ManifestEntry s into manifest files. |
Modifier and Type | Method and Description |
---|---|
org.apache.flink.table.data.RowData |
ManifestFileMetaSerializer.convertTo(ManifestFileMeta meta) |
Modifier and Type | Method and Description |
---|---|
static List<ManifestFileMeta> |
ManifestFileMeta.merge(List<ManifestFileMeta> metas,
ManifestFile manifestFile,
long suggestedMetaSize,
int suggestedMinMetaCount)
Merge several
ManifestFileMeta s. |
String |
ManifestList.write(List<ManifestFileMeta> metas)
Write several
ManifestFileMeta s into a manifest list. |
Modifier and Type | Method and Description |
---|---|
FileStoreScan |
FileStoreScan.withManifestList(List<ManifestFileMeta> manifests) |
FileStoreScan |
AbstractFileStoreScan.withManifestList(List<ManifestFileMeta> manifests) |
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.