Uses of Package
org.apache.paimon.operation

Packages that use org.apache.paimon.operation

Package	Description
org.apache.paimon
org.apache.paimon.append
org.apache.paimon.flink.lookup
org.apache.paimon.flink.orphan
org.apache.paimon.flink.sink
org.apache.paimon.operation
org.apache.paimon.partition
org.apache.paimon.privilege
org.apache.paimon.schema
org.apache.paimon.table
org.apache.paimon.table.sink
org.apache.paimon.table.source
org.apache.paimon.table.source.snapshot
org.apache.paimon.table.source.splitread
org.apache.paimon.tag
org.apache.paimon.utils

Classes in org.apache.paimon.operation used by org.apache.paimon

Class and Description
AppendOnlyFileStoreScan FileStoreScan for AppendOnlyFileStore.
AppendOnlyFileStoreWrite FileStoreWrite for AppendOnlyFileStore.
ChangelogDeletion Delete changelog files.
FileStoreCommit Commit operation which provides commit and overwrite.
FileStoreScan Scan operation which produces a plan.
FileStoreWrite Write operation which provides RecordWriter creation and writes SinkRecord to FileStore.
KeyValueFileStoreScan FileStoreScan for KeyValueFileStore.
KeyValueFileStoreWrite FileStoreWrite for KeyValueFileStore.
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.
PartitionExpire Expire partitions.
RawFileSplitRead A SplitRead to read raw file directly from DataSplit.
SnapshotDeletion Delete snapshot files.
SplitRead Read operation which provides RecordReader creation.
TagDeletion Delete tag files.

Classes in org.apache.paimon.operation used by org.apache.paimon.append

Class and Description
AppendOnlyFileStoreWrite FileStoreWrite for AppendOnlyFileStore.

Classes in org.apache.paimon.operation used by org.apache.paimon.flink.lookup

Class and Description
DefaultValueAssigner The field Default value assigner.
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.
SplitRead Read operation which provides RecordReader creation.

Classes in org.apache.paimon.operation used by org.apache.paimon.flink.orphan

Class and Description
OrphanFilesClean To remove the data files and metadata files that are not used by table (so-called "orphan files").

Classes in org.apache.paimon.operation used by org.apache.paimon.flink.sink

Class and Description
TagDeletion Delete tag files.

Classes in org.apache.paimon.operation used by org.apache.paimon.operation

Class and Description
AbstractFileStoreScan Default implementation of FileStoreScan.
AbstractFileStoreWrite Base FileStoreWrite implementation.
AbstractFileStoreWrite.WriterContainer 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.
BucketSelectConverter Bucket filter push down in scan to skip files.
BundleFileStoreWriter Whether the writer could write bundle.
DefaultValueAssigner The field Default value assigner.
FileDeletionBase Base class for file deletion including methods for clean data files, manifest files and empty data directories.
FileStoreCommit Commit operation which provides commit and overwrite.
FileStoreScan Scan operation which produces a plan.
FileStoreScan.Plan Result plan of this scan.
FileStoreWrite Write operation which provides RecordWriter creation and writes SinkRecord to FileStore.
FileStoreWrite.State Recoverable state of FileStoreWrite.
KeyValueFileStoreScan FileStoreScan for KeyValueFileStore.
LocalOrphanFilesClean Local OrphanFilesClean, it will use thread pool to execute deletion.
Lock An interface that allows file store to use global lock to some transaction-related things.
Lock.Factory A factory to create Lock.
ManifestsReader A util class to read manifest files.
ManifestsReader.Result Result for reading manifest files.
MemoryFileStoreWrite 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").
OrphanFilesClean.ReaderWithIOException A helper functional interface for method OrphanFilesClean.retryReadingFiles(org.apache.paimon.operation.OrphanFilesClean.ReaderWithIOException<T>, T).
PartitionExpire Expire partitions.
RawFileSplitRead A SplitRead to read raw file directly from DataSplit.
SplitRead Read operation which provides RecordReader creation.

Classes in org.apache.paimon.operation used by org.apache.paimon.partition

Class and Description
FileStoreScan Scan operation which produces a plan.

Classes in org.apache.paimon.operation used by org.apache.paimon.privilege

Class and Description
ChangelogDeletion Delete changelog files.
FileStoreCommit Commit operation which provides commit and overwrite.
FileStoreScan Scan operation which produces a plan.
FileStoreWrite Write operation which provides RecordWriter creation and writes SinkRecord to FileStore.
PartitionExpire Expire partitions.
SnapshotDeletion Delete snapshot files.
SplitRead Read operation which provides RecordReader creation.
TagDeletion Delete tag files.

Classes in org.apache.paimon.operation used by org.apache.paimon.schema

Class and Description
Lock An interface that allows file store to use global lock to some transaction-related things.

Classes in org.apache.paimon.operation used by org.apache.paimon.table

Class and Description
ChangelogDeletion Delete changelog files.
Lock.Factory A factory to create Lock.
SnapshotDeletion Delete snapshot files.
TagDeletion Delete tag files.

Classes in org.apache.paimon.operation used by org.apache.paimon.table.sink

Class and Description
FileStoreCommit Commit operation which provides commit and overwrite.
FileStoreWrite Write operation which provides RecordWriter creation and writes SinkRecord to FileStore.
FileStoreWrite.State Recoverable state of FileStoreWrite.
Lock An interface that allows file store to use global lock to some transaction-related things.
PartitionExpire Expire partitions.

Classes in org.apache.paimon.operation used by org.apache.paimon.table.source

Class and Description
DefaultValueAssigner The field Default value assigner.
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.
RawFileSplitRead A SplitRead to read raw file directly from DataSplit.

Classes in org.apache.paimon.operation used by org.apache.paimon.table.source.snapshot

Class and Description
DefaultValueAssigner The field Default value assigner.
FileStoreScan Scan operation which produces a plan.
ManifestsReader A util class to read manifest files.

Classes in org.apache.paimon.operation used by org.apache.paimon.table.source.splitread

Class and Description
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.
RawFileSplitRead A SplitRead to read raw file directly from DataSplit.
SplitRead Read operation which provides RecordReader creation.

Classes in org.apache.paimon.operation used by org.apache.paimon.tag

Class and Description
TagDeletion Delete tag files.

Classes in org.apache.paimon.operation used by org.apache.paimon.utils

Class and Description
TagDeletion Delete tag files.