Package org.apache.paimon.operation

Interface Summary

Interface	Description
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.
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.
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.
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.
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.
ScanBucketFilter	Bucket filter push down in scan to skip files.
ScanBucketFilter.ScanBucketSelector	Selector to select bucket from Predicate.
SnapshotDeletion	Delete snapshot files.
TagDeletion	Delete tag files.