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/01 05:31:55 UTC

[flink] branch master updated (fe867a6 -> 853e190)

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 fe867a6  [FLINK-18977][datastream] Extract WindowOperator construction into a builder class
     add 853e190  [FLINK-18824][json][table] Support serialization for canal-json format

No new revisions were added by this update.

Summary of changes:
 docs/dev/table/connectors/formats/canal.md         |  8 ++-
 docs/dev/table/connectors/formats/canal.zh.md      |  6 +-
 .../formats/json/canal/CanalJsonFormatFactory.java | 26 ++++++++-
 .../CanalJsonSerializationSchema.java}             | 67 ++++++++++++----------
 .../json/canal/CanalJsonFormatFactoryTest.java     | 61 +++++++++++++-------
 ...hemaTest.java => CanalJsonSerDeSchemaTest.java} | 56 ++++++++++++++++--
 6 files changed, 163 insertions(+), 61 deletions(-)
 copy flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/{maxwell/MaxwellJsonSerializationSchema.java => canal/CanalJsonSerializationSchema.java} (58%)
 rename flink-formats/flink-json/src/test/java/org/apache/flink/formats/json/canal/{CanalJsonDeserializationSchemaTest.java => CanalJsonSerDeSchemaTest.java} (57%)