This is an automated email from the ASF dual-hosted git repository. healchow pushed a commit to branch release-1.2.0 in repository https://gitbox.apache.org/repos/asf/incubator-inlong.git
commit 5afe65654c72d8eb525a75ef152351e674c01141 Author: lucaspeng12138 <[email protected]> AuthorDate: Thu Jun 9 16:57:10 2022 +0800 [INLONG-4607][Manager] Add ClickHouse field types for FormatInfo (#4608) --- .../java/org/apache/inlong/manager/common/enums/FieldType.java | 7 +++++++ .../apache/inlong/manager/service/sort/util/FieldInfoUtils.java | 7 +++++++ 2 files changed, 14 insertions(+) diff --git a/inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/enums/FieldType.java b/inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/enums/FieldType.java index 354f6852a..9264eb0d5 100644 --- a/inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/enums/FieldType.java +++ b/inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/enums/FieldType.java @@ -37,6 +37,13 @@ public enum FieldType { BOOLEAN, DATE, TIME, + INT8, + INT16, + INT32, + INT64, + FLOAT32, + FLOAT64, + DATETIME, TIMESTAMP; public static FieldType forName(String name) { diff --git a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sort/util/FieldInfoUtils.java b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sort/util/FieldInfoUtils.java index 60e735637..0d1073318 100644 --- a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sort/util/FieldInfoUtils.java +++ b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sort/util/FieldInfoUtils.java @@ -163,24 +163,30 @@ public class FieldInfoUtils { case BOOLEAN: formatInfo = new BooleanFormatInfo(); break; + case INT8: case TINYINT: case BYTE: formatInfo = new ByteFormatInfo(); break; + case INT16: case SMALLINT: case SHORT: formatInfo = new ShortFormatInfo(); break; + case INT32: case INT: formatInfo = new IntFormatInfo(); break; + case INT64: case BIGINT: case LONG: formatInfo = new LongFormatInfo(); break; + case FLOAT32: case FLOAT: formatInfo = new FloatFormatInfo(); break; + case FLOAT64: case DOUBLE: formatInfo = new DoubleFormatInfo(); break; @@ -194,6 +200,7 @@ public class FieldInfoUtils { formatInfo = new DateFormatInfo(); } break; + case DATETIME: case TIME: if (StringUtils.isNotBlank(format)) { formatInfo = new TimeFormatInfo(convertToSortFormat(format));
