You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@seatunnel.apache.org by ga...@apache.org on 2022/10/16 14:20:20 UTC
[incubator-seatunnel] branch dev updated: [Improve] [Clickhouse-V2] Clickhouse Support Int128,Int256 Type (#3067)
This is an automated email from the ASF dual-hosted git repository.
gaojun2048 pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git
The following commit(s) were added to refs/heads/dev by this push:
new e118ccea0 [Improve] [Clickhouse-V2] Clickhouse Support Int128,Int256 Type (#3067)
e118ccea0 is described below
commit e118ccea0a30b7d9bfbeaa2523b43af5ff2e71d3
Author: lambin <54...@qq.com>
AuthorDate: Sun Oct 16 22:20:13 2022 +0800
[Improve] [Clickhouse-V2] Clickhouse Support Int128,Int256 Type (#3067)
* [Improve] [Clickhouse-V2] Clickhouse Support Int128,Int256 Type
---
.../seatunnel/clickhouse/sink/inject/StringInjectFunction.java | 6 +++++-
.../connectors/seatunnel/clickhouse/util/TypeConvertUtil.java | 3 +++
2 files changed, 8 insertions(+), 1 deletion(-)
diff --git a/seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/inject/StringInjectFunction.java b/seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/inject/StringInjectFunction.java
index 4894774dc..4728fe216 100644
--- a/seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/inject/StringInjectFunction.java
+++ b/seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/inject/StringInjectFunction.java
@@ -29,6 +29,10 @@ public class StringInjectFunction implements ClickhouseFieldInjectFunction {
@Override
public boolean isCurrentFieldType(String fieldType) {
- return "String".equals(fieldType);
+ return "String".equals(fieldType)
+ || "Int128".equals(fieldType)
+ || "UInt128".equals(fieldType)
+ || "Int256".equals(fieldType)
+ || "UInt256".equals(fieldType);
}
}
diff --git a/seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/util/TypeConvertUtil.java b/seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/util/TypeConvertUtil.java
index 323df2c3b..0ccad51c9 100644
--- a/seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/util/TypeConvertUtil.java
+++ b/seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/util/TypeConvertUtil.java
@@ -28,6 +28,7 @@ import com.clickhouse.client.ClickHouseColumn;
import com.clickhouse.client.ClickHouseValue;
import java.math.BigDecimal;
+import java.math.BigInteger;
import java.net.Inet4Address;
import java.net.Inet6Address;
import java.time.LocalDate;
@@ -71,6 +72,8 @@ public class TypeConvertUtil {
return BasicType.STRING_TYPE;
} else if (Object.class.equals(type)) {
return BasicType.STRING_TYPE;
+ } else if (BigInteger.class.equals(type)) {
+ return BasicType.STRING_TYPE;
} else {
// TODO support pojo
throw new IllegalArgumentException("not supported data type: " + column.getDataType());