| Interface | Description |
|---|---|
| SourceAbilitySpec |
An interface that can not only serialize/deserialize the source abilities to/from JSON, but also
can apply the abilities to a
DynamicTableSource. |
| Class | Description |
|---|---|
| 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. |
| 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. |
| 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. |
| 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. |
| 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. |
| 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. |
| SourceAbilityContext |
A sub-class of
FlinkContext which contains the information for SourceAbilitySpec
to apply the following abilities to DynamicTableSource. |
| SourceAbilitySpecBase |
Base class for
SourceAbilitySpec. |
| 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. |
| 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. |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.