Uses of Class
org.apache.paimon.manifest.ManifestEntry

Packages that use ManifestEntry

Package	Description
org.apache.paimon.flink.sink
org.apache.paimon.flink.source
org.apache.paimon.iceberg
org.apache.paimon.manifest
org.apache.paimon.metastore
org.apache.paimon.operation
org.apache.paimon.operation.metrics
org.apache.paimon.table
org.apache.paimon.table.sink
org.apache.paimon.table.source.snapshot
org.apache.paimon.table.system

Uses of ManifestEntry in org.apache.paimon.flink.sink

Methods in org.apache.paimon.flink.sink that return types with arguments of type ManifestEntry

Modifier and Type	Method and Description
protected org.apache.flink.streaming.api.operators.OneInputStreamOperator<ManifestEntry,Committable>	RewriteFileIndexSink.createWriteOperator(StoreSinkWrite.Provider writeProvider, String commitUser)

Uses of ManifestEntry in org.apache.paimon.flink.source

Methods in org.apache.paimon.flink.source that return types with arguments of type ManifestEntry

Modifier and Type	Method and Description
org.apache.flink.api.connector.source.SourceReader<ManifestEntry,RewriteFileIndexSource.Split>	RewriteFileIndexSource.createReader(org.apache.flink.api.connector.source.SourceReaderContext sourceReaderContext)

Constructors in org.apache.paimon.flink.source with parameters of type ManifestEntry

Constructor and Description
Split(ManifestEntry manifestEntry)

Uses of ManifestEntry in org.apache.paimon.iceberg

Method parameters in org.apache.paimon.iceberg with type arguments of type ManifestEntry

Modifier and Type	Method and Description
void	AbstractIcebergCommitCallback.call(List<ManifestEntry> committedEntries, Snapshot snapshot)

Uses of ManifestEntry in org.apache.paimon.manifest

Subclasses of ManifestEntry in org.apache.paimon.manifest

Modifier and Type	Class and Description
class	FilteredManifestEntry Wrap a ManifestEntry to contain FilteredManifestEntry.selected.

Methods in org.apache.paimon.manifest that return ManifestEntry

Modifier and Type	Method and Description
ManifestEntry	ManifestEntrySerializer.convertFrom(int version, InternalRow row)
ManifestEntry	ManifestEntry.copyWithoutStats()
ManifestEntry	ManifestEntry.fromBytes(byte[] bytes)

Methods in org.apache.paimon.manifest that return types with arguments of type ManifestEntry

Modifier and Type	Method and Description
RollingFileWriter<ManifestEntry,ManifestFileMeta>	ManifestFile.createRollingWriter()
static Iterable<ManifestEntry>	FileEntry.readManifestEntries(ManifestFile manifestFile, List<ManifestFileMeta> manifestFiles, Integer manifestReadParallelism)

Methods in org.apache.paimon.manifest with parameters of type ManifestEntry

Modifier and Type	Method and Description
InternalRow	ManifestEntrySerializer.convertTo(ManifestEntry entry)
static SimpleFileEntry	SimpleFileEntry.from(ManifestEntry entry)
static PartitionEntry	PartitionEntry.fromManifestEntry(ManifestEntry entry)
static BucketEntry	BucketEntry.fromManifestEntry(ManifestEntry entry)

Method parameters in org.apache.paimon.manifest with type arguments of type ManifestEntry

Modifier and Type	Method and Description
static List<SimpleFileEntry>	SimpleFileEntry.from(List<ManifestEntry> entries)
static Collection<PartitionEntry>	PartitionEntry.merge(Collection<ManifestEntry> fileEntries)
static Collection<BucketEntry>	BucketEntry.merge(Collection<ManifestEntry> fileEntries)
static void	FileEntry.mergeEntries(ManifestFile manifestFile, List<ManifestFileMeta> manifestFiles, Map<FileEntry.Identifier,ManifestEntry> map, Integer manifestReadParallelism)
static long	ManifestEntry.recordCount(List<ManifestEntry> manifestEntries)
static long	ManifestEntry.recordCountAdd(List<ManifestEntry> manifestEntries)
static long	ManifestEntry.recordCountDelete(List<ManifestEntry> manifestEntries)
List<ManifestFileMeta>	ManifestFile.write(List<ManifestEntry> entries) Write several ManifestEntrys into manifest files.

Constructors in org.apache.paimon.manifest with parameters of type ManifestEntry

Constructor and Description
FilteredManifestEntry(ManifestEntry entry, boolean selected)

Uses of ManifestEntry in org.apache.paimon.metastore

