Uses of Interface
org.apache.paimon.predicate.Predicate

Packages that use Predicate

Package	Description
org.apache.paimon.append
org.apache.paimon.fileindex
org.apache.paimon.flink
org.apache.paimon.flink.action
org.apache.paimon.flink.compact
org.apache.paimon.flink.lookup
org.apache.paimon.flink.predicate
org.apache.paimon.flink.sink
org.apache.paimon.flink.source
org.apache.paimon.format
org.apache.paimon.format.avro
org.apache.paimon.format.orc
org.apache.paimon.format.parquet
org.apache.paimon.hive
org.apache.paimon.hive.utils
org.apache.paimon.io
org.apache.paimon.lineage
org.apache.paimon.operation
org.apache.paimon.partition
org.apache.paimon.predicate
org.apache.paimon.schema
org.apache.paimon.spark
org.apache.paimon.stats
org.apache.paimon.table.source
org.apache.paimon.table.source.snapshot
org.apache.paimon.table.source.splitread
org.apache.paimon.table.system
org.apache.parquet.filter2.predicate

Uses of Predicate in org.apache.paimon.append

Constructors in org.apache.paimon.append with parameters of type Predicate

Constructor and Description
UnawareAppendTableCompactionCoordinator(FileStoreTable table, boolean isStreaming, Predicate filter)

Uses of Predicate in org.apache.paimon.fileindex

Methods in org.apache.paimon.fileindex with parameters of type Predicate

Modifier and Type	Method and Description
boolean	FileIndexPredicate.testPredicate(Predicate filePredicate)

Uses of Predicate in org.apache.paimon.flink

Methods in org.apache.paimon.flink that return Predicate

Modifier and Type	Method and Description
Predicate	PredicateConverter.visit(org.apache.flink.table.expressions.CallExpression call)
Predicate	PredicateConverter.visit(org.apache.flink.table.expressions.Expression expression)
Predicate	PredicateConverter.visit(org.apache.flink.table.expressions.FieldReferenceExpression fieldReferenceExpression)
Predicate	PredicateConverter.visit(org.apache.flink.table.expressions.TypeLiteralExpression typeLiteralExpression)
Predicate	PredicateConverter.visit(org.apache.flink.table.expressions.ValueLiteralExpression valueLiteralExpression)

Methods in org.apache.paimon.flink that return types with arguments of type Predicate

Modifier and Type	Method and Description
static Optional<Predicate>	PredicateConverter.convert(org.apache.flink.table.types.logical.RowType rowType, org.apache.flink.table.expressions.ResolvedExpression filter) Try best to convert a ResolvedExpression to Predicate.

Uses of Predicate in org.apache.paimon.flink.action

Methods in org.apache.paimon.flink.action that return Predicate

Modifier and Type	Method and Description
protected Predicate	CompactAction.getPredicate()

Uses of Predicate in org.apache.paimon.flink.compact

Methods in org.apache.paimon.flink.compact with parameters of type Predicate

Modifier and Type	Method and Description
void	UnawareBucketCompactionTopoBuilder.withPartitionPredicate(Predicate predicate)

Uses of Predicate in org.apache.paimon.flink.lookup

Fields in org.apache.paimon.flink.lookup declared as Predicate

Modifier and Type	Field and Description
Predicate	FullCacheLookupTable.Context.projectedPredicate
Predicate	FullCacheLookupTable.Context.tablePredicate

Methods in org.apache.paimon.flink.lookup that return Predicate

Modifier and Type	Method and Description
Predicate	FullCacheLookupTable.projectedPredicate()

Methods in org.apache.paimon.flink.lookup with parameters of type Predicate

Modifier and Type	Method and Description
protected abstract void	FullCacheLookupTable.refreshRow(InternalRow row, Predicate predicate)
protected void	SecondaryIndexLookupTable.refreshRow(InternalRow row, Predicate predicate)
protected void	NoPrimaryKeyLookupTable.refreshRow(InternalRow row, Predicate predicate)
protected void	PrimaryKeyLookupTable.refreshRow(InternalRow row, Predicate predicate)
void	LookupTable.specificPartitionFilter(Predicate filter)
void	FullCacheLookupTable.specificPartitionFilter(Predicate filter)
void	PrimaryKeyPartialLookupTable.specificPartitionFilter(Predicate filter)

