Package | Description |
---|---|
org.apache.flink.table.planner.plan.abilities.source | |
org.apache.flink.table.planner.plan.nodes.exec.spec |
Modifier and Type | Class and Description |
---|---|
class |
AggregatePushDownSpec
A sub-class of
SourceAbilitySpec that can not only serialize/deserialize the aggregation
to/from JSON, but also can push the local aggregate into a SupportsAggregatePushDown . |
class |
FilterPushDownSpec
A sub-class of
SourceAbilitySpec that can not only serialize/deserialize the filter
to/from JSON, but also can push the filter into a SupportsFilterPushDown . |
class |
LimitPushDownSpec
A sub-class of
SourceAbilitySpec that can not only serialize/deserialize the limit value
to/from JSON, but also can push the limit value into a LimitPushDownSpec . |
class |
PartitionPushDownSpec
A sub-class of
SourceAbilitySpec that can not only serialize/deserialize the partitions
to/from JSON, but also can push the partitions into a SupportsPartitionPushDown . |
class |
ProjectPushDownSpec
A sub-class of
SourceAbilitySpec that can not only serialize/deserialize the projection
to/from JSON, but also can push the projection into a SupportsProjectionPushDown . |
class |
ReadingMetadataSpec
A sub-class of
SourceAbilitySpec that can not only serialize/deserialize the metadata
columns to/from JSON, but also can read the metadata columns from SupportsReadingMetadata . |
class |
SourceAbilitySpecBase
Base class for
SourceAbilitySpec . |
class |
SourceWatermarkSpec
A sub-class of
SourceAbilitySpec that can not only serialize/deserialize the boolean flag
whether a source watermark should be used to/from JSON, but can also apply it to SupportsSourceWatermark . |
class |
WatermarkPushDownSpec
A sub-class of
SourceAbilitySpec that can not only serialize/deserialize the watermark
to/from JSON, but also can push the watermark into a SupportsWatermarkPushDown . |
Modifier and Type | Method and Description |
---|---|
List<SourceAbilitySpec> |
DynamicTableSourceSpec.getSourceAbilities() |
Constructor and Description |
---|
DynamicTableSourceSpec(ContextResolvedTable contextResolvedTable,
List<SourceAbilitySpec> sourceAbilities) |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.