You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by lz...@apache.org on 2020/05/15 09:08:31 UTC
[flink] branch master updated (bff623a -> 3e820a6)

This is an automated email from the ASF dual-hosted git repository.

lzljs3620320 pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from bff623a  [FLINK-17701][build] Exclude transitive jdk:tools dependency from all Hadoop dependencies.
     add 3e820a6  [FLINK-17664][table] Introduce print, blackhole connector in table

No new revisions were added by this update.

Summary of changes:
 .../table/factories/BlackHoleTableSinkFactory.java |  91 +++++++++++
 .../DataGenTableSourceFactory.java                 |  92 +++++++++++-
 .../table/factories/PrintTableSinkFactory.java     | 166 +++++++++++++++++++++
 .../table/sources/datagen/DataGenTableSource.java  | 108 --------------
 .../org.apache.flink.table.factories.Factory       |   4 +-
 .../table/factories/BlackHoleSinkFactoryTest.java} |  50 ++++---
 .../factories/DataGenTableSourceFactoryTest.java   |  23 ++-
 .../table/factories/PrintSinkFactoryTest.java      |  63 ++++++++
 .../stream/table/BlackHoleConnectorITCase.java     |  28 ++--
 .../runtime/stream/table/PrintConnectorITCase.java | 137 +++++++++++++++++
 10 files changed, 599 insertions(+), 163 deletions(-)
 create mode 100644 flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/factories/BlackHoleTableSinkFactory.java
 rename flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/{sources/datagen => factories}/DataGenTableSourceFactory.java (74%)
 create mode 100644 flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/factories/PrintTableSinkFactory.java
 delete mode 100644 flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/sources/datagen/DataGenTableSource.java
 copy flink-table/{flink-table-api-java/src/test/java/org/apache/flink/table/descriptors/ConnectTableDescriptorTest.java => flink-table-api-java-bridge/src/test/java/org/apache/flink/table/factories/BlackHoleSinkFactoryTest.java} (50%)
 create mode 100644 flink-table/flink-table-api-java-bridge/src/test/java/org/apache/flink/table/factories/PrintSinkFactoryTest.java
 copy flink-core/src/test/java/org/apache/flink/util/IterableUtilsTest.java => flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/runtime/stream/table/BlackHoleConnectorITCase.java (58%)
 create mode 100644 flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/runtime/stream/table/PrintConnectorITCase.java