Constructors in org.apache.paimon.flink.lookup with parameters of type Predicate

Constructor and Description
Context(FileStoreTable table, int[] projection, Predicate tablePredicate, Predicate projectedPredicate, File tempPath, List<String> joinKey, Set<Integer> requiredCachedBucketIds)
FileStoreLookupFunction(Table table, int[] projection, int[] joinKeyIndex, Predicate predicate)
LookupStreamingReader(Table table, int[] projection, Predicate predicate, Set<Integer> requireCachedBucketIds)

Uses of Predicate in org.apache.paimon.flink.predicate

Methods in org.apache.paimon.flink.predicate that return Predicate

Modifier and Type	Method and Description
Predicate	SimpleSqlPredicateConvertor.convert(Object sqlBasicCall)
Predicate	SimpleSqlPredicateConvertor.convertSqlToPredicate(String whereSql)
Predicate	SimpleSqlPredicateConvertor.visitBiFunction(Object left, Object right, java.util.function.BiFunction<Integer,Object,Predicate> visitLeft, java.util.function.BiFunction<Integer,Object,Predicate> visitRight)

Method parameters in org.apache.paimon.flink.predicate with type arguments of type Predicate

Modifier and Type	Method and Description
Predicate	SimpleSqlPredicateConvertor.visitBiFunction(Object left, Object right, java.util.function.BiFunction<Integer,Object,Predicate> visitLeft, java.util.function.BiFunction<Integer,Object,Predicate> visitRight)
Predicate	SimpleSqlPredicateConvertor.visitBiFunction(Object left, Object right, java.util.function.BiFunction<Integer,Object,Predicate> visitLeft, java.util.function.BiFunction<Integer,Object,Predicate> visitRight)

Uses of Predicate in org.apache.paimon.flink.sink

Fields in org.apache.paimon.flink.sink declared as Predicate

Modifier and Type	Field and Description
protected Predicate	SupportsRowLevelOperationFlinkTableSink.deletePredicate

Uses of Predicate in org.apache.paimon.flink.source

Fields in org.apache.paimon.flink.source declared as Predicate

Modifier and Type	Field and Description
protected Predicate	FlinkTableSource.predicate

Methods in org.apache.paimon.flink.source with parameters of type Predicate

Modifier and Type	Method and Description
static FlinkSource	LogHybridSourceFactory.buildHybridFirstSource(Table table, int[][] projectedFields, Predicate predicate)
FlinkSourceBuilder	FlinkSourceBuilder.predicate(Predicate predicate)
CompactorSourceBuilder	CompactorSourceBuilder.withPartitionPredicate(Predicate partitionPredicate)

Constructors in org.apache.paimon.flink.source with parameters of type Predicate

Constructor and Description
BucketUnawareCompactSource(FileStoreTable table, boolean isStreaming, long scanInterval, Predicate filter)
DataTableSource(org.apache.flink.table.catalog.ObjectIdentifier tableIdentifier, Table table, boolean streaming, org.apache.flink.table.factories.DynamicTableFactory.Context context, LogStoreTableFactory logStoreTableFactory, Predicate predicate, int[][] projectFields, Long limit, org.apache.flink.api.common.eventtime.WatermarkStrategy<org.apache.flink.table.data.RowData> watermarkStrategy, List<String> dynamicPartitionFilteringFields)
FlinkTableSource(Table table, Predicate predicate, int[][] projectFields, Long limit)
RewriteFileIndexSource(FileStoreTable table, Predicate partitionPredicate)
SystemTableSource(Table table, boolean isStreamingMode, Predicate predicate, int[][] projectFields, Long limit, int splitBatchSize, FlinkConnectorOptions.SplitAssignMode splitAssignMode, org.apache.flink.table.catalog.ObjectIdentifier tableIdentifier)

Uses of Predicate in org.apache.paimon.format

