[incubator-inlong] branch master updated (a46ac5a -> 9c259ac)

[do...@apache.org]

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

dockerzhang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-inlong.git.


    from a46ac5a  [INLONG-2483] Manager provide metadata interface to Dataproxy, and Dataproxy dynamically get metadata and MQ config from Manager. (#2493)
     add 9c259ac  [INLONG-2526][Sort] Support serialization and deserialization of debezium-json formatted data (#2584)

No new revisions were added by this update.

Summary of changes:
 ...nInfo.java => DebeziumDeserializationInfo.java} | 58 ++++-------------
 .../deserialization/DeserializationInfo.java       |  1 +
 ...ionInfo.java => DebeziumSerializationInfo.java} | 46 +++++++------
 .../protocol/serialization/SerializationInfo.java  |  2 +
 .../DebeziumDeserializationSchemaBuilder.java      | 73 +++++++++++++++++++++
 .../DeserializationSchemaFactory.java              |  4 ++
 .../CanalSerializationSchemaBuilder.java           | 23 +------
 ...ava => DebeziumSerializationSchemaBuilder.java} | 43 ++++--------
 .../serialization/SerializationSchemaFactory.java  | 22 +++++++
 .../sort/singletenant/flink/utils/CommonUtils.java |  4 +-
 ...nTest.java => DebeziumDeserializationTest.java} | 76 ++++++++++++++--------
 ...st.java => RowToDebeziumJsonKafkaSinkTest.java} | 16 ++---
 12 files changed, 217 insertions(+), 151 deletions(-)
 copy inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/deserialization/{CanalDeserializationInfo.java => DebeziumDeserializationInfo.java} (59%)
 copy inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/serialization/{CanalSerializationInfo.java => DebeziumSerializationInfo.java} (68%)
 create mode 100644 inlong-sort/sort-single-tenant/src/main/java/org/apache/inlong/sort/singletenant/flink/deserialization/DebeziumDeserializationSchemaBuilder.java
 copy inlong-sort/sort-single-tenant/src/main/java/org/apache/inlong/sort/singletenant/flink/serialization/{CanalSerializationSchemaBuilder.java => DebeziumSerializationSchemaBuilder.java} (56%)
 copy inlong-sort/sort-single-tenant/src/test/java/org/apache/inlong/sort/singletenant/flink/deserialization/{JsonDeserializationTest.java => DebeziumDeserializationTest.java} (58%)
 copy inlong-sort/sort-single-tenant/src/test/java/org/apache/inlong/sort/singletenant/flink/kafka/{RowToCanalKafkaSinkTest.java => RowToDebeziumJsonKafkaSinkTest.java} (79%)