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/05/17 13:31:31 UTC
[flink] branch master updated (d3c3909 -> ca46672)
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 d3c3909 [FLINK-17449][sql-parser-hive] Implement ADD/DROP partitions
add 83ae463 [hotfix][table-common] Add validateExcept() to FactoryUtil
add 10a65ed [hotfix][kafka] Make FlinkKafkaConsumerBase#setStartFromTimestamp to be public
add ca46672 [FLINK-17026][kafka] Introduce a new Kafka connect or with new property keys
No new revisions were added by this update.
Summary of changes:
.../flink-connector-kafka-0.10/pom.xml | 17 +
.../connectors/kafka/FlinkKafkaConsumer010.java | 11 -
.../kafka/table/Kafka010DynamicSink.java | 81 +++++
.../kafka/table/Kafka010DynamicSource.java | 98 +++++
.../kafka/table/Kafka010DynamicTableFactory.java | 82 +++++
.../org.apache.flink.table.factories.Factory | 16 +
.../table/Kafka010DynamicTableFactoryTest.java | 93 +++++
.../kafka/{ => table}/Kafka010TableITCase.java | 7 +-
.../flink-connector-kafka-0.11/pom.xml | 9 +
.../kafka/table/Kafka011DynamicSink.java | 82 +++++
.../kafka/table/Kafka011DynamicSource.java | 98 +++++
.../kafka/table/Kafka011DynamicTableFactory.java | 79 +++++
.../org.apache.flink.table.factories.Factory | 16 +
.../table/Kafka011DynamicTableFactoryTest.java | 93 +++++
.../kafka/{ => table}/Kafka011TableITCase.java | 7 +-
.../connectors/kafka/FlinkKafkaConsumerBase.java | 6 +-
.../kafka/table/KafkaDynamicSinkBase.java | 133 +++++++
.../kafka/table/KafkaDynamicSourceBase.java | 214 +++++++++++
.../kafka/table/KafkaDynamicTableFactoryBase.java | 172 +++++++++
.../connectors/kafka/table/KafkaOptions.java | 370 +++++++++++++++++++
.../table/KafkaDynamicTableFactoryTestBase.java | 393 +++++++++++++++++++++
.../kafka/{ => table}/KafkaTableTestBase.java | 142 ++++----
flink-connectors/flink-connector-kafka/pom.xml | 9 +
.../connectors/kafka/FlinkKafkaConsumer.java | 11 -
.../connectors/kafka/table/KafkaDynamicSink.java | 81 +++++
.../connectors/kafka/table/KafkaDynamicSource.java | 95 +++++
.../kafka/table/KafkaDynamicTableFactory.java | 78 ++++
.../org.apache.flink.table.factories.Factory | 16 +
.../kafka/table/KafkaDynamicTableFactoryTest.java | 92 +++++
.../kafka/{ => table}/KafkaTableITCase.java | 7 +-
.../apache/flink/table/factories/FactoryUtil.java | 21 ++
.../flink/table/factories/TestFormatFactory.java | 4 +-
32 files changed, 2537 insertions(+), 96 deletions(-)
create mode 100644 flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/table/Kafka010DynamicSink.java
create mode 100644 flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/table/Kafka010DynamicSource.java
create mode 100644 flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/table/Kafka010DynamicTableFactory.java
create mode 100644 flink-connectors/flink-connector-kafka-0.10/src/main/resources/META-INF/services/org.apache.flink.table.factories.Factory
create mode 100644 flink-connectors/flink-connector-kafka-0.10/src/test/java/org/apache/flink/streaming/connectors/kafka/table/Kafka010DynamicTableFactoryTest.java
rename flink-connectors/flink-connector-kafka-0.10/src/test/java/org/apache/flink/streaming/connectors/kafka/{ => table}/Kafka010TableITCase.java (87%)
create mode 100644 flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/table/Kafka011DynamicSink.java
create mode 100644 flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/table/Kafka011DynamicSource.java
create mode 100644 flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/table/Kafka011DynamicTableFactory.java
create mode 100644 flink-connectors/flink-connector-kafka-0.11/src/main/resources/META-INF/services/org.apache.flink.table.factories.Factory
create mode 100644 flink-connectors/flink-connector-kafka-0.11/src/test/java/org/apache/flink/streaming/connectors/kafka/table/Kafka011DynamicTableFactoryTest.java
rename flink-connectors/flink-connector-kafka-0.11/src/test/java/org/apache/flink/streaming/connectors/kafka/{ => table}/Kafka011TableITCase.java (87%)
create mode 100644 flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSinkBase.java
create mode 100644 flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSourceBase.java
create mode 100644 flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicTableFactoryBase.java
create mode 100644 flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaOptions.java
create mode 100644 flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicTableFactoryTestBase.java
rename flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/{ => table}/KafkaTableTestBase.java (62%)
create mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java
create mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSource.java
create mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicTableFactory.java
create mode 100644 flink-connectors/flink-connector-kafka/src/main/resources/META-INF/services/org.apache.flink.table.factories.Factory
create mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicTableFactoryTest.java
rename flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/{ => table}/KafkaTableITCase.java (87%)