Method parameters in org.apache.paimon.format with type arguments of type Predicate

Modifier and Type	Method and Description
abstract FormatReaderFactory	FileFormat.createReaderFactory(RowType projectedRowType, List<Predicate> filters) Create a FormatReaderFactory from the type, with projection pushed down.

Uses of Predicate in org.apache.paimon.format.avro

Method parameters in org.apache.paimon.format.avro with type arguments of type Predicate

Modifier and Type	Method and Description
FormatReaderFactory	AvroFileFormat.createReaderFactory(RowType projectedRowType, List<Predicate> filters)

Uses of Predicate in org.apache.paimon.format.orc

Method parameters in org.apache.paimon.format.orc with type arguments of type Predicate

Modifier and Type	Method and Description
FormatReaderFactory	OrcFileFormat.createReaderFactory(RowType projectedRowType, List<Predicate> filters)

Uses of Predicate in org.apache.paimon.format.parquet

Method parameters in org.apache.paimon.format.parquet with type arguments of type Predicate

Modifier and Type	Method and Description
FormatReaderFactory	ParquetFileFormat.createReaderFactory(RowType projectedRowType, List<Predicate> filters)

Uses of Predicate in org.apache.paimon.hive

Methods in org.apache.paimon.hive that return types with arguments of type Predicate

Modifier and Type	Method and Description
Optional<Predicate>	SearchArgumentToPredicateConverter.convert()

Uses of Predicate in org.apache.paimon.hive.utils

Methods in org.apache.paimon.hive.utils that return types with arguments of type Predicate

Modifier and Type	Method and Description
static Optional<Predicate>	HiveUtils.createPredicate(TableSchema tableSchema, org.apache.hadoop.mapred.JobConf jobConf, boolean limitToReadColumnNames)

Uses of Predicate in org.apache.paimon.io

Method parameters in org.apache.paimon.io with type arguments of type Predicate

Modifier and Type	Method and Description
KeyValueFileReaderFactory	KeyValueFileReaderFactory.Builder.build(BinaryRow partition, int bucket, DeletionVector.Factory dvFactory, boolean projectKeys, List<Predicate> filters)
static boolean	FileIndexSkipper.skip(FileIO fileIO, TableSchema dataSchema, List<Predicate> dataFilter, DataFilePathFactory dataFilePathFactory, DataFileMeta file)

Uses of Predicate in org.apache.paimon.lineage

Methods in org.apache.paimon.lineage with parameters of type Predicate

Modifier and Type	Method and Description
Iterator<DataLineageEntity>	LineageMeta.sinkDataLineages(Predicate predicate) Get sink data and job lineages.
Iterator<TableLineageEntity>	LineageMeta.sinkTableLineages(Predicate predicate) Get sink table and job lineages.
Iterator<DataLineageEntity>	LineageMeta.sourceDataLineages(Predicate predicate) Get source data and job lineages.
Iterator<TableLineageEntity>	LineageMeta.sourceTableLineages(Predicate predicate) Get source table and job lineages.

Uses of Predicate in org.apache.paimon.operation

Methods in org.apache.paimon.operation that return Predicate

Modifier and Type	Method and Description
Predicate	DefaultValueAssigner.handlePredicate(Predicate filters)

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

Modifier and Type	Method and Description
Predicate	DefaultValueAssigner.handlePredicate(Predicate filters)
abstract void	ScanBucketFilter.pushdown(Predicate predicate)
void	ScanBucketFilter.setBucketKeyFilter(Predicate predicate)
MergeFileSplitRead	MergeFileSplitRead.withFilter(Predicate predicate)
RawFileSplitRead	RawFileSplitRead.withFilter(Predicate predicate)
AppendOnlyFileStoreScan	AppendOnlyFileStoreScan.withFilter(Predicate predicate)
SplitRead<T>	SplitRead.withFilter(Predicate predicate)
KeyValueFileStoreScan	KeyValueFileStoreScan.withKeyFilter(Predicate predicate)
FileStoreScan	AbstractFileStoreScan.withPartitionFilter(Predicate predicate)
FileStoreScan	FileStoreScan.withPartitionFilter(Predicate predicate)
KeyValueFileStoreScan	KeyValueFileStoreScan.withValueFilter(Predicate predicate)