Method parameters in org.apache.paimon.metastore with type arguments of type ManifestEntry

Modifier and Type	Method and Description
void	TagPreviewCommitCallback.call(List<ManifestEntry> committedEntries, Snapshot snapshot)
void	AddPartitionCommitCallback.call(List<ManifestEntry> committedEntries, Snapshot snapshot)

Uses of ManifestEntry in org.apache.paimon.operation

Methods in org.apache.paimon.operation that return ManifestEntry

Modifier and Type	Method and Description
protected ManifestEntry	AbstractFileStoreScan.dropStats(ManifestEntry entry)
protected ManifestEntry	KeyValueFileStoreScan.dropStats(ManifestEntry entry)

Methods in org.apache.paimon.operation that return types with arguments of type ManifestEntry

Modifier and Type	Method and Description
java.util.function.Predicate<ManifestEntry>	FileDeletionBase.createDataFileSkipperForTags(List<Snapshot> taggedSnapshots, long expiringSnapshotId)
java.util.function.Predicate<ManifestEntry>	TagDeletion.dataFileSkipper(List<Snapshot> fromSnapshots)
java.util.function.Predicate<ManifestEntry>	TagDeletion.dataFileSkipper(Snapshot fromSnapshot)
List<ManifestEntry>	FileStoreScan.Plan.files() Result ManifestEntry files.
default List<ManifestEntry>	FileStoreScan.Plan.files(FileKind kind) Result ManifestEntry files with specific file kind.
protected List<ManifestEntry>	AbstractFileStoreScan.filterWholeBucketByStats(List<ManifestEntry> entries)
protected List<ManifestEntry>	KeyValueFileStoreScan.filterWholeBucketByStats(List<ManifestEntry> entries)
Iterator<ManifestEntry>	FileStoreScan.readFileIterator()
Iterator<ManifestEntry>	AbstractFileStoreScan.readFileIterator()
List<ManifestEntry>	FileStoreScan.readManifest(ManifestFileMeta manifest)
List<ManifestEntry>	AbstractFileStoreScan.readManifest(ManifestFileMeta manifest) Note: Keep this thread-safe.
protected Collection<ManifestEntry>	FileDeletionBase.readMergedDataFiles(Snapshot snapshot)

Methods in org.apache.paimon.operation with parameters of type ManifestEntry

Modifier and Type	Method and Description
protected boolean	FileDeletionBase.containsDataFile(Map<BinaryRow,Map<Integer,Set<String>>> dataFiles, ManifestEntry testee)
protected ManifestEntry	AbstractFileStoreScan.dropStats(ManifestEntry entry)
protected ManifestEntry	KeyValueFileStoreScan.dropStats(ManifestEntry entry)
protected abstract boolean	AbstractFileStoreScan.filterByStats(ManifestEntry entry) Note: Keep this thread-safe.
protected boolean	KeyValueFileStoreScan.filterByStats(ManifestEntry entry) Note: Keep this thread-safe.
protected boolean	AppendOnlyFileStoreScan.filterByStats(ManifestEntry entry) Note: Keep this thread-safe.
protected void	FileDeletionBase.recordDeletionBuckets(ManifestEntry entry)

Method parameters in org.apache.paimon.operation with type arguments of type ManifestEntry

Modifier and Type	Method and Description
void	ChangelogDeletion.cleanUnusedDataFiles(Changelog changelog, java.util.function.Predicate<ManifestEntry> skipper)
void	SnapshotDeletion.cleanUnusedDataFiles(Snapshot snapshot, java.util.function.Predicate<ManifestEntry> skipper)
void	TagDeletion.cleanUnusedDataFiles(Snapshot taggedSnapshot, java.util.function.Predicate<ManifestEntry> skipper)
void	FileDeletionBase.cleanUnusedDataFiles(String manifestList, java.util.function.Predicate<ManifestEntry> skipper)
abstract void	FileDeletionBase.cleanUnusedDataFiles(T snapshot, java.util.function.Predicate<ManifestEntry> skipper) Clean data files that will not be used anymore in the snapshot.
protected void	FileDeletionBase.doCleanUnusedDataFile(Map<Path,Pair<ManifestEntry,List<Path>>> dataFileToDelete, java.util.function.Predicate<ManifestEntry> skipper)
protected void	FileDeletionBase.doCleanUnusedDataFile(Map<Path,Pair<ManifestEntry,List<Path>>> dataFileToDelete, java.util.function.Predicate<ManifestEntry> skipper)
protected List<ManifestEntry>	AbstractFileStoreScan.filterWholeBucketByStats(List<ManifestEntry> entries)
protected List<ManifestEntry>	KeyValueFileStoreScan.filterWholeBucketByStats(List<ManifestEntry> entries)
protected void	FileDeletionBase.getDataFileToDelete(Map<Path,Pair<ManifestEntry,List<Path>>> dataFileToDelete, List<ManifestEntry> dataFileEntries)
protected void	FileDeletionBase.getDataFileToDelete(Map<Path,Pair<ManifestEntry,List<Path>>> dataFileToDelete, List<ManifestEntry> dataFileEntries)
static Map<BinaryRow,Map<Integer,List<DataFileMeta>>>	FileStoreScan.Plan.groupByPartFiles(List<ManifestEntry> files) Return a map group by partition and bucket.
FileStoreScan	FileStoreScan.withManifestEntryFilter(Filter<ManifestEntry> filter)
FileStoreScan	AbstractFileStoreScan.withManifestEntryFilter(Filter<ManifestEntry> filter)

