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/09/10 08:25:02 UTC

[flink] branch master updated (da257d0 -> db378c1)

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 da257d0  [FLINK-16905][python] TableEnvironment.from_elements support Expression
     add db378c1  [FLINK-18823][format] Support serialization for debezium-json format

No new revisions were added by this update.

Summary of changes:
 docs/dev/table/connectors/formats/canal.md         |  2 +-
 docs/dev/table/connectors/formats/canal.zh.md      |  2 +-
 docs/dev/table/connectors/formats/debezium.md      |  6 +-
 docs/dev/table/connectors/formats/debezium.zh.md   |  6 +-
 .../DebeziumJsonDeserializationSchema.java         |  2 +-
 .../json/debezium/DebeziumJsonFormatFactory.java   | 23 ++++++-
 .../DebeziumJsonSerializationSchema.java}          | 80 ++++++++++------------
 .../json/canal/CanalJsonSerDeSchemaTest.java       |  2 +-
 .../debezium/DebeziumJsonFormatFactoryTest.java    | 20 +++++-
 ...aTest.java => DebeziumJsonSerDeSchemaTest.java} | 69 ++++++++++++++-----
 10 files changed, 142 insertions(+), 70 deletions(-)
 copy flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/{canal/CanalJsonSerializationSchema.java => debezium/DebeziumJsonSerializationSchema.java} (57%)
 rename flink-formats/flink-json/src/test/java/org/apache/flink/formats/json/debezium/{DebeziumJsonDeserializationSchemaTest.java => DebeziumJsonSerDeSchemaTest.java} (58%)