diff options
| author | lifengchao <[email protected]> | 2024-04-08 11:18:30 +0800 |
|---|---|---|
| committer | lifengchao <[email protected]> | 2024-04-08 11:18:30 +0800 |
| commit | 54aa02f7b873580b282af1b1d0aab39ab5ebbb19 (patch) | |
| tree | 39a6cfcc315c95a5d463abb6bee95781327ef8e4 | |
| parent | 943550db229ca3a14f14a54d52b862433093d650 (diff) | |
[improve][connector-clickhouse] CN-1622 Clickhouse Sink兼容AggregateFunction
| -rw-r--r-- | groot-connectors/connector-clickhouse/src/main/java/com/geedgenetworks/connectors/clickhouse/util/ClickHouseUtils.java | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/groot-connectors/connector-clickhouse/src/main/java/com/geedgenetworks/connectors/clickhouse/util/ClickHouseUtils.java b/groot-connectors/connector-clickhouse/src/main/java/com/geedgenetworks/connectors/clickhouse/util/ClickHouseUtils.java index 4a35878..8efc7d0 100644 --- a/groot-connectors/connector-clickhouse/src/main/java/com/geedgenetworks/connectors/clickhouse/util/ClickHouseUtils.java +++ b/groot-connectors/connector-clickhouse/src/main/java/com/geedgenetworks/connectors/clickhouse/util/ClickHouseUtils.java @@ -112,10 +112,11 @@ public class ClickHouseUtils { if ("LowCardinality(String)".equals(typeStr)) {
typeStr = "String";
}
- IDataType<?, ?> type = DataTypeFactory.get(typeStr, connection.serverContext());
if ("MATERIALIZED".equals(defaultTypeStr)) {
continue;
}
+ IDataType<?, ?> type = DataTypeFactory.get(typeStr, connection.serverContext());
+
Object defaultValue = parseDefaultValue(type, defaultExpression); // 只解析数字和字符串
if (defaultValue == null && !type.nullable()) {
if (type instanceof DataTypeArray) {
|