This is an automated email from the ASF dual-hosted git repository. twalthr pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git.
from fa816c5 [FLINK-15816][k8s] Limit the value of kubernetes.cluster-id to have no more than 45 characters add 691fed1 [FLINK-16992][table-common] Add all ability interfaces for table sourcs and sinks No new revisions were added by this update. Summary of changes: .../PeriodicWatermarkAssignerProvider.java} | 22 ++-- .../PunctuatedWatermarkAssignerProvider.java} | 22 ++-- .../table/connector/sink/DynamicTableSink.java | 5 +- .../sink/abilities/SupportsOverwrite.java | 21 ++-- .../sink/abilities/SupportsPartitioning.java | 117 +++++++++++++++++++++ .../table/connector/source/ScanTableSource.java | 10 ++ .../abilities/SupportsComputedColumnPushDown.java | 24 ++++- .../source/abilities/SupportsFilterPushDown.java | 8 ++ .../source/abilities/SupportsLimitPushDown.java} | 30 +++--- .../abilities/SupportsPartitionPushDown.java | 80 ++++++++++++++ .../abilities/SupportsProjectionPushDown.java | 72 +++++++++++++ .../abilities/SupportsWatermarkPushDown.java | 79 ++++++++++++++ 12 files changed, 424 insertions(+), 66 deletions(-) copy flink-table/{flink-table-common/src/main/java/org/apache/flink/table/connector/sink/OutputFormatProvider.java => flink-table-api-java-bridge/src/main/java/org/apache/flink/table/connector/source/abilities/PeriodicWatermarkAssignerProvider.java} (62%) copy flink-table/{flink-table-common/src/main/java/org/apache/flink/table/connector/sink/OutputFormatProvider.java => flink-table-api-java-bridge/src/main/java/org/apache/flink/table/connector/source/abilities/PunctuatedWatermarkAssignerProvider.java} (62%) copy flink-core/src/main/java/org/apache/flink/util/function/TriConsumer.java => flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/sink/abilities/SupportsOverwrite.java (64%) create mode 100644 flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/sink/abilities/SupportsPartitioning.java copy flink-table/{flink-table-api-java/src/main/java/org/apache/flink/table/api/SqlDialect.java => flink-table-common/src/main/java/org/apache/flink/table/connector/source/abilities/SupportsLimitPushDown.java} (51%) create mode 100644 flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/source/abilities/SupportsPartitionPushDown.java create mode 100644 flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/source/abilities/SupportsProjectionPushDown.java create mode 100644 flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/source/abilities/SupportsWatermarkPushDown.java