From 32dcc771c1c2a53f14602537e38f7922ca620d8c Mon Sep 17 00:00:00 2001 From: xiaoyou201 Date: Tue, 13 Aug 2024 19:05:52 +0800 Subject: [PATCH] [INLONG-10784][Sort] fix format --- .../formats/inlongmsgcsv/InLongMsgCsvFormatDeserializer.java | 2 +- .../sort/formats/inlongmsgkv/InLongMsgKvFormatDeserializer.java | 2 +- .../inlongmsgtlogcsv/InLongMsgTlogCsvFormatDeserializer.java | 2 +- .../inlongmsgtlogkv/InLongMsgTlogKvFormatDeserializer.java | 2 +- 4 files changed, 4 insertions(+), 4 deletions(-) diff --git a/inlong-sort/sort-formats/format-rowdata/format-inlongmsg-rowdata-csv/src/main/java/org/apache/inlong/sort/formats/inlongmsgcsv/InLongMsgCsvFormatDeserializer.java b/inlong-sort/sort-formats/format-rowdata/format-inlongmsg-rowdata-csv/src/main/java/org/apache/inlong/sort/formats/inlongmsgcsv/InLongMsgCsvFormatDeserializer.java index a637a5df00c..5b525e93e52 100644 --- a/inlong-sort/sort-formats/format-rowdata/format-inlongmsg-rowdata-csv/src/main/java/org/apache/inlong/sort/formats/inlongmsgcsv/InLongMsgCsvFormatDeserializer.java +++ b/inlong-sort/sort-formats/format-rowdata/format-inlongmsg-rowdata-csv/src/main/java/org/apache/inlong/sort/formats/inlongmsgcsv/InLongMsgCsvFormatDeserializer.java @@ -22,10 +22,10 @@ import org.apache.inlong.sort.formats.base.FieldToRowDataConverters.FieldToRowDataConverter; import org.apache.inlong.sort.formats.base.TableFormatUtils; import org.apache.inlong.sort.formats.base.TextFormatBuilder; -import org.apache.inlong.sort.formats.inlongmsg.rowdata.AbstractInLongMsgFormatDeserializer; import org.apache.inlong.sort.formats.inlongmsg.FailureHandler; import org.apache.inlong.sort.formats.inlongmsg.InLongMsgBody; import org.apache.inlong.sort.formats.inlongmsg.InLongMsgHead; +import org.apache.inlong.sort.formats.inlongmsg.rowdata.AbstractInLongMsgFormatDeserializer; import org.apache.inlong.sort.formats.inlongmsg.rowdata.InLongMsgUtils; import org.apache.flink.api.common.typeinfo.TypeInformation; diff --git a/inlong-sort/sort-formats/format-rowdata/format-inlongmsg-rowdata-kv/src/main/java/org/apache/inlong/sort/formats/inlongmsgkv/InLongMsgKvFormatDeserializer.java b/inlong-sort/sort-formats/format-rowdata/format-inlongmsg-rowdata-kv/src/main/java/org/apache/inlong/sort/formats/inlongmsgkv/InLongMsgKvFormatDeserializer.java index 770822aceb3..7524abd8ab5 100644 --- a/inlong-sort/sort-formats/format-rowdata/format-inlongmsg-rowdata-kv/src/main/java/org/apache/inlong/sort/formats/inlongmsgkv/InLongMsgKvFormatDeserializer.java +++ b/inlong-sort/sort-formats/format-rowdata/format-inlongmsg-rowdata-kv/src/main/java/org/apache/inlong/sort/formats/inlongmsgkv/InLongMsgKvFormatDeserializer.java @@ -22,10 +22,10 @@ import org.apache.inlong.sort.formats.base.FieldToRowDataConverters.FieldToRowDataConverter; import org.apache.inlong.sort.formats.base.TableFormatUtils; import org.apache.inlong.sort.formats.base.TextFormatBuilder; -import org.apache.inlong.sort.formats.inlongmsg.rowdata.AbstractInLongMsgFormatDeserializer; import org.apache.inlong.sort.formats.inlongmsg.FailureHandler; import org.apache.inlong.sort.formats.inlongmsg.InLongMsgBody; import org.apache.inlong.sort.formats.inlongmsg.InLongMsgHead; +import org.apache.inlong.sort.formats.inlongmsg.rowdata.AbstractInLongMsgFormatDeserializer; import org.apache.inlong.sort.formats.inlongmsg.rowdata.InLongMsgUtils; import org.apache.flink.api.common.typeinfo.TypeInformation; diff --git a/inlong-sort/sort-formats/format-rowdata/format-inlongmsg-rowdata-tlogcsv/src/main/java/org/apache/inlong/sort/formats/inlongmsgtlogcsv/InLongMsgTlogCsvFormatDeserializer.java b/inlong-sort/sort-formats/format-rowdata/format-inlongmsg-rowdata-tlogcsv/src/main/java/org/apache/inlong/sort/formats/inlongmsgtlogcsv/InLongMsgTlogCsvFormatDeserializer.java index 111d69ca03f..112cce24a9f 100644 --- a/inlong-sort/sort-formats/format-rowdata/format-inlongmsg-rowdata-tlogcsv/src/main/java/org/apache/inlong/sort/formats/inlongmsgtlogcsv/InLongMsgTlogCsvFormatDeserializer.java +++ b/inlong-sort/sort-formats/format-rowdata/format-inlongmsg-rowdata-tlogcsv/src/main/java/org/apache/inlong/sort/formats/inlongmsgtlogcsv/InLongMsgTlogCsvFormatDeserializer.java @@ -22,10 +22,10 @@ import org.apache.inlong.sort.formats.base.FieldToRowDataConverters.FieldToRowDataConverter; import org.apache.inlong.sort.formats.base.TableFormatUtils; import org.apache.inlong.sort.formats.base.TextFormatBuilder; -import org.apache.inlong.sort.formats.inlongmsg.rowdata.AbstractInLongMsgFormatDeserializer; import org.apache.inlong.sort.formats.inlongmsg.FailureHandler; import org.apache.inlong.sort.formats.inlongmsg.InLongMsgBody; import org.apache.inlong.sort.formats.inlongmsg.InLongMsgHead; +import org.apache.inlong.sort.formats.inlongmsg.rowdata.AbstractInLongMsgFormatDeserializer; import org.apache.inlong.sort.formats.inlongmsg.rowdata.InLongMsgUtils; import org.apache.flink.api.common.typeinfo.TypeInformation; diff --git a/inlong-sort/sort-formats/format-rowdata/format-inlongmsg-rowdata-tlogkv/src/main/java/org/apache/inlong/sort/formats/inlongmsgtlogkv/InLongMsgTlogKvFormatDeserializer.java b/inlong-sort/sort-formats/format-rowdata/format-inlongmsg-rowdata-tlogkv/src/main/java/org/apache/inlong/sort/formats/inlongmsgtlogkv/InLongMsgTlogKvFormatDeserializer.java index b9bc4c67c56..aeef94b2bd8 100644 --- a/inlong-sort/sort-formats/format-rowdata/format-inlongmsg-rowdata-tlogkv/src/main/java/org/apache/inlong/sort/formats/inlongmsgtlogkv/InLongMsgTlogKvFormatDeserializer.java +++ b/inlong-sort/sort-formats/format-rowdata/format-inlongmsg-rowdata-tlogkv/src/main/java/org/apache/inlong/sort/formats/inlongmsgtlogkv/InLongMsgTlogKvFormatDeserializer.java @@ -22,10 +22,10 @@ import org.apache.inlong.sort.formats.base.FieldToRowDataConverters.FieldToRowDataConverter; import org.apache.inlong.sort.formats.base.TableFormatUtils; import org.apache.inlong.sort.formats.base.TextFormatBuilder; -import org.apache.inlong.sort.formats.inlongmsg.rowdata.AbstractInLongMsgFormatDeserializer; import org.apache.inlong.sort.formats.inlongmsg.FailureHandler; import org.apache.inlong.sort.formats.inlongmsg.InLongMsgBody; import org.apache.inlong.sort.formats.inlongmsg.InLongMsgHead; +import org.apache.inlong.sort.formats.inlongmsg.rowdata.AbstractInLongMsgFormatDeserializer; import org.apache.inlong.sort.formats.inlongmsg.rowdata.InLongMsgUtils; import org.apache.flink.api.common.typeinfo.TypeInformation;