You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@inlong.apache.org by do...@apache.org on 2022/01/25 09:36:54 UTC
[incubator-inlong] branch master updated (256ebf9 -> 5aca9cd)

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 256ebf9  [INLONG-2297][agent] support audit for source and sink (#2307)
     add 5aca9cd  [INLONG-2322][Feature][InLong-Sort] Support json format for kafka sink (#2325)

No new revisions were added by this update.

Summary of changes:
 inlong-sort/pom.xml                                |  42 +++-
 .../org/apache/inlong/sort/protocol/FieldInfo.java |  19 ++
 .../serialization/JsonSerializationInfo.java       |   8 +
 .../inlong/sort/protocol/sink/KafkaSinkInfo.java   |   6 +-
 .../apache/inlong/sort/protocol/sink/SinkInfo.java |  19 ++
 .../inlong/sort/protocol/ProtocolBaseTest.java     |  64 ++++++
 .../sort/protocol/kafka/KafkaSinkInfoTest.java     |  67 ++++++
 .../serialization/JsonSerializationInfoTest.java}  |  31 ++-
 inlong-sort/sort-formats/format-base/pom.xml       |   2 +-
 .../sort-formats/format-inlongmsg-base/pom.xml     |   2 +-
 inlong-sort/sort-formats/pom.xml                   |  12 --
 inlong-sort/sort-single-tenant/pom.xml             |  23 +++
 .../singletenant/flink/kafka/KafkaSinkBuilder.java |   4 +-
 .../RowSerializationSchemaFactory.java             |  70 +++++++
 .../serialization/SerializationSchemaBuilder.java  |  40 ----
 .../sort/singletenant/flink/utils/CommonUtils.java |  19 ++
 .../flink/kafka/KafkaSinkTestBase.java             | 230 +++++++++++++++++++++
 .../flink/kafka/RowToJsonKafkaSinkTest.java        |  90 ++++++++
 .../flink/kafka/RowToStringKafkaSinkTest.java      |  73 +++++++
 .../singletenant/flink/utils/CommonUtilsTest.java  |  46 +++++
 .../src/test/resources/log4j-test.properties       |  18 +-
 21 files changed, 801 insertions(+), 84 deletions(-)
 create mode 100644 inlong-sort/sort-common/src/test/java/org/apache/inlong/sort/protocol/ProtocolBaseTest.java
 create mode 100644 inlong-sort/sort-common/src/test/java/org/apache/inlong/sort/protocol/kafka/KafkaSinkInfoTest.java
 copy inlong-sort/{sort-formats/format-common/src/test/java/org/apache/inlong/sort/formats/common/StringFormatInfoTest.java => sort-common/src/test/java/org/apache/inlong/sort/protocol/serialization/JsonSerializationInfoTest.java} (60%)
 create mode 100644 inlong-sort/sort-single-tenant/src/main/java/org/apache/inlong/sort/singletenant/flink/serialization/RowSerializationSchemaFactory.java
 delete mode 100644 inlong-sort/sort-single-tenant/src/main/java/org/apache/inlong/sort/singletenant/flink/serialization/SerializationSchemaBuilder.java
 create mode 100644 inlong-sort/sort-single-tenant/src/test/java/org/apache/inlong/sort/singletenant/flink/kafka/KafkaSinkTestBase.java
 create mode 100644 inlong-sort/sort-single-tenant/src/test/java/org/apache/inlong/sort/singletenant/flink/kafka/RowToJsonKafkaSinkTest.java
 create mode 100644 inlong-sort/sort-single-tenant/src/test/java/org/apache/inlong/sort/singletenant/flink/kafka/RowToStringKafkaSinkTest.java
 create mode 100644 inlong-sort/sort-single-tenant/src/test/java/org/apache/inlong/sort/singletenant/flink/utils/CommonUtilsTest.java
 copy inlong-tubemq/tubemq-client/src/test/resources/log4j.properties => inlong-sort/sort-single-tenant/src/test/resources/log4j-test.properties (54%)