Move ClickHouseStatementWrapper to the connection package and format …

…README.md
itinycheng · May 17, 2023 · e2994e1 · e2994e1
1 parent 430e5bf
commit e2994e1
Show file tree

Hide file tree

Showing 7 changed files with 219 additions and 217 deletions.
diff --git a/README.md b/README.md
diff --git a/.../java/org/apache/flink/connector/clickhouse/internal/ClickHouseRowDataLookupFunction.java b/.../java/org/apache/flink/connector/clickhouse/internal/ClickHouseRowDataLookupFunction.java
@@ -2,8 +2,8 @@
 
 import org.apache.flink.annotation.Internal;
 import org.apache.flink.connector.clickhouse.internal.connection.ClickHouseConnectionProvider;
+import org.apache.flink.connector.clickhouse.internal.connection.ClickHouseStatementWrapper;
 import org.apache.flink.connector.clickhouse.internal.converter.ClickHouseRowConverter;
-import org.apache.flink.connector.clickhouse.internal.converter.ClickHouseStatementWrapper;
 import org.apache.flink.connector.clickhouse.internal.options.ClickHouseReadOptions;
 import org.apache.flink.connector.clickhouse.util.ClickHouseUtil;
 import org.apache.flink.table.data.RowData;

diff --git a/...converter/ClickHouseStatementWrapper.java → ...onnection/ClickHouseStatementWrapper.java b/...converter/ClickHouseStatementWrapper.java → ...onnection/ClickHouseStatementWrapper.java
@@ -1,4 +1,4 @@
-package org.apache.flink.connector.clickhouse.internal.converter;
+package org.apache.flink.connector.clickhouse.internal.connection;
 
 import ru.yandex.clickhouse.ClickHousePreparedStatement;
 

diff --git a/...java/org/apache/flink/connector/clickhouse/internal/converter/ClickHouseRowConverter.java b/...java/org/apache/flink/connector/clickhouse/internal/converter/ClickHouseRowConverter.java
@@ -1,5 +1,6 @@
 package org.apache.flink.connector.clickhouse.internal.converter;
 
+import org.apache.flink.connector.clickhouse.internal.connection.ClickHouseStatementWrapper;
 import org.apache.flink.table.data.DecimalData;
 import org.apache.flink.table.data.GenericRowData;
 import org.apache.flink.table.data.RowData;

diff --git a/...java/org/apache/flink/connector/clickhouse/internal/executor/ClickHouseBatchExecutor.java b/...java/org/apache/flink/connector/clickhouse/internal/executor/ClickHouseBatchExecutor.java
@@ -3,8 +3,8 @@
 import org.apache.flink.api.common.functions.RuntimeContext;
 import org.apache.flink.connector.clickhouse.internal.ClickHouseShardOutputFormat;
 import org.apache.flink.connector.clickhouse.internal.connection.ClickHouseConnectionProvider;
+import org.apache.flink.connector.clickhouse.internal.connection.ClickHouseStatementWrapper;
 import org.apache.flink.connector.clickhouse.internal.converter.ClickHouseRowConverter;
-import org.apache.flink.connector.clickhouse.internal.converter.ClickHouseStatementWrapper;
 import org.apache.flink.connector.clickhouse.internal.options.ClickHouseDmlOptions;
 import org.apache.flink.table.data.RowData;
 

diff --git a/...main/java/org/apache/flink/connector/clickhouse/internal/executor/ClickHouseExecutor.java b/...main/java/org/apache/flink/connector/clickhouse/internal/executor/ClickHouseExecutor.java
@@ -3,8 +3,8 @@
 import org.apache.flink.api.common.functions.RuntimeContext;
 import org.apache.flink.connector.clickhouse.internal.ClickHouseStatementFactory;
 import org.apache.flink.connector.clickhouse.internal.connection.ClickHouseConnectionProvider;
+import org.apache.flink.connector.clickhouse.internal.connection.ClickHouseStatementWrapper;
 import org.apache.flink.connector.clickhouse.internal.converter.ClickHouseRowConverter;
-import org.apache.flink.connector.clickhouse.internal.converter.ClickHouseStatementWrapper;
 import org.apache.flink.connector.clickhouse.internal.options.ClickHouseDmlOptions;
 import org.apache.flink.table.data.GenericRowData;
 import org.apache.flink.table.data.RowData;

diff --git a/...ava/org/apache/flink/connector/clickhouse/internal/executor/ClickHouseUpsertExecutor.java b/...ava/org/apache/flink/connector/clickhouse/internal/executor/ClickHouseUpsertExecutor.java
@@ -4,8 +4,8 @@
 import org.apache.flink.connector.clickhouse.config.ClickHouseConfigOptions.SinkUpdateStrategy;
 import org.apache.flink.connector.clickhouse.internal.ClickHouseShardOutputFormat;
 import org.apache.flink.connector.clickhouse.internal.connection.ClickHouseConnectionProvider;
+import org.apache.flink.connector.clickhouse.internal.connection.ClickHouseStatementWrapper;
 import org.apache.flink.connector.clickhouse.internal.converter.ClickHouseRowConverter;
-import org.apache.flink.connector.clickhouse.internal.converter.ClickHouseStatementWrapper;
 import org.apache.flink.connector.clickhouse.internal.options.ClickHouseDmlOptions;
 import org.apache.flink.table.data.RowData;