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%)