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/05/18 04:24:01 UTC
[flink] branch master updated (1f668dd -> adfd45f)
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 1f668dd [FLINK-14255][hive] Integrate hive with parquet and orc format to streaming file sink
add adfd45f [FLINK-16999][table] Enable new data structure converters for connectors
No new revisions were added by this update.
Summary of changes:
.../flink/table/connector/RuntimeConverter.java | 18 ++++++++---
.../table/types/inference/TypeTransformations.java | 16 +++++++++-
.../planner/factories/TestValuesTableFactory.java | 2 ++
...per.java => DataStructureConverterWrapper.java} | 24 ++++++++-------
.../connector/sink/SinkRuntimeProviderContext.java | 34 ++++++--------------
...per.java => DataStructureConverterWrapper.java} | 24 ++++++++-------
.../source/LookupRuntimeProviderContext.java | 18 ++++-------
.../source/ScanRuntimeProviderContext.java | 36 ++++++----------------
8 files changed, 82 insertions(+), 90 deletions(-)
rename flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/connector/sink/{DataFormatConverterWrapper.java => DataStructureConverterWrapper.java} (59%)
rename flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/connector/source/{DataFormatConverterWrapper.java => DataStructureConverterWrapper.java} (60%)