You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ja...@apache.org on 2020/06/01 02:38:21 UTC
[flink] branch release-1.11 updated (cae8f46 -> 5b98a9e)
This is an automated email from the ASF dual-hosted git repository.
jark pushed a change to branch release-1.11
in repository https://gitbox.apache.org/repos/asf/flink.git.
from cae8f46 [hotfix][table] Use AbstractDataType in fromValues()
add 5b98a9e [FLINK-17887][table][connector] Improve interface of ScanFormatFactory and SinkFormatFactory
No new revisions were added by this update.
Summary of changes:
.../table/Elasticsearch6DynamicSink.java | 10 ++--
.../table/Elasticsearch6DynamicSinkFactory.java | 4 +-
.../table/Elasticsearch6DynamicSinkTest.java | 8 ++--
.../table/Elasticsearch7DynamicSink.java | 10 ++--
.../table/Elasticsearch7DynamicSinkFactory.java | 4 +-
.../table/Elasticsearch7DynamicSinkTest.java | 8 ++--
.../hbase/source/HBaseDynamicTableSource.java | 4 +-
.../jdbc/table/JdbcDynamicTableSource.java | 4 +-
.../kafka/table/Kafka010DynamicSink.java | 8 ++--
.../kafka/table/Kafka010DynamicSource.java | 10 ++--
.../kafka/table/Kafka010DynamicTableFactory.java | 12 ++---
.../table/Kafka010DynamicTableFactoryTest.java | 12 ++---
.../kafka/table/Kafka011DynamicSink.java | 8 ++--
.../kafka/table/Kafka011DynamicSource.java | 10 ++--
.../kafka/table/Kafka011DynamicTableFactory.java | 12 ++---
.../table/Kafka011DynamicTableFactoryTest.java | 12 ++---
.../kafka/table/KafkaDynamicSinkBase.java | 16 +++----
.../kafka/table/KafkaDynamicSourceBase.java | 22 ++++-----
.../kafka/table/KafkaDynamicTableFactoryBase.java | 20 ++++----
.../table/KafkaDynamicTableFactoryTestBase.java | 22 ++++-----
.../connectors/kafka/table/KafkaDynamicSink.java | 8 ++--
.../connectors/kafka/table/KafkaDynamicSource.java | 10 ++--
.../kafka/table/KafkaDynamicTableFactory.java | 12 ++---
.../kafka/table/KafkaDynamicTableFactoryTest.java | 12 ++---
.../flink/formats/avro/AvroFormatFactory.java | 22 ++++-----
.../flink/formats/avro/AvroFormatFactoryTest.java | 8 ++--
.../apache/flink/formats/csv/CsvFormatFactory.java | 22 ++++-----
.../flink/formats/csv/CsvFormatFactoryTest.java | 12 ++---
.../flink/formats/json/JsonFormatFactory.java | 22 ++++-----
.../formats/json/canal/CanalJsonFormatFactory.java | 15 +++---
.../json/debezium/DebeziumJsonFormatFactory.java | 15 +++---
.../flink/formats/json/JsonFormatFactoryTest.java | 8 ++--
.../json/canal/CanalJsonFormatFactoryTest.java | 4 +-
.../debezium/DebeziumJsonFormatFactoryTest.java | 4 +-
.../table/factories/DataGenTableSourceFactory.java | 2 +-
.../{ScanFormat.java => DecodingFormat.java} | 10 ++--
.../{SinkFormat.java => EncodingFormat.java} | 8 ++--
.../flink/table/connector/format/Format.java | 8 ++--
.../table/connector/source/DynamicTableSource.java | 38 +++++++++++++++
.../table/connector/source/LookupTableSource.java | 27 +++--------
.../table/connector/source/ScanTableSource.java | 36 +++------------
...rmatFactory.java => DecodingFormatFactory.java} | 9 ++--
.../factories/DeserializationFormatFactory.java | 6 +--
...rmatFactory.java => EncodingFormatFactory.java} | 10 ++--
.../apache/flink/table/factories/FactoryUtil.java | 28 +++++------
.../factories/SerializationFormatFactory.java | 6 +--
.../flink/table/factories/FactoryUtilTest.java | 24 +++++-----
.../table/factories/TestDynamicTableFactory.java | 54 +++++++++++-----------
.../flink/table/factories/TestFormatFactory.java | 36 +++++++--------
.../planner/factories/TestValuesTableFactory.java | 8 ++--
.../source/LookupRuntimeProviderContext.java | 15 +++++-
.../source/ScanRuntimeProviderContext.java | 2 +-
52 files changed, 366 insertions(+), 351 deletions(-)
rename flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/format/{ScanFormat.java => DecodingFormat.java} (73%)
rename flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/format/{SinkFormat.java => EncodingFormat.java} (78%)
rename flink-table/flink-table-common/src/main/java/org/apache/flink/table/factories/{ScanFormatFactory.java => DecodingFormatFactory.java} (81%)
rename flink-table/flink-table-common/src/main/java/org/apache/flink/table/factories/{SinkFormatFactory.java => EncodingFormatFactory.java} (82%)