Uses of Predicate in org.apache.paimon.partition

Methods in org.apache.paimon.partition that return Predicate

Modifier and Type	Method and Description
static Predicate	PartitionPredicate.createPartitionPredicate(List<Map<String,String>> partitions, RowType rowType, String defaultPartValue)
static Predicate	PartitionPredicate.createPartitionPredicate(Map<String,String> spec, RowType rowType, String defaultPartValue)
static Predicate	PartitionPredicate.createPartitionPredicate(RowType partitionType, BinaryRow partition)
static Predicate	PartitionPredicate.createPartitionPredicate(RowType rowType, Map<String,Object> partition)
static Predicate	PartitionPredicate.createPartitionPredicate(RowType partitionType, Object[] partition)

Methods in org.apache.paimon.partition with parameters of type Predicate

Modifier and Type	Method and Description
static PartitionPredicate	PartitionPredicate.fromPredicate(RowType partitionType, Predicate predicate) Compared to the multiple method, this approach can accept filtering of partially partitioned fields.

Uses of Predicate in org.apache.paimon.predicate

Classes in org.apache.paimon.predicate that implement Predicate

Modifier and Type	Class and Description
class	CompoundPredicate Non-leaf node in a Predicate tree.
class	LeafPredicate Leaf node of a Predicate tree.

Methods in org.apache.paimon.predicate that return Predicate

Modifier and Type	Method and Description
static Predicate	PredicateBuilder.and(List<Predicate> predicates)
static Predicate	PredicateBuilder.and(Predicate... predicates)
static Predicate	PredicateBuilder.andNullable(List<Predicate> predicates)
static Predicate	PredicateBuilder.andNullable(Predicate... predicates)
Predicate	PredicateBuilder.between(int idx, Object includedLowerBound, Object includedUpperBound)
Predicate	PredicateBuilder.contains(int idx, Object patternLiteral)
Predicate	PredicateBuilder.endsWith(int idx, Object patternLiteral)
Predicate	PredicateBuilder.equal(int idx, Object literal)
Predicate	PredicateBuilder.greaterOrEqual(int idx, Object literal)
Predicate	PredicateBuilder.greaterThan(int idx, Object literal)
Predicate	PredicateBuilder.in(int idx, List<Object> literals)
Predicate	PredicateBuilder.isNotNull(int idx)
Predicate	PredicateBuilder.isNull(int idx)
Predicate	PredicateBuilder.leaf(LeafUnaryFunction function, int idx)
Predicate	PredicateBuilder.leaf(NullFalseLeafBinaryFunction function, int idx, Object literal)
Predicate	PredicateBuilder.lessOrEqual(int idx, Object literal)
Predicate	PredicateBuilder.lessThan(int idx, Object literal)
Predicate	PredicateBuilder.notEqual(int idx, Object literal)
Predicate	PredicateBuilder.notIn(int idx, List<Object> literals)
static Predicate	PredicateBuilder.or(List<Predicate> predicates)
static Predicate	PredicateBuilder.or(Predicate... predicates)
static Predicate	PredicateBuilder.partition(Map<String,String> map, RowType rowType, String defaultPartValue)
static Predicate	PredicateBuilder.partitions(List<Map<String,String>> partitions, RowType rowType, String defaultPartValue)
Predicate	PredicateBuilder.startsWith(int idx, Object patternLiteral)

Methods in org.apache.paimon.predicate that return types with arguments of type Predicate

