From 59b11227df67f5857bc251ae6a9f40e29ec877d7 Mon Sep 17 00:00:00 2001 From: wending <1062698930@qq.com> Date: Tue, 6 Jun 2023 22:30:15 +0800 Subject: [PATCH] [FLINK-32068] connector jdbc support clickhouse --- .../converter/ClickhouseRowConvert.java | 19 ------------------- 1 file changed, 19 deletions(-) delete mode 100644 flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/converter/ClickhouseRowConvert.java diff --git a/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/converter/ClickhouseRowConvert.java b/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/converter/ClickhouseRowConvert.java deleted file mode 100644 index f696111b..00000000 --- a/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/converter/ClickhouseRowConvert.java +++ /dev/null @@ -1,19 +0,0 @@ -package org.apache.flink.connector.jdbc.internal.converter; - -import org.apache.flink.connector.jdbc.converter.AbstractJdbcRowConverter; -import org.apache.flink.table.types.logical.RowType; - -/** */ -public class ClickhouseRowConvert extends AbstractJdbcRowConverter { - - private static final long serialVersionUID = 1L; - - @Override - public String converterName() { - return "Clickhouse"; - } - - public ClickhouseRowConvert(RowType rowType) { - super(rowType); - } -}