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

Reply via email to