Package org.apache.paimon.operation

Interface Summary

Interface	Description
BucketSelectConverter	Bucket filter push down in scan to skip files.
BundleFileStoreWriter	Whether the writer could write bundle.
FileStoreCommit	Commit operation which provides commit and overwrite.
FileStoreScan	Scan operation which produces a plan.
FileStoreScan.Plan	Result plan of this scan.
FileStoreWrite<T>	Write operation which provides RecordWriter creation and writes SinkRecord to FileStore.
Lock	An interface that allows file store to use global lock to some transaction-related things.
Lock.Factory	A factory to create Lock.
OrphanFilesClean.ReaderWithIOException<T>	A helper functional interface for method OrphanFilesClean.retryReadingFiles(org.apache.paimon.operation.OrphanFilesClean.ReaderWithIOException<T>, T).
SplitRead<T>	Read operation which provides RecordReader creation.

Class Summary

Class	Description
AbstractFileStoreScan	Default implementation of FileStoreScan.
AbstractFileStoreWrite<T>	Base FileStoreWrite implementation.
AbstractFileStoreWrite.WriterContainer<T>	RecordWriter with the snapshot id it is created upon and the identifier of its last modified commit.
AppendOnlyFileStoreScan	FileStoreScan for AppendOnlyFileStore.
AppendOnlyFileStoreWrite	FileStoreWrite for AppendOnlyFileStore.
AppendOnlyFixedBucketFileStoreWrite	AppendOnlyFileStoreWrite for BucketMode.HASH_FIXED.
AppendOnlyUnawareBucketFileStoreWrite	AppendOnlyFileStoreWrite for BucketMode.BUCKET_UNAWARE.
BucketSelectConverter.Selector	Selector to select bucket from Predicate.
ChangelogDeletion	Delete changelog files.
DefaultValueAssigner	The field Default value assigner.
FileDeletionBase<T extends Snapshot>	Base class for file deletion including methods for clean data files, manifest files and empty data directories.
FileStoreCommitImpl	Default implementation of FileStoreCommit.
FileStoreWrite.State<T>	Recoverable state of FileStoreWrite.
KeyValueFileStoreScan	FileStoreScan for KeyValueFileStore.
KeyValueFileStoreWrite	FileStoreWrite for KeyValueFileStore.
LocalOrphanFilesClean	Local OrphanFilesClean, it will use thread pool to execute deletion.
Lock.CatalogLockImpl	A Lock to wrap CatalogLock.
Lock.EmptyFactory	A Lock.Factory creating empty lock.
Lock.EmptyLock	An empty lock.
Lock.LockFactory	A Lock.Factory creating lock from catalog.
ManifestFileMerger	Util for merging manifest files.
ManifestsReader	A util class to read manifest files.
ManifestsReader.Result	Result for reading manifest files.
MemoryFileStoreWrite<T>	Base FileStoreWrite implementation which supports using shared memory and preempting memory from other writers.
MergeFileSplitRead	An implementation for KeyValueFileStore, this class handle LSM merging and changelog row kind things, it will force reading fields such as sequence and row_kind.
OrphanFilesClean	To remove the data files and metadata files that are not used by table (so-called "orphan files").
PartitionExpire	Expire partitions.
RawFileSplitRead	A SplitRead to read raw file directly from DataSplit.
ReverseReader	A RecordReader which reverses the RowKind of the KeyValue from RowKind.INSERT to RowKind.DELETE read from the wrapped reader.
SnapshotDeletion	Delete snapshot files.
TagDeletion	Delete tag files.