Modifier and Type	Method and Description
List<Predicate>	CompoundPredicate.children()
static List<Predicate>	PredicateBuilder.excludePredicateWithFields(List<Predicate> predicates, Set<String> fields)
Optional<Predicate>	Predicate.negate()
Optional<Predicate>	LeafPredicate.negate()
Optional<Predicate>	CompoundPredicate.negate()
Optional<Predicate>	Or.negate(List<Predicate> children)
Optional<Predicate>	And.negate(List<Predicate> children)
abstract Optional<Predicate>	CompoundPredicate.Function.negate(List<Predicate> children)
static List<Predicate>	PredicateBuilder.pickTransformFieldMapping(List<Predicate> predicates, int[] fieldIdxMapping)
static List<Predicate>	PredicateBuilder.pickTransformFieldMapping(List<Predicate> predicates, List<String> inputFields, List<String> pickedFields)
static List<Predicate>	PredicateBuilder.splitAnd(Predicate predicate)
static List<Predicate>	PredicateBuilder.splitOr(Predicate predicate)
static Optional<Predicate>	PredicateBuilder.transformFieldMapping(Predicate predicate, int[] fieldIdxMapping)
default Optional<Predicate>	PredicateReplaceVisitor.visit(CompoundPredicate predicate)
Optional<Predicate>	PredicateProjectionConverter.visit(CompoundPredicate predicate)
Optional<Predicate>	PredicateProjectionConverter.visit(LeafPredicate predicate)

Methods in org.apache.paimon.predicate with parameters of type Predicate

Modifier and Type	Method and Description
static Predicate	PredicateBuilder.and(Predicate... predicates)
static Predicate	PredicateBuilder.andNullable(Predicate... predicates)
static boolean	PredicateBuilder.containsFields(Predicate predicate, Set<String> fields)
static Predicate	PredicateBuilder.or(Predicate... predicates)
static List<Predicate>	PredicateBuilder.splitAnd(Predicate predicate)
static List<Predicate>	PredicateBuilder.splitOr(Predicate predicate)
static Optional<Predicate>	PredicateBuilder.transformFieldMapping(Predicate predicate, int[] fieldIdxMapping)

Method parameters in org.apache.paimon.predicate with type arguments of type Predicate

Modifier and Type	Method and Description
static Predicate	PredicateBuilder.and(List<Predicate> predicates)
static Predicate	PredicateBuilder.andNullable(List<Predicate> predicates)
static List<Predicate>	PredicateBuilder.excludePredicateWithFields(List<Predicate> predicates, Set<String> fields)
Optional<Predicate>	Or.negate(List<Predicate> children)
Optional<Predicate>	And.negate(List<Predicate> children)
abstract Optional<Predicate>	CompoundPredicate.Function.negate(List<Predicate> children)
static Predicate	PredicateBuilder.or(List<Predicate> predicates)
static List<Predicate>	PredicateBuilder.pickTransformFieldMapping(List<Predicate> predicates, int[] fieldIdxMapping)
static List<Predicate>	PredicateBuilder.pickTransformFieldMapping(List<Predicate> predicates, List<String> inputFields, List<String> pickedFields)
boolean	Or.test(InternalRow row, List<Predicate> children)
boolean	And.test(InternalRow row, List<Predicate> children)
abstract boolean	CompoundPredicate.Function.test(InternalRow row, List<Predicate> children)
boolean	Or.test(long rowCount, InternalRow minValues, InternalRow maxValues, InternalArray nullCounts, List<Predicate> children)
boolean	And.test(long rowCount, InternalRow minValues, InternalRow maxValues, InternalArray nullCounts, List<Predicate> children)
abstract boolean	CompoundPredicate.Function.test(long rowCount, InternalRow minValues, InternalRow maxValues, InternalArray nullCounts, List<Predicate> children)

Constructor parameters in org.apache.paimon.predicate with type arguments of type Predicate

Constructor and Description
CompoundPredicate(CompoundPredicate.Function function, List<Predicate> children)

Uses of Predicate in org.apache.paimon.schema

Methods in org.apache.paimon.schema that return types with arguments of type Predicate

Modifier and Type	Method and Description
static List<Predicate>	SchemaEvolutionUtil.createDataFilters(List<DataField> tableFields, List<DataField> dataFields, List<Predicate> filters) Create predicate list from data fields.

Method parameters in org.apache.paimon.schema with type arguments of type Predicate

Modifier and Type	Method and Description
static List<Predicate>	SchemaEvolutionUtil.createDataFilters(List<DataField> tableFields, List<DataField> dataFields, List<Predicate> filters) Create predicate list from data fields.

