Modifier and Type | Method and Description |
---|---|
Optional<Predicate> |
SearchArgumentToPredicateConverter.convert() |
Constructor and Description |
---|
FileStoreLookupFunction(FileStoreTable table,
int[] projection,
int[] joinKeyIndex,
Predicate predicate) |
Modifier and Type | Field and Description |
---|---|
protected Predicate |
FlinkSource.predicate |
protected Predicate |
FlinkTableSource.predicate |
Modifier and Type | Method and Description |
---|---|
FlinkSourceBuilder |
FlinkSourceBuilder.withPredicate(Predicate predicate) |
Constructor and Description |
---|
ContinuousFileStoreSource(DataTable table,
int[][] projectedFields,
Predicate predicate,
Long limit) |
ContinuousFileStoreSource(DataTable table,
int[][] projectedFields,
Predicate predicate,
Long limit,
ContinuousDataFileSnapshotEnumerator.Factory enumeratorFactory) |
FlinkSource(Table table,
int[][] projectedFields,
Predicate predicate,
Long limit) |
FlinkTableSource(Table table,
Predicate predicate,
int[][] projectFields,
Long limit) |
SimpleSystemSource(Table table,
int[][] projectedFields,
Predicate predicate,
Long limit) |
StaticFileStoreSource(DataTable table,
int[][] projectedFields,
Predicate predicate,
Long limit) |
StaticFileStoreSource(DataTable table,
int[][] projectedFields,
Predicate predicate,
Long limit,
StaticDataFileSnapshotEnumerator.Factory enumeratorFactory) |
SystemTableSource(Table table,
boolean isStreamingMode,
Predicate predicate,
int[][] projectFields,
Long limit) |
Modifier and Type | Method and Description |
---|---|
KeyValueFileReaderFactory |
KeyValueFileReaderFactory.Builder.build(org.apache.flink.table.data.binary.BinaryRowData partition,
int bucket,
boolean projectKeys,
List<Predicate> filters) |
Modifier and Type | Method and Description |
---|---|
protected FileStoreScan |
AbstractFileStoreScan.withBucketKeyFilter(Predicate predicate) |
FileStoreRead<KeyValue> |
KeyValueFileStoreRead.withFilter(Predicate predicate) |
FileStoreRead<T> |
FileStoreRead.withFilter(Predicate predicate) |
AppendOnlyFileStoreScan |
AppendOnlyFileStoreScan.withFilter(Predicate predicate) |
FileStoreRead<org.apache.flink.table.data.RowData> |
AppendOnlyFileStoreRead.withFilter(Predicate predicate) |
KeyValueFileStoreScan |
KeyValueFileStoreScan.withKeyFilter(Predicate predicate) |
FileStoreScan |
FileStoreScan.withPartitionFilter(Predicate predicate) |
FileStoreScan |
AbstractFileStoreScan.withPartitionFilter(Predicate predicate) |
Modifier and Type | Class and Description |
---|---|
class |
CompoundPredicate
Non-leaf node in a
Predicate tree. |
class |
LeafPredicate
Leaf node of a
Predicate tree. |
Modifier and Type | Method and Description |
---|---|
static Predicate |
PredicateBuilder.and(List<Predicate> predicates) |
static Predicate |
PredicateBuilder.and(Predicate... predicates) |
Predicate |
PredicateBuilder.between(int idx,
Object includedLowerBound,
Object includedUpperBound) |
Predicate |
PredicateBuilder.equal(int idx,
Object literal) |
static Predicate |
PredicateConverter.fromMap(Map<String,String> map,
org.apache.flink.table.types.logical.RowType rowType) |
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) |
Predicate |
PredicateBuilder.startsWith(int idx,
Object patternLiteral) |
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) |
Modifier and Type | Method and Description |
---|---|
List<Predicate> |
CompoundPredicate.children() |
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 . |
Optional<Predicate> |
Predicate.negate() |
Optional<Predicate> |
CompoundPredicate.negate() |
Optional<Predicate> |
LeafPredicate.negate() |
abstract Optional<Predicate> |
CompoundPredicate.Function.negate(List<Predicate> children) |
Optional<Predicate> |
And.negate(List<Predicate> children) |
Optional<Predicate> |
Or.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) |
Modifier and Type | Method and Description |
---|---|
static Predicate |
PredicateBuilder.and(Predicate... predicates) |
static boolean |
PredicateBuilder.containsFields(Predicate predicate,
Set<String> fields) |
static Optional<BucketSelector> |
BucketSelector.create(Predicate bucketPredicate,
org.apache.flink.table.types.logical.RowType bucketKeyType) |
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) |
Modifier and Type | Method and Description |
---|---|
static Predicate |
PredicateBuilder.and(List<Predicate> predicates) |
abstract Optional<Predicate> |
CompoundPredicate.Function.negate(List<Predicate> children) |
Optional<Predicate> |
And.negate(List<Predicate> children) |
Optional<Predicate> |
Or.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) |
abstract boolean |
CompoundPredicate.Function.test(long rowCount,
FieldStats[] fieldStats,
List<Predicate> children) |
boolean |
And.test(long rowCount,
FieldStats[] fieldStats,
List<Predicate> children) |
boolean |
Or.test(long rowCount,
FieldStats[] fieldStats,
List<Predicate> children) |
abstract boolean |
CompoundPredicate.Function.test(Object[] values,
List<Predicate> children) |
boolean |
And.test(Object[] values,
List<Predicate> children) |
boolean |
Or.test(Object[] values,
List<Predicate> children) |
Constructor and Description |
---|
PredicateFilter(org.apache.flink.table.types.logical.RowType rowType,
Predicate predicate) |
Constructor and Description |
---|
CompoundPredicate(CompoundPredicate.Function function,
List<Predicate> children) |
PredicateFilter(org.apache.flink.table.types.logical.RowType rowType,
List<Predicate> predicates) |
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.
|
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.
|
Modifier and Type | Method and Description |
---|---|
static BulkFormatMapping.BulkFormatMappingBuilder |
BulkFormatMapping.newBuilder(FileFormat fileFormat,
KeyValueFieldsExtractor extractor,
int[][] keyProjection,
int[][] valueProjection,
List<Predicate> filters) |
Modifier and Type | Method and Description |
---|---|
abstract org.apache.flink.connector.file.src.reader.BulkFormat<org.apache.flink.table.data.RowData,org.apache.flink.connector.file.src.FileSourceSplit> |
FileFormat.createReaderFactory(org.apache.flink.table.types.logical.RowType type,
int[][] projection,
List<Predicate> filters)
Create a
BulkFormat from the type, with projection pushed down. |
Modifier and Type | Method and Description |
---|---|
org.apache.flink.connector.file.src.reader.BulkFormat<org.apache.flink.table.data.RowData,org.apache.flink.connector.file.src.FileSourceSplit> |
AvroFileFormat.createReaderFactory(org.apache.flink.table.types.logical.RowType type,
int[][] projection,
List<Predicate> filters) |
Modifier and Type | Method and Description |
---|---|
org.apache.flink.connector.file.src.reader.BulkFormat<org.apache.flink.table.data.RowData,org.apache.flink.connector.file.src.FileSourceSplit> |
OrcFileFormat.createReaderFactory(org.apache.flink.table.types.logical.RowType type,
int[][] projection,
List<Predicate> filters) |
Modifier and Type | Method and Description |
---|---|
org.apache.flink.connector.file.src.reader.BulkFormat<org.apache.flink.table.data.RowData,org.apache.flink.connector.file.src.FileSourceSplit> |
ParquetFileFormat.createReaderFactory(org.apache.flink.table.types.logical.RowType type,
int[][] projection,
List<Predicate> filters) |
Modifier and Type | Method and Description |
---|---|
Predicate |
SparkFilterConverter.convert(org.apache.spark.sql.sources.Filter filter) |
Constructor and Description |
---|
SparkReaderFactory(Table table,
int[] projectedFields,
List<Predicate> predicates,
org.apache.flink.configuration.Configuration conf) |
SparkScan(Table table,
List<Predicate> predicates,
int[] projectedFields,
org.apache.flink.configuration.Configuration conf) |
Modifier and Type | Method and Description |
---|---|
default void |
SupportsWrite.deleteWhere(String commitUser,
List<Predicate> filters,
Lock.Factory lockFactory) |
Modifier and Type | Method and Description |
---|---|
TableRead |
TableRead.withFilter(Predicate predicate) |
DataTableScan |
DataTableScan.withFilter(Predicate predicate) |
TableScan |
TableScan.withFilter(Predicate predicate) |
AbstractDataTableScan |
AbstractDataTableScan.withFilter(Predicate predicate) |
protected abstract void |
AbstractDataTableScan.withNonPartitionFilter(Predicate predicate) |
Modifier and Type | Method and Description |
---|---|
default TableRead |
TableRead.withFilter(List<Predicate> predicates) |
default TableScan |
TableScan.withFilter(List<Predicate> predicates) |
Constructor and Description |
---|
TableStreamingReader(FileStoreTable table,
int[] projection,
Predicate predicate) |
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.