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 2024/01/31 09:14:03 UTC
(inlong) branch master updated: [INLONG-9204][Manager] Add field type for PostgreSQL (#9636)
This is an automated email from the ASF dual-hosted git repository.
dockerzhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git
The following commit(s) were added to refs/heads/master by this push:
new e9aa6e111a [INLONG-9204][Manager] Add field type for PostgreSQL (#9636)
e9aa6e111a is described below
commit e9aa6e111acdc57e5ac50970235907006c530506
Author: haifxu <xh...@gmail.com>
AuthorDate: Wed Jan 31 17:13:58 2024 +0800
[INLONG-9204][Manager] Add field type for PostgreSQL (#9636)
---
.../java/org/apache/inlong/manager/common/enums/FieldType.java | 8 +++++++-
.../org/apache/inlong/manager/pojo/sort/util/FieldInfoUtils.java | 1 +
2 files changed, 8 insertions(+), 1 deletion(-)
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 79026e88f7..38412c347c 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
@@ -22,6 +22,7 @@ import org.apache.inlong.manager.common.util.Preconditions;
public enum FieldType {
INT,
+ INTEGER,
TINYINT,
SMALLINT,
BIGINT,
@@ -35,6 +36,7 @@ public enum FieldType {
FIXED,
BYTE,
BINARY,
+ CHAR,
VARCHAR,
VARBINARY,
BOOLEAN,
@@ -44,6 +46,8 @@ public enum FieldType {
INT16,
INT32,
INT64,
+ FLOAT4,
+ FLOAT8,
FLOAT32,
FLOAT64,
DATETIME,
@@ -54,7 +58,9 @@ public enum FieldType {
MAP,
STRUCT,
FUNCTION,
- KEYWORD;
+ KEYWORD,
+ LARGEINT,
+ JSON;
public static FieldType forName(String name) {
Preconditions.expectNotBlank(name, ErrorCodeEnum.INVALID_PARAMETER, "FieldType should not be null");
diff --git a/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sort/util/FieldInfoUtils.java b/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sort/util/FieldInfoUtils.java
index f04fabb41a..6e6a0483d2 100644
--- a/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sort/util/FieldInfoUtils.java
+++ b/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sort/util/FieldInfoUtils.java
@@ -297,6 +297,7 @@ public class FieldInfoUtils {
formatInfo = new TimeFormatInfo();
}
break;
+ case TIMESTAMPTZ:
case TIMESTAMP:
case DATETIME:
if (StringUtils.isNotBlank(format)) {