Uses of Predicate in org.apache.paimon.spark

Methods in org.apache.paimon.spark that return Predicate

Modifier and Type	Method and Description
Predicate	SparkFilterConverter.convert(org.apache.spark.sql.sources.Filter filter)
Predicate	SparkFilterConverter.convertIgnoreFailure(org.apache.spark.sql.sources.Filter filter)

Uses of Predicate in org.apache.paimon.stats

Methods in org.apache.paimon.stats that return Predicate

Modifier and Type	Method and Description
Predicate	SimpleStatsConverters.convertFilter(long dataSchemaId, Predicate filter)

Methods in org.apache.paimon.stats with parameters of type Predicate

Modifier and Type	Method and Description
Predicate	SimpleStatsConverters.convertFilter(long dataSchemaId, Predicate filter)

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

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

Modifier and Type	Method and Description
protected InnerTableRead	KeyValueTableRead.innerWithFilter(Predicate predicate)
protected abstract InnerTableRead	AbstractDataTableRead.innerWithFilter(Predicate predicate)
DataTableStreamScan	DataTableStreamScan.withFilter(Predicate predicate)
InnerTableRead	InnerTableRead.withFilter(Predicate predicate)
ReadBuilder	ReadBuilder.withFilter(Predicate predicate) Push filters, will filter the data as much as possible, but it is not guaranteed that it is a complete filter.
InnerTableRead	AbstractDataTableRead.withFilter(Predicate predicate)
InnerTableScan	DataTableBatchScan.withFilter(Predicate predicate)
InnerTableScan	InnerTableScan.withFilter(Predicate predicate)
ReadBuilder	ReadBuilderImpl.withFilter(Predicate filter)

Method parameters in org.apache.paimon.table.source with type arguments of type Predicate

Modifier and Type	Method and Description
default InnerTableRead	InnerTableRead.withFilter(List<Predicate> predicates)
default ReadBuilder	ReadBuilder.withFilter(List<Predicate> predicates) Apply filters to the readers to decrease the number of produced records.

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

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

Modifier and Type	Method and Description
SnapshotReader	SnapshotReader.withFilter(Predicate predicate)
SnapshotReader	SnapshotReaderImpl.withFilter(Predicate predicate)
SnapshotReader	SnapshotReader.withPartitionFilter(Predicate predicate)
SnapshotReader	SnapshotReaderImpl.withPartitionFilter(Predicate predicate)

Constructor parameters in org.apache.paimon.table.source.snapshot with type arguments of type Predicate

Constructor and Description
SnapshotReaderImpl(FileStoreScan scan, TableSchema tableSchema, CoreOptions options, SnapshotManager snapshotManager, SplitGenerator splitGenerator, java.util.function.BiConsumer<FileStoreScan,Predicate> nonPartitionFilterConsumer, DefaultValueAssigner defaultValueAssigner, FileStorePathFactory pathFactory, String tableName, IndexFileHandler indexFileHandler)

Uses of Predicate in org.apache.paimon.table.source.splitread

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

Modifier and Type	Method and Description
SplitRead<InternalRow>	IncrementalDiffSplitRead.withFilter(Predicate predicate)

Uses of Predicate in org.apache.paimon.table.system

Methods in org.apache.paimon.table.system with parameters of type Predicate

Modifier and Type	Method and Description
InnerTableRead	TableLineageTable.TableLineageRead.withFilter(Predicate predicate)

Constructor parameters in org.apache.paimon.table.system with type arguments of type Predicate

Constructor and Description
TableLineageRead(LineageMetaFactory lineageMetaFactory, Options options, java.util.function.BiFunction<LineageMeta,Predicate,Iterator<TableLineageEntity>> tableLineageQuery)

Uses of Predicate in org.apache.parquet.filter2.predicate

Method parameters in org.apache.parquet.filter2.predicate with type arguments of type Predicate

Modifier and Type	Method and Description
static org.apache.parquet.filter2.compat.FilterCompat.Filter	ParquetFilters.convert(List<Predicate> predicates)