Uses of ManifestEntry in org.apache.paimon.operation.metrics

Constructor parameters in org.apache.paimon.operation.metrics with type arguments of type ManifestEntry

Constructor and Description
CommitStats(List<ManifestEntry> appendTableFiles, List<ManifestEntry> appendChangelogFiles, List<ManifestEntry> compactTableFiles, List<ManifestEntry> compactChangelogFiles, long commitDuration, int generatedSnapshots, int attempts)
CommitStats(List<ManifestEntry> appendTableFiles, List<ManifestEntry> appendChangelogFiles, List<ManifestEntry> compactTableFiles, List<ManifestEntry> compactChangelogFiles, long commitDuration, int generatedSnapshots, int attempts)
CommitStats(List<ManifestEntry> appendTableFiles, List<ManifestEntry> appendChangelogFiles, List<ManifestEntry> compactTableFiles, List<ManifestEntry> compactChangelogFiles, long commitDuration, int generatedSnapshots, int attempts)
CommitStats(List<ManifestEntry> appendTableFiles, List<ManifestEntry> appendChangelogFiles, List<ManifestEntry> compactTableFiles, List<ManifestEntry> compactChangelogFiles, long commitDuration, int generatedSnapshots, int attempts)

Uses of ManifestEntry in org.apache.paimon.table

Methods in org.apache.paimon.table that return types with arguments of type ManifestEntry

Modifier and Type	Method and Description
SimpleFileReader<ManifestEntry>	Table.manifestFileReader() Reader to read manifest entry from manifest file.
default SimpleFileReader<ManifestEntry>	FormatTable.manifestFileReader()
default SimpleFileReader<ManifestEntry>	ReadonlyTable.manifestFileReader()
SimpleFileReader<ManifestEntry>	DelegatedFileStoreTable.manifestFileReader()

Uses of ManifestEntry in org.apache.paimon.table.sink

Method parameters in org.apache.paimon.table.sink with type arguments of type ManifestEntry

Modifier and Type	Method and Description
void	CommitCallback.call(List<ManifestEntry> committedEntries, Snapshot snapshot)

Uses of ManifestEntry in org.apache.paimon.table.source.snapshot

Methods in org.apache.paimon.table.source.snapshot that return types with arguments of type ManifestEntry

Modifier and Type	Method and Description
Iterator<ManifestEntry>	SnapshotReader.readFileIterator()
Iterator<ManifestEntry>	SnapshotReaderImpl.readFileIterator()
List<ManifestEntry>	SnapshotReader.readManifest(ManifestFileMeta manifest)
List<ManifestEntry>	SnapshotReaderImpl.readManifest(ManifestFileMeta manifest)

Method parameters in org.apache.paimon.table.source.snapshot with type arguments of type ManifestEntry

Modifier and Type	Method and Description
SnapshotReader	SnapshotReader.withManifestEntryFilter(Filter<ManifestEntry> filter)
SnapshotReader	SnapshotReaderImpl.withManifestEntryFilter(Filter<ManifestEntry> filter)

Uses of ManifestEntry in org.apache.paimon.table.system

Methods in org.apache.paimon.table.system that return types with arguments of type ManifestEntry

Modifier and Type	Method and Description
SimpleFileReader<ManifestEntry>	FileMonitorTable.manifestFileReader()
SimpleFileReader<ManifestEntry>	CompactBucketsTable.manifestFileReader()
SimpleFileReader<ManifestEntry>	AuditLogTable.manifestFileReader()
SimpleFileReader<ManifestEntry>	ReadOptimizedTable.manifestFileReader()