This is an automated email from the ASF dual-hosted git repository.
jark pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from dc0c5b5 [FLINK-19235][python] Support mixed use with most built-in
aggs for Python UDAF
add e90f2b1 [hotfix][table-common] Add ChangelogMode.toString()
add 4fa58f3 [hotfix][core] Add Configuration.fromMap
add 59d2a2d [FLINK-19294][connector-kafka] Support key/value formats in
Kafka table source and sinks
No new revisions were added by this update.
Summary of changes:
.../table/DynamicKafkaDeserializationSchema.java | 139 ++++--
.../table/DynamicKafkaSerializationSchema.java | 81 ++--
.../connectors/kafka/table/KafkaDynamicSink.java | 125 ++++--
.../connectors/kafka/table/KafkaDynamicSource.java | 110 ++++-
.../kafka/table/KafkaDynamicTableFactory.java | 155 +++++--
.../connectors/kafka/table/KafkaOptions.java | 183 ++++++++
.../kafka/table/KafkaDynamicTableFactoryTest.java | 477 +++++++++++----------
.../connectors/kafka/table/KafkaOptionsTest.java | 182 ++++++++
.../connectors/kafka/table/KafkaTableITCase.java | 140 ++++++
.../apache/flink/configuration/Configuration.java | 11 +
.../configuration/DelegatingConfigurationTest.java | 6 +-
.../flink/table/connector/ChangelogMode.java | 5 +
.../apache/flink/table/factories/FactoryUtil.java | 79 ++--
.../types/logical/utils/LogicalTypeUtils.java | 21 +
.../flink/table/types/utils/DataTypeUtils.java | 39 +-
.../table/factories/TestDynamicTableFactory.java | 13 +-
.../flink/table/factories/TestFormatFactory.java | 25 +-
17 files changed, 1368 insertions(+), 423 deletions(-)
create mode 100644
flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/table/KafkaOptionsTest.java
