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.catalog
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.postpone
org.apache.paimon.privilege
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
AbstractFileStoreWrite Base FileStoreWrite implementation.
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.
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.catalog

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.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
CleanOrphanFilesResult The result of OrphanFilesClean.
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.
CleanOrphanFilesResult The result of OrphanFilesClean.
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.
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").
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.postpone

Class and Description
AbstractFileStoreWrite Base FileStoreWrite implementation.
AbstractFileStoreWrite.WriterContainer RecordWriter with the snapshot id it is created upon and the identifier of its last modified commit.
FileStoreScan Scan operation which produces a plan.
FileStoreWrite Write operation which provides RecordWriter creation and writes SinkRecord to FileStore.

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.table

Class and Description
ChangelogDeletion Delete changelog files.
FileStoreScan Scan operation which produces a plan.
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.
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.