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 61b1106 [FLINK-18922][python][docs] Add "Catalogs" under the "Python
API" -> "User Guide" -> "Table API" section
add 9cc5e07 [FLINK-19858][upsert-kafka] Introduce the upsert-kafka table
factory
add 37fe824 [hotfix][kafka] Disallow primary key on insert-only kafka
table
add f504bf5 [hotfix][upsert-kafka] Support sink parallelism on
upsert-kafka sink
No new revisions were added by this update.
Summary of changes:
.../table/DynamicKafkaDeserializationSchema.java | 52 +-
.../table/DynamicKafkaSerializationSchema.java | 28 +-
.../connectors/kafka/table/KafkaDynamicSink.java | 25 +-
.../connectors/kafka/table/KafkaDynamicSource.java | 19 +-
.../kafka/table/KafkaDynamicTableFactory.java | 25 +-
.../table/UpsertKafkaDynamicTableFactory.java | 338 +++++++++++++
.../org.apache.flink.table.factories.Factory | 1 +
.../kafka/table/KafkaChangelogTableITCase.java | 39 +-
.../kafka/table/KafkaDynamicTableFactoryTest.java | 124 +++--
.../connectors/kafka/table/KafkaTableITCase.java | 24 +-
.../kafka/table/KafkaTableTestUtils.java | 113 +++++
.../table/UpsertKafkaDynamicTableFactoryTest.java | 425 ++++++++++++++++
.../kafka/table/UpsertKafkaTableITCase.java | 540 +++++++++++++++++++++
.../flink/table/factories/FactoryUtilTest.java | 2 +
.../flink/table/factories/TestFormatFactory.java | 90 +++-
15 files changed, 1726 insertions(+), 119 deletions(-)
create mode 100644
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/UpsertKafkaDynamicTableFactory.java
create mode 100644
flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/table/KafkaTableTestUtils.java
create mode 100644
flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/table/UpsertKafkaDynamicTableFactoryTest.java
create mode 100644
flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/table/UpsertKafkaTableITCase.java
