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.OneInputStreamOperatorFactory<ManifestEntry,Committable>	RewriteFileIndexSink.createWriteOperatorFactory(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 ExpireFileEntry	ExpireFileEntry.from(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	AddPartitionCommitCallback.call(List<ManifestEntry> committedEntries, Snapshot snapshot)
void	TagPreviewCommitCallback.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	KeyValueFileStoreScan.dropStats(ManifestEntry entry)
protected ManifestEntry	AbstractFileStoreScan.dropStats(ManifestEntry entry)

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

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.
protected List<ManifestEntry>	KeyValueFileStoreScan.filterWholeBucketByStats(List<ManifestEntry> entries)
protected List<ManifestEntry>	AbstractFileStoreScan.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.

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

Modifier and Type	Method and Description
protected ManifestEntry	KeyValueFileStoreScan.dropStats(ManifestEntry entry)
protected ManifestEntry	AbstractFileStoreScan.dropStats(ManifestEntry entry)
protected boolean	KeyValueFileStoreScan.filterByStats(ManifestEntry entry) Note: Keep this thread-safe.
protected boolean	AppendOnlyFileStoreScan.filterByStats(ManifestEntry entry) Note: Keep this thread-safe.
protected abstract boolean	AbstractFileStoreScan.filterByStats(ManifestEntry entry) Note: Keep this thread-safe.

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

Modifier and Type	Method and Description
protected List<ManifestEntry>	KeyValueFileStoreScan.filterWholeBucketByStats(List<ManifestEntry> entries)
protected List<ManifestEntry>	AbstractFileStoreScan.filterWholeBucketByStats(List<ManifestEntry> entries)
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
default SimpleFileReader<ManifestEntry>	ReadonlyTable.manifestFileReader()
SimpleFileReader<ManifestEntry>	DelegatedFileStoreTable.manifestFileReader()
SimpleFileReader<ManifestEntry>	Table.manifestFileReader() Reader to read manifest entry from manifest file.
default SimpleFileReader<ManifestEntry>	FormatTable.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>	ReadOptimizedTable.manifestFileReader()
SimpleFileReader<ManifestEntry>	FileMonitorTable.manifestFileReader()
SimpleFileReader<ManifestEntry>	CompactBucketsTable.manifestFileReader()
SimpleFileReader<ManifestEntry>	AuditLogTable.manifestFileReader()