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
