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/09/22 09:00:05 UTC
[flink] branch master updated (5c7b5d9 -> 048c89a)
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 5c7b5d9 [FLINK-19186][python] Add Python building blocks to make sure the basic functionality of Pandas Batch Group Aggregation could work
add 048c89a [FLINK-19272][table-common] Add metadata interfaces for FLIP-107
No new revisions were added by this update.
Summary of changes:
.../table/connector/format/DecodingFormat.java | 36 ++++++
.../table/connector/format/EncodingFormat.java | 36 ++++++
.../table/connector/sink/DynamicTableSink.java | 2 +
.../sink/abilities/SupportsWritingMetadata.java | 119 +++++++++++++++++++
.../table/connector/source/ScanTableSource.java | 2 +
.../source/abilities/SupportsReadingMetadata.java | 127 +++++++++++++++++++++
6 files changed, 322 insertions(+)
create mode 100644 flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/sink/abilities/SupportsWritingMetadata.java
create mode 100644 flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/source/abilities/SupportsReadingMetadata.java