Uses of Class
org.apache.paimon.utils.ChangelogManager

Packages that use ChangelogManager

Package	Description
org.apache.paimon
org.apache.paimon.flink.lookup
org.apache.paimon.privilege
org.apache.paimon.table
org.apache.paimon.table.source
org.apache.paimon.table.source.snapshot
org.apache.paimon.table.system
org.apache.paimon.utils

Uses of ChangelogManager in org.apache.paimon

Methods in org.apache.paimon that return ChangelogManager

Modifier and Type	Method and Description
ChangelogManager	FileStore.changelogManager()

Uses of ChangelogManager in org.apache.paimon.flink.lookup

Constructors in org.apache.paimon.flink.lookup with parameters of type ChangelogManager

Constructor and Description
LookupDataTableScan(CoreOptions options, SnapshotReader snapshotReader, SnapshotManager snapshotManager, ChangelogManager changelogManager, boolean supportStreamingReadOverwrite, DefaultValueAssigner defaultValueAssigner, LookupFileStoreTable.LookupStreamScanMode lookupScanMode)

Uses of ChangelogManager in org.apache.paimon.privilege

Methods in org.apache.paimon.privilege that return ChangelogManager

Modifier and Type	Method and Description
ChangelogManager	PrivilegedFileStore.changelogManager()
ChangelogManager	PrivilegedFileStoreTable.changelogManager()

Uses of ChangelogManager in org.apache.paimon.table

Methods in org.apache.paimon.table that return ChangelogManager

Modifier and Type	Method and Description
ChangelogManager	DelegatedFileStoreTable.changelogManager()
ChangelogManager	DataTable.changelogManager()

Constructors in org.apache.paimon.table with parameters of type ChangelogManager

Constructor and Description
ExpireChangelogImpl(SnapshotManager snapshotManager, ChangelogManager changelogManager, TagManager tagManager, ChangelogDeletion changelogDeletion)
ExpireSnapshotsImpl(SnapshotManager snapshotManager, ChangelogManager changelogManager, SnapshotDeletion snapshotDeletion, TagManager tagManager)
RollbackHelper(SnapshotManager snapshotManager, ChangelogManager changelogManager, TagManager tagManager, FileIO fileIO, SnapshotDeletion snapshotDeletion, ChangelogDeletion changelogDeletion, TagDeletion tagDeletion)

Uses of ChangelogManager in org.apache.paimon.table.source

Constructors in org.apache.paimon.table.source with parameters of type ChangelogManager

Constructor and Description
DataTableStreamScan(CoreOptions options, SnapshotReader snapshotReader, SnapshotManager snapshotManager, ChangelogManager changelogManager, boolean supportStreamingReadOverwrite, DefaultValueAssigner defaultValueAssigner)

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

Methods in org.apache.paimon.table.source.snapshot that return ChangelogManager

Modifier and Type	Method and Description
ChangelogManager	SnapshotReaderImpl.changelogManager()
ChangelogManager	SnapshotReader.changelogManager()

Methods in org.apache.paimon.table.source.snapshot with parameters of type ChangelogManager

Modifier and Type	Method and Description
static Long	TimeTravelUtil.earlierThanTimeMills(SnapshotManager snapshotManager, ChangelogManager changelogManager, long timestampMills, boolean startFromChangelog) Returns the latest snapshot earlier than the timestamp mills.

Constructors in org.apache.paimon.table.source.snapshot with parameters of type ChangelogManager

Constructor and Description
ContinuousFromSnapshotStartingScanner(SnapshotManager snapshotManager, ChangelogManager changelogManager, long snapshotId, boolean changelogDecoupled)
ContinuousFromTimestampStartingScanner(SnapshotManager snapshotManager, ChangelogManager changelogManager, long startupMillis, boolean changelogDecoupled)
SnapshotReaderImpl(FileStoreScan scan, TableSchema tableSchema, CoreOptions options, SnapshotManager snapshotManager, ChangelogManager changelogManager, SplitGenerator splitGenerator, java.util.function.BiConsumer<FileStoreScan,Predicate> nonPartitionFilterConsumer, DefaultValueAssigner defaultValueAssigner, FileStorePathFactory pathFactory, String tableName, IndexFileHandler indexFileHandler)

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

Methods in org.apache.paimon.table.system that return ChangelogManager

Modifier and Type	Method and Description
ChangelogManager	FileMonitorTable.changelogManager()
ChangelogManager	AuditLogTable.changelogManager()
ChangelogManager	ReadOptimizedTable.changelogManager()
ChangelogManager	CompactBucketsTable.changelogManager()

Uses of ChangelogManager in org.apache.paimon.utils

Constructors in org.apache.paimon.utils with parameters of type ChangelogManager

Constructor and Description
NextSnapshotFetcher(SnapshotManager snapshotManager, ChangelogManager changelogManager, boolean changelogDecoupled)