You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@inlong.apache.org by he...@apache.org on 2022/06/09 08:57:15 UTC
[incubator-inlong] branch master updated: [INLONG-4607][Manager] Add ClickHouse field types for FormatInfo (#4608)
This is an automated email from the ASF dual-hosted git repository.
healchow pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-inlong.git
The following commit(s) were added to refs/heads/master by this push:
new 738106578 [INLONG-4607][Manager] Add ClickHouse field types for FormatInfo (#4608)
738106578 is described below
commit 7381065787b5380f2b5555cb2316bb5a6a8ac838
Author: lucaspeng12138 <10...@users.noreply.github.com>
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));