Uses of Interface
org.apache.paimon.utils.Filter

Packages that use Filter

Package	Description
org.apache.paimon.crosspartition
org.apache.paimon.manifest
org.apache.paimon.mergetree.compact
org.apache.paimon.operation
org.apache.paimon.reader
org.apache.paimon.table.source
org.apache.paimon.table.source.snapshot
org.apache.paimon.utils

Uses of Filter in org.apache.paimon.crosspartition

Methods in org.apache.paimon.crosspartition with parameters of type Filter

Modifier and Type	Method and Description
int	BucketAssigner.assignBucket(BinaryRow part, Filter<Integer> filter, int maxCount)

Uses of Filter in org.apache.paimon.manifest

Methods in org.apache.paimon.manifest that return Filter

Modifier and Type	Method and Description
static Filter<InternalRow>	FileEntry.deletedFilter()

Uses of Filter in org.apache.paimon.mergetree.compact

Constructors in org.apache.paimon.mergetree.compact with parameters of type Filter

Constructor and Description
FirstRowMergeFunctionWrapper(MergeFunctionFactory<KeyValue> mergeFunctionFactory, Filter<InternalRow> contains)

Uses of Filter in org.apache.paimon.operation

Methods in org.apache.paimon.operation with parameters of type Filter

Modifier and Type	Method and Description
<T extends FileEntry> Collection<T>	AbstractFileStoreScan.readAndMergeFileEntries(List<ManifestFileMeta> manifests, java.util.function.Function<ManifestFileMeta,List<T>> manifestReader, Filter<T> filterUnmergedEntry)
FileStoreScan	AbstractFileStoreScan.withBucketFilter(Filter<Integer> bucketFilter)
FileStoreScan	FileStoreScan.withBucketFilter(Filter<Integer> bucketFilter)
FileStoreScan	AbstractFileStoreScan.withDataFileNameFilter(Filter<String> fileNameFilter)
FileStoreScan	FileStoreScan.withDataFileNameFilter(Filter<String> fileNameFilter)
FileStoreScan	AbstractFileStoreScan.withLevelFilter(Filter<Integer> levelFilter)
FileStoreScan	FileStoreScan.withLevelFilter(Filter<Integer> levelFilter)
FileStoreScan	AbstractFileStoreScan.withManifestEntryFilter(Filter<ManifestEntry> filter)
FileStoreScan	FileStoreScan.withManifestEntryFilter(Filter<ManifestEntry> filter)

Uses of Filter in org.apache.paimon.reader

Methods in org.apache.paimon.reader with parameters of type Filter

Modifier and Type	Method and Description
default FileRecordIterator<T>	FileRecordIterator.filter(Filter<T> filter)
default RecordReader<T>	RecordReader.filter(Filter<T> filter) Filters a RecordReader.
default RecordReader.RecordIterator<T>	RecordReader.RecordIterator.filter(Filter<T> filter) Filters a RecordReader.RecordIterator.

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

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

Modifier and Type	Method and Description
AbstractDataTableScan	AbstractDataTableScan.withBucketFilter(Filter<Integer> bucketFilter)
ReadBuilder	ReadBuilder.withBucketFilter(Filter<Integer> bucketFilter) Push bucket filter.
default InnerTableScan	InnerTableScan.withBucketFilter(Filter<Integer> bucketFilter)
ReadBuilder	ReadBuilderImpl.withBucketFilter(Filter<Integer> bucketFilter)
AbstractDataTableScan	AbstractDataTableScan.withLevelFilter(Filter<Integer> levelFilter)
default InnerTableScan	InnerTableScan.withLevelFilter(Filter<Integer> levelFilter)

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

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

Modifier and Type	Method and Description
SnapshotReader	SnapshotReader.withBucketFilter(Filter<Integer> bucketFilter)
SnapshotReader	SnapshotReaderImpl.withBucketFilter(Filter<Integer> bucketFilter)
SnapshotReader	SnapshotReader.withDataFileNameFilter(Filter<String> fileNameFilter)
SnapshotReader	SnapshotReaderImpl.withDataFileNameFilter(Filter<String> fileNameFilter)
SnapshotReader	SnapshotReader.withLevelFilter(Filter<Integer> levelFilter)
SnapshotReader	SnapshotReaderImpl.withLevelFilter(Filter<Integer> levelFilter)
SnapshotReader	SnapshotReader.withManifestEntryFilter(Filter<ManifestEntry> filter)
SnapshotReader	SnapshotReaderImpl.withManifestEntryFilter(Filter<ManifestEntry> filter)

Uses of Filter in org.apache.paimon.utils

Fields in org.apache.paimon.utils declared as Filter

Modifier and Type	Field and Description
static Filter<?>	Filter.ALWAYS_TRUE

Methods in org.apache.paimon.utils that return Filter

Modifier and Type	Method and Description
static <T> Filter<T>	Filter.alwaysTrue()

Methods in org.apache.paimon.utils with parameters of type Filter

Modifier and Type	Method and Description
List<V>	ObjectsCache.read(K key, Long fileSize, Filter<InternalRow> loadFilter, Filter<InternalRow> readFilter)
List<V>	ObjectsCache.read(K key, Long fileSize, Filter<InternalRow> loadFilter, Filter<InternalRow> readFilter)
List<T>	ObjectsFile.read(String fileName, Long fileSize, Filter<InternalRow> loadFilter, Filter<InternalRow> readFilter)
List<T>	ObjectsFile.read(String fileName, Long fileSize, Filter<InternalRow> loadFilter, Filter<InternalRow> readFilter)
static <V> List<V>	ObjectsFile.readFromIterator(CloseableIterator<InternalRow> inputIterator, ObjectSerializer<V> serializer, Filter<InternalRow> readFilter)
Snapshot	SnapshotManager.traversalSnapshotsFromLatestSafely(Filter<Snapshot> checker) Traversal snapshots from latest to earliest safely, this is applied on the writer side because the committer may delete obsolete snapshots, which may cause the writer to encounter unreadable snapshots.