You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tw...@apache.org on 2020/04/20 10:13:01 UTC
[flink] branch master updated (fa816c5 -> 691fed1)

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