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