Modifier and Type | Method and Description |
---|---|
SupportsFilterPushDown.Result |
FileSystemTableSource.applyFilters(List<ResolvedExpression> filters) |
Modifier and Type | Method and Description |
---|---|
SupportsFilterPushDown.Result |
SupportsFilterPushDown.applyFilters(List<ResolvedExpression> filters)
Provides a list of filters in conjunctive form.
|
static SupportsFilterPushDown.Result |
SupportsFilterPushDown.Result.of(List<ResolvedExpression> acceptedFilters,
List<ResolvedExpression> remainingFilters)
Constructs a filter push-down result.
|
Modifier and Type | Method and Description |
---|---|
static SupportsFilterPushDown.Result |
FilterPushDownSpec.apply(List<org.apache.calcite.rex.RexNode> predicates,
DynamicTableSource tableSource,
SourceAbilityContext context) |
Modifier and Type | Method and Description |
---|---|
protected scala.Tuple2<SupportsFilterPushDown.Result,org.apache.flink.table.planner.plan.schema.TableSourceTable> |
PushFilterIntoSourceScanRuleBase.resolveFiltersAndCreateTableSourceTable(org.apache.calcite.rex.RexNode[] convertiblePredicates,
org.apache.flink.table.planner.plan.schema.TableSourceTable oldTableSourceTable,
org.apache.calcite.rel.core.TableScan scan,
org.apache.calcite.tools.RelBuilder relBuilder)
Resolves filters using the underlying sources
SupportsFilterPushDown and creates a
new TableSourceTable with the supplied predicates. |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.