org.apache.paimon.manifest

Interface FileEntry

All Known Implementing Classes:

FilteredManifestEntry, ManifestEntry, SimpleFileEntry

public interface FileEntry

Entry representing a file.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	FileEntry.Identifier The same FileEntry.Identifier indicates that the ManifestEntry refers to the same data file.

Method Summary

Modifier and Type	Method and Description
static Filter<InternalRow>	addFilter()
int	bucket()
static Filter<InternalRow>	deletedFilter()
String	fileName()
FileEntry.Identifier	identifier()
FileKind	kind()
int	level()
BinaryRow	maxKey()
static <T extends FileEntry> Collection<T>	mergeEntries(Iterable<T> entries)
static <T extends FileEntry> void	mergeEntries(Iterable<T> entries, Map<FileEntry.Identifier,T> map)
static void	mergeEntries(ManifestFile manifestFile, List<ManifestFileMeta> manifestFiles, Map<FileEntry.Identifier,ManifestEntry> map, Integer manifestReadParallelism)
BinaryRow	minKey()
BinaryRow	partition()
static <T extends FileEntry> Set<FileEntry.Identifier>	readDeletedEntries(java.util.function.Function<ManifestFileMeta,List<T>> manifestReader, List<ManifestFileMeta> manifestFiles, Integer manifestReadParallelism)
static Set<FileEntry.Identifier>	readDeletedEntries(ManifestFile manifestFile, List<ManifestFileMeta> manifestFiles, Integer manifestReadParallelism)
static Iterable<ManifestEntry>	readManifestEntries(ManifestFile manifestFile, List<ManifestFileMeta> manifestFiles, Integer manifestReadParallelism)

Method Detail

kind

FileKind kind()

partition

BinaryRow partition()

bucket

int bucket()

level

int level()

fileName

String fileName()

identifier

FileEntry.Identifier identifier()

minKey

BinaryRow minKey()

maxKey

BinaryRow maxKey()

mergeEntries

static <T extends FileEntry> Collection<T> mergeEntries(Iterable<T> entries)

mergeEntries

static void mergeEntries(ManifestFile manifestFile,
                         List<ManifestFileMeta> manifestFiles,
                         Map<FileEntry.Identifier,ManifestEntry> map,
                         @Nullable
                         Integer manifestReadParallelism)

mergeEntries

static <T extends FileEntry> void mergeEntries(Iterable<T> entries,
                                               Map<FileEntry.Identifier,T> map)

readManifestEntries

static Iterable<ManifestEntry> readManifestEntries(ManifestFile manifestFile,
                                                   List<ManifestFileMeta> manifestFiles,
                                                   @Nullable
                                                   Integer manifestReadParallelism)

readDeletedEntries

static Set<FileEntry.Identifier> readDeletedEntries(ManifestFile manifestFile,
                                                    List<ManifestFileMeta> manifestFiles,
                                                    @Nullable
                                                    Integer manifestReadParallelism)

readDeletedEntries

static <T extends FileEntry> Set<FileEntry.Identifier> readDeletedEntries(java.util.function.Function<ManifestFileMeta,List<T>> manifestReader,
                                                                          List<ManifestFileMeta> manifestFiles,
                                                                          @Nullable
                                                                          Integer manifestReadParallelism)

deletedFilter

static Filter<InternalRow> deletedFilter()

addFilter

static Filter<InternalRow> addFilter()