org.apache.paimon.operation

Interface BucketSelectConverter

public interface BucketSelectConverter

Bucket filter push down in scan to skip files.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	BucketSelectConverter.Selector Selector to select bucket from Predicate.

Field Summary

Fields

Modifier and Type	Field and Description
static int	MAX_VALUES

Method Summary

Modifier and Type	Method and Description
static void	assembleRows(List<Object>[] rowValues, java.util.function.Consumer<List<Object>> consumer, List<Object> stack, int columnIndex)
Optional<BiFilter<Integer,Integer>>	convert(Predicate predicate)
static Optional<BiFilter<Integer,Integer>>	create(Predicate bucketPredicate, RowType bucketKeyType)
static int	hash(List<Object> columns, InternalRowSerializer serializer)

Field Detail

MAX_VALUES

static final int MAX_VALUES

See Also:

Constant Field Values

Method Detail

convert

Optional<BiFilter<Integer,Integer>> convert(Predicate predicate)

create

static Optional<BiFilter<Integer,Integer>> create(Predicate bucketPredicate,
                                                  RowType bucketKeyType)

hash

static int hash(List<Object> columns,
                InternalRowSerializer serializer)

assembleRows

static void assembleRows(List<Object>[] rowValues,
                         java.util.function.Consumer<List<Object>> consumer,
                         List<Object> stack,
                         int columnIndex)