org.apache.paimon.predicate

Class PredicateBuilder

java.lang.Object

org.apache.paimon.predicate.PredicateBuilder

@Public
public class PredicateBuilder
extends Object

A utility class to create Predicate object for common filter conditions.

Since:

0.4.0

Constructor Summary

Constructors

Constructor and Description
PredicateBuilder(RowType rowType)

Method Summary

Modifier and Type	Method and Description
static Predicate	and(List<Predicate> predicates)
static Predicate	and(Predicate... predicates)
static Predicate	andNullable(List<Predicate> predicates)
static Predicate	andNullable(Predicate... predicates)
Predicate	between(int idx, Object includedLowerBound, Object includedUpperBound)
Predicate	contains(int idx, Object patternLiteral)
static boolean	containsFields(Predicate predicate, Set<String> fields)
static Object	convertJavaObject(DataType literalType, Object o)
Predicate	endsWith(int idx, Object patternLiteral)
Predicate	equal(int idx, Object literal)
static List<Predicate>	excludePredicateWithFields(List<Predicate> predicates, Set<String> fields)
Predicate	greaterOrEqual(int idx, Object literal)
Predicate	greaterThan(int idx, Object literal)
Predicate	in(int idx, List<Object> literals)
int	indexOf(String field)
Predicate	isNotNull(int idx)
Predicate	isNull(int idx)
Predicate	leaf(LeafUnaryFunction function, int idx)
Predicate	leaf(NullFalseLeafBinaryFunction function, int idx, Object literal)
Predicate	lessOrEqual(int idx, Object literal)
Predicate	lessThan(int idx, Object literal)
Predicate	notEqual(int idx, Object literal)
Predicate	notIn(int idx, List<Object> literals)
static Predicate	or(List<Predicate> predicates)
static Predicate	or(Predicate... predicates)
static Predicate	partition(Map<String,String> map, RowType rowType, String defaultPartValue)
static Predicate	partitions(List<Map<String,String>> partitions, RowType rowType, String defaultPartValue)
static List<Predicate>	pickTransformFieldMapping(List<Predicate> predicates, int[] fieldIdxMapping)
static List<Predicate>	pickTransformFieldMapping(List<Predicate> predicates, List<String> inputFields, List<String> pickedFields)
static List<Predicate>	splitAnd(Predicate predicate)
static List<Predicate>	splitOr(Predicate predicate)
Predicate	startsWith(int idx, Object patternLiteral)
static Optional<Predicate>	transformFieldMapping(Predicate predicate, int[] fieldIdxMapping)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PredicateBuilder

public PredicateBuilder(RowType rowType)

Method Detail

indexOf

public int indexOf(String field)

equal

public Predicate equal(int idx,
                       Object literal)

notEqual

public Predicate notEqual(int idx,
                          Object literal)

lessThan

public Predicate lessThan(int idx,
                          Object literal)

lessOrEqual

public Predicate lessOrEqual(int idx,
                             Object literal)

greaterThan

public Predicate greaterThan(int idx,
                             Object literal)

greaterOrEqual

public Predicate greaterOrEqual(int idx,
                                Object literal)

isNull

public Predicate isNull(int idx)

isNotNull

public Predicate isNotNull(int idx)

startsWith

public Predicate startsWith(int idx,
                            Object patternLiteral)

endsWith

public Predicate endsWith(int idx,
                          Object patternLiteral)

contains

public Predicate contains(int idx,
                          Object patternLiteral)

leaf

public Predicate leaf(NullFalseLeafBinaryFunction function,
                      int idx,
                      Object literal)

leaf

public Predicate leaf(LeafUnaryFunction function,
                      int idx)

in

public Predicate in(int idx,
                    List<Object> literals)

notIn

public Predicate notIn(int idx,
                       List<Object> literals)

between

public Predicate between(int idx,
                         Object includedLowerBound,
                         Object includedUpperBound)

and

public static Predicate and(Predicate... predicates)

and

public static Predicate and(List<Predicate> predicates)

andNullable

@Nullable
public static Predicate andNullable(Predicate... predicates)

andNullable

@Nullable
public static Predicate andNullable(List<Predicate> predicates)

or

public static Predicate or(Predicate... predicates)

or

public static Predicate or(List<Predicate> predicates)

splitAnd

public static List<Predicate> splitAnd(@Nullable
                                       Predicate predicate)

splitOr

public static List<Predicate> splitOr(@Nullable
                                      Predicate predicate)

convertJavaObject

public static Object convertJavaObject(DataType literalType,
                                       Object o)

pickTransformFieldMapping

public static List<Predicate> pickTransformFieldMapping(List<Predicate> predicates,
                                                        List<String> inputFields,
                                                        List<String> pickedFields)

pickTransformFieldMapping

public static List<Predicate> pickTransformFieldMapping(List<Predicate> predicates,
                                                        int[] fieldIdxMapping)

transformFieldMapping

public static Optional<Predicate> transformFieldMapping(Predicate predicate,
                                                        int[] fieldIdxMapping)

containsFields

public static boolean containsFields(Predicate predicate,
                                     Set<String> fields)

excludePredicateWithFields

public static List<Predicate> excludePredicateWithFields(@Nullable
                                                         List<Predicate> predicates,
                                                         Set<String> fields)

partition

@Nullable
public static Predicate partition(Map<String,String> map,
                                            RowType rowType,
                                            String defaultPartValue)

partitions

public static Predicate partitions(List<Map<String,String>> partitions,
                                   RowType rowType,
                                   String defaultPartValue)