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/08/20 02:56:49 UTC

[flink] branch master updated (6ddc9b8 -> b8ee51b)

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 6ddc9b8  [FLINK-18912][python][docs] Add Python api tutorial under Python GettingStart (#13192)
     add b8ee51b  [FLINK-18449][kafka][table] Support topic list and topic pattern and partition discovery for Kafka source in Table API

No new revisions were added by this update.

Summary of changes:
 docs/dev/table/connectors/kafka.md                 |  28 +++-
 docs/dev/table/connectors/kafka.zh.md              |  30 +++-
 .../kafka/table/Kafka010DynamicSource.java         |  28 +++-
 .../kafka/table/Kafka010DynamicTableFactory.java   |  10 +-
 .../table/Kafka010DynamicTableFactoryTest.java     |  10 +-
 .../kafka/table/Kafka011DynamicSource.java         |  28 +++-
 .../kafka/table/Kafka011DynamicTableFactory.java   |  10 +-
 .../table/Kafka011DynamicTableFactoryTest.java     |  10 +-
 .../kafka/table/KafkaDynamicSourceBase.java        |  68 ++++++---
 .../kafka/table/KafkaDynamicTableFactoryBase.java  |  59 +++++---
 .../connectors/kafka/table/KafkaOptions.java       |  81 ++++++++++-
 .../table/KafkaDynamicTableFactoryTestBase.java    | 156 ++++++++++++++++++++-
 .../connectors/kafka/table/KafkaTableTestBase.java |  88 ++++++++++++
 .../connectors/kafka/table/KafkaDynamicSource.java |  28 +++-
 .../kafka/table/KafkaDynamicTableFactory.java      |  10 +-
 .../kafka/table/KafkaDynamicTableFactoryTest.java  |  10 +-
 16 files changed, 564 insertions(+), 90 deletions(-)