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/15 15:09:43 UTC
[flink] branch master updated (f9d4428 -> d2b8ebb)

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 f9d4428  [FLINK-17643][tests] Fix LaunchCoordinatorTest instability by completing stubbing
     add 0c038b8  [FLINK-17149][json][debezium] Introduce Debezium format to support reading debezium changelogs
     add d2b8ebb  [FLINK-17150][json][canal] Introduce Canal format to support reading canal changelogs

No new revisions were added by this update.

Summary of changes:
 .../json/canal/CanalJsonDeserializationSchema.java | 188 +++++++++++++++++++++
 .../formats/json/canal/CanalJsonFormatFactory.java | 114 +++++++++++++
 .../DebeziumJsonDeserializationSchema.java         | 186 ++++++++++++++++++++
 .../json/debezium/DebeziumJsonFormatFactory.java   | 126 ++++++++++++++
 .../org.apache.flink.table.factories.Factory       |   2 +
 .../canal/CanalJsonDeserializationSchemaTest.java  | 160 ++++++++++++++++++
 .../json/canal/CanalJsonFormatFactoryTest.java     | 143 ++++++++++++++++
 .../DebeziumJsonDeserializationSchemaTest.java     | 162 ++++++++++++++++++
 .../debezium/DebeziumJsonFormatFactoryTest.java    | 145 ++++++++++++++++
 .../flink-json/src/test/resources/canal-data.txt   |  10 ++
 .../resources/debezium-data-schema-exclude.txt     |  16 ++
 .../resources/debezium-data-schema-include.txt     |  16 ++
 pom.xml                                            |   1 +
 13 files changed, 1269 insertions(+)
 create mode 100644 flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/canal/CanalJsonDeserializationSchema.java
 create mode 100644 flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/canal/CanalJsonFormatFactory.java
 create mode 100644 flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/debezium/DebeziumJsonDeserializationSchema.java
 create mode 100644 flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/debezium/DebeziumJsonFormatFactory.java
 create mode 100644 flink-formats/flink-json/src/test/java/org/apache/flink/formats/json/canal/CanalJsonDeserializationSchemaTest.java
 create mode 100644 flink-formats/flink-json/src/test/java/org/apache/flink/formats/json/canal/CanalJsonFormatFactoryTest.java
 create mode 100644 flink-formats/flink-json/src/test/java/org/apache/flink/formats/json/debezium/DebeziumJsonDeserializationSchemaTest.java
 create mode 100644 flink-formats/flink-json/src/test/java/org/apache/flink/formats/json/debezium/DebeziumJsonFormatFactoryTest.java
 create mode 100644 flink-formats/flink-json/src/test/resources/canal-data.txt
 create mode 100644 flink-formats/flink-json/src/test/resources/debezium-data-schema-exclude.txt
 create mode 100644 flink-formats/flink-json/src/test/resources/debezium-data-schema-include.txt