[INLONG-9204][Manager] Add field type for PostgreSQL (#9636)

apache · Jan 31, 2024 · e9aa6e1 · e9aa6e1
1 parent 54d6dda
commit e9aa6e1
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 1 deletion.
diff --git a/...anager/manager-common/src/main/java/org/apache/inlong/manager/common/enums/FieldType.java b/...anager/manager-common/src/main/java/org/apache/inlong/manager/common/enums/FieldType.java
@@ -22,6 +22,7 @@
 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/...r/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sort/util/FieldInfoUtils.java b/...r/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sort/util/FieldInfoUtils.java
@@ -297,6 +297,7 @@ public static FormatInfo convertFieldFormat(String type, String format) {
  formatInfo = new TimeFormatInfo();
  }
  break;
+ case TIMESTAMPTZ:
  case TIMESTAMP:
  case DATETIME:
  if (StringUtils.isNotBlank(format)) {