org.apache.paimon.partition

Interface PartitionPredicate

All Known Implementing Classes:

PartitionPredicate.DefaultPartitionPredicate, PartitionPredicate.MultiplePartitionPredicate

public interface PartitionPredicate

A special predicate to filter partition only, just like Predicate.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	PartitionPredicate.DefaultPartitionPredicate A PartitionPredicate using Predicate.
static class	PartitionPredicate.MultiplePartitionPredicate A PartitionPredicate optimizing for multiple partitions.

Method Summary

Modifier and Type	Method and Description
static PartitionPredicate	alwaysFalse()
static PartitionPredicate	alwaysTrue()
static List<BinaryRow>	createBinaryPartitions(List<Map<String,String>> partitions, RowType partitionType, String defaultPartValue)
static Predicate	createPartitionPredicate(List<Map<String,String>> partitions, RowType rowType, String defaultPartValue)
static Predicate	createPartitionPredicate(Map<String,String> spec, RowType rowType, String defaultPartValue)
static Predicate	createPartitionPredicate(RowType partitionType, BinaryRow partition)
static Predicate	createPartitionPredicate(RowType rowType, Map<String,Object> partition)
static Predicate	createPartitionPredicate(RowType partitionType, Object[] partition)
static PartitionPredicate	fromMultiple(RowType partitionType, List<BinaryRow> partitions)
static PartitionPredicate	fromMultiple(RowType partitionType, Set<BinaryRow> partitions)
static PartitionPredicate	fromPredicate(RowType partitionType, Predicate predicate) Compared to the multiple method, this approach can accept filtering of partially partitioned fields.
boolean	test(BinaryRow part)
boolean	test(long rowCount, InternalRow minValues, InternalRow maxValues, InternalArray nullCounts)

Method Detail

test

boolean test(BinaryRow part)

test

boolean test(long rowCount,
             InternalRow minValues,
             InternalRow maxValues,
             InternalArray nullCounts)

fromPredicate

@Nullable
static PartitionPredicate fromPredicate(RowType partitionType,
                                                  Predicate predicate)

Compared to the multiple method, this approach can accept filtering of partially partitioned fields.

fromMultiple

@Nullable
static PartitionPredicate fromMultiple(RowType partitionType,
                                                 List<BinaryRow> partitions)

fromMultiple

@Nullable
static PartitionPredicate fromMultiple(RowType partitionType,
                                                 Set<BinaryRow> partitions)

alwaysFalse

static PartitionPredicate alwaysFalse()

alwaysTrue

static PartitionPredicate alwaysTrue()

createPartitionPredicate

static Predicate createPartitionPredicate(RowType rowType,
                                          Map<String,Object> partition)

createPartitionPredicate

static Predicate createPartitionPredicate(RowType partitionType,
                                          Object[] partition)

createPartitionPredicate

static Predicate createPartitionPredicate(RowType partitionType,
                                          BinaryRow partition)

createPartitionPredicate

@Nullable
static Predicate createPartitionPredicate(Map<String,String> spec,
                                                    RowType rowType,
                                                    String defaultPartValue)

createPartitionPredicate

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

createBinaryPartitions

static List<BinaryRow> createBinaryPartitions(List<Map<String,String>> partitions,
                                              RowType partitionType,
                                              String defaultPartValue)