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%)
