Package | Description |
---|---|
org.apache.flink.table.planner.plan.abilities.source |
Modifier and Type | Method and Description |
---|---|
static SourceAbilityContext |
SourceAbilityContext.from(org.apache.calcite.rel.core.TableScan scan) |
Modifier and Type | Method and Description |
---|---|
void |
AggregatePushDownSpec.apply(DynamicTableSource tableSource,
SourceAbilityContext context) |
void |
ProjectPushDownSpec.apply(DynamicTableSource tableSource,
SourceAbilityContext context) |
void |
WatermarkPushDownSpec.apply(DynamicTableSource tableSource,
SourceAbilityContext context) |
void |
SourceAbilitySpec.apply(DynamicTableSource tableSource,
SourceAbilityContext context)
Apply the ability to the given
DynamicTableSource . |
void |
LimitPushDownSpec.apply(DynamicTableSource tableSource,
SourceAbilityContext context) |
void |
ReadingMetadataSpec.apply(DynamicTableSource tableSource,
SourceAbilityContext context) |
void |
PartitionPushDownSpec.apply(DynamicTableSource tableSource,
SourceAbilityContext context) |
void |
SourceWatermarkSpec.apply(DynamicTableSource tableSource,
SourceAbilityContext context) |
void |
FilterPushDownSpec.apply(DynamicTableSource tableSource,
SourceAbilityContext context) |
static SupportsFilterPushDown.Result |
FilterPushDownSpec.apply(List<org.apache.calcite.rex.RexNode> predicates,
DynamicTableSource tableSource,
SourceAbilityContext context) |
static boolean |
AggregatePushDownSpec.apply(RowType inputType,
List<int[]> groupingSets,
List<org.apache.calcite.rel.core.AggregateCall> aggregateCalls,
RowType producedType,
DynamicTableSource tableSource,
SourceAbilityContext context) |
String |
AggregatePushDownSpec.getDigests(SourceAbilityContext context) |
String |
ProjectPushDownSpec.getDigests(SourceAbilityContext context) |
String |
WatermarkPushDownSpec.getDigests(SourceAbilityContext context) |
String |
SourceAbilitySpec.getDigests(SourceAbilityContext context)
Additional digests to generate when this spec is applied to the source.
|
String |
LimitPushDownSpec.getDigests(SourceAbilityContext context) |
String |
ReadingMetadataSpec.getDigests(SourceAbilityContext context) |
String |
PartitionPushDownSpec.getDigests(SourceAbilityContext context) |
String |
SourceWatermarkSpec.getDigests(SourceAbilityContext context) |
String |
FilterPushDownSpec.getDigests(SourceAbilityContext context) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.