This is an automated email from the ASF dual-hosted git repository.
jark pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 2dc872a [FLINK-19235][python] Support mixed use of built-in aggs with
Python UDAF
add 3bf5786 [FLINK-19824][table-api] Refactor and merge
SupportsComputedColumnPushDown and SupportsWatermarkPushDown interfaces
No new revisions were added by this update.
Summary of changes:
.../PeriodicWatermarkAssignerProvider.java | 34 -------
.../PunctuatedWatermarkAssignerProvider.java | 34 -------
.../table/connector/source/DynamicTableSource.java | 4 +-
.../table/connector/source/ScanTableSource.java | 2 -
.../abilities/SupportsComputedColumnPushDown.java | 102 ---------------------
.../abilities/SupportsProjectionPushDown.java | 4 -
.../abilities/SupportsWatermarkPushDown.java | 53 +++++------
.../table/planner/sources/DynamicSourceUtils.java | 5 +-
8 files changed, 25 insertions(+), 213 deletions(-)
delete mode 100644
flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/connector/source/abilities/PeriodicWatermarkAssignerProvider.java
delete mode 100644
flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/connector/source/abilities/PunctuatedWatermarkAssignerProvider.java
delete mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/source/abilities/SupportsComputedColumnPushDown.java
