Skip to content

Commit 336d781

Browse files
committed
correction
1 parent 8849e5d commit 336d781

File tree

1 file changed

+5
-14
lines changed
  • client-v2/src/main/java/com/clickhouse/client/api

1 file changed

+5
-14
lines changed

client-v2/src/main/java/com/clickhouse/client/api/Client.java

Lines changed: 5 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -5,20 +5,16 @@
55
import com.clickhouse.client.api.data_formats.ClickHouseBinaryFormatReader;
66
import com.clickhouse.client.api.data_formats.NativeFormatReader;
77
import com.clickhouse.client.api.data_formats.RowBinaryFormatReader;
8-
import com.clickhouse.client.api.data_formats.RowBinaryFormatSerializer;
98
import com.clickhouse.client.api.data_formats.RowBinaryWithNamesAndTypesFormatReader;
109
import com.clickhouse.client.api.data_formats.RowBinaryWithNamesFormatReader;
1110
import com.clickhouse.client.api.data_formats.internal.BinaryStreamReader;
1211
import com.clickhouse.client.api.data_formats.internal.MapBackedRecord;
1312
import com.clickhouse.client.api.data_formats.internal.ProcessParser;
14-
import com.clickhouse.client.api.data_formats.internal.SerializerUtils;
1513
import com.clickhouse.client.api.enums.Protocol;
1614
import com.clickhouse.client.api.enums.ProxyType;
1715
import com.clickhouse.client.api.http.ClickHouseHttpProto;
18-
import com.clickhouse.client.api.serde.DataSerializationException;
1916
import com.clickhouse.client.api.insert.InsertResponse;
2017
import com.clickhouse.client.api.insert.InsertSettings;
21-
import com.clickhouse.client.api.serde.POJOFieldSerializer;
2218
import com.clickhouse.client.api.internal.ClickHouseLZ4OutputStream;
2319
import com.clickhouse.client.api.internal.ClientStatisticsHolder;
2420
import com.clickhouse.client.api.internal.HttpAPIClientHelper;
@@ -31,13 +27,15 @@
3127
import com.clickhouse.client.api.metrics.ClientMetrics;
3228
import com.clickhouse.client.api.metrics.OperationMetrics;
3329
import com.clickhouse.client.api.query.GenericRecord;
34-
import com.clickhouse.client.api.serde.POJOFieldDeserializer;
3530
import com.clickhouse.client.api.query.QueryResponse;
3631
import com.clickhouse.client.api.query.QuerySettings;
3732
import com.clickhouse.client.api.query.Records;
33+
import com.clickhouse.client.api.serde.DataSerializationException;
34+
import com.clickhouse.client.api.serde.POJOFieldDeserializer;
35+
import com.clickhouse.client.api.serde.POJOFieldSerializer;
36+
import com.clickhouse.client.api.serde.POJOSerDe;
3837
import com.clickhouse.client.api.transport.Endpoint;
3938
import com.clickhouse.client.api.transport.HttpEndpoint;
40-
import com.clickhouse.client.api.serde.POJOSerDe;
4139
import com.clickhouse.client.config.ClickHouseClientOption;
4240
import com.clickhouse.data.ClickHouseColumn;
4341
import com.clickhouse.data.ClickHouseFormat;
@@ -55,7 +53,6 @@
5553
import java.io.InputStream;
5654
import java.io.OutputStream;
5755
import java.lang.reflect.InvocationTargetException;
58-
import java.lang.reflect.Method;
5956
import java.net.URL;
6057
import java.nio.charset.StandardCharsets;
6158
import java.time.Duration;
@@ -125,10 +122,7 @@ public class Client implements AutoCloseable {
125122
private final Map<String, String> configuration;
126123

127124
private final Map<String, String> readOnlyConfig;
128-
129-
// POJO serializer mapping (class -> (schema -> (format -> serializer)))
130-
private final Map<Class<?>, Map<String, Map<String, POJOSerializer>>> serializers;
131-
125+
132126
private final POJOSerDe pojoSerDe;
133127

134128
private final ExecutorService sharedOperationExecutor;
@@ -172,9 +166,6 @@ private Client(Set<String> endpoints, Map<String,String> configuration, boolean
172166
this.sharedOperationExecutor = sharedOperationExecutor;
173167
}
174168

175-
this.columnToMethodMatchingStrategy = columnToMethodMatchingStrategy;
176-
177-
178169
// Transport
179170
ImmutableList.Builder<Endpoint> tmpEndpoints = ImmutableList.builder();
180171
boolean initSslContext = false;

0 commit comments

Comments
 (0)