Skip to content

Commit 70d46a1

Browse files
simenliuxingsimenliuxing
committed
import Collections
1 parent 7610562 commit 70d46a1

6 files changed

Lines changed: 25 additions & 53 deletions

File tree

‎cassandra/cassandra-side/cassandra-async-side/src/main/java/com/dtstack/flink/sql/side/cassandra/CassandraAsyncReqRow.java‎

Lines changed: 9 additions & 23 deletions
Original file line numberDiff line numberDiff line change
@@ -19,46 +19,32 @@
1919

2020
package com.dtstack.flink.sql.side.cassandra;
2121

22-
import com.dtstack.flink.sql.util.RowDataComplete;
23-
import org.apache.flink.api.java.tuple.Tuple2;
24-
import org.apache.flink.api.java.typeutils.RowTypeInfo;
25-
import org.apache.flink.configuration.Configuration;
26-
import org.apache.flink.streaming.api.functions.async.ResultFuture;
27-
import org.apache.flink.table.dataformat.BaseRow;
28-
import org.apache.flink.types.Row;
29-
30-
import com.datastax.driver.core.Cluster;
31-
import com.datastax.driver.core.ConsistencyLevel;
32-
import com.datastax.driver.core.HostDistance;
33-
import com.datastax.driver.core.PoolingOptions;
34-
import com.datastax.driver.core.QueryOptions;
35-
import com.datastax.driver.core.ResultSet;
36-
import com.datastax.driver.core.Session;
37-
import com.datastax.driver.core.SocketOptions;
22+
import com.datastax.driver.core.*;
3823
import com.datastax.driver.core.policies.DowngradingConsistencyRetryPolicy;
3924
import com.datastax.driver.core.policies.RetryPolicy;
4025
import com.dtstack.flink.sql.enums.ECacheContentType;
41-
import com.dtstack.flink.sql.side.BaseAsyncReqRow;
42-
import com.dtstack.flink.sql.side.CacheMissVal;
43-
import com.dtstack.flink.sql.side.FieldInfo;
44-
import com.dtstack.flink.sql.side.JoinInfo;
45-
import com.dtstack.flink.sql.side.AbstractSideTableInfo;
26+
import com.dtstack.flink.sql.side.*;
4627
import com.dtstack.flink.sql.side.cache.CacheObj;
4728
import com.dtstack.flink.sql.side.cassandra.table.CassandraSideTableInfo;
29+
import com.dtstack.flink.sql.util.RowDataComplete;
4830
import com.google.common.base.Function;
4931
import com.google.common.collect.Lists;
5032
import com.google.common.util.concurrent.AsyncFunction;
5133
import com.google.common.util.concurrent.FutureCallback;
5234
import com.google.common.util.concurrent.Futures;
5335
import com.google.common.util.concurrent.ListenableFuture;
54-
import io.vertx.core.json.JsonArray;
5536
import org.apache.commons.lang3.StringUtils;
37+
import org.apache.flink.api.java.typeutils.RowTypeInfo;
38+
import org.apache.flink.configuration.Configuration;
39+
import org.apache.flink.streaming.api.functions.async.ResultFuture;
40+
import org.apache.flink.table.dataformat.BaseRow;
41+
import org.apache.flink.types.Row;
5642
import org.slf4j.Logger;
5743
import org.slf4j.LoggerFactory;
5844

5945
import java.net.InetAddress;
60-
import java.sql.Timestamp;
6146
import java.util.ArrayList;
47+
import java.util.Collections;
6248
import java.util.List;
6349
import java.util.Map;
6450

‎core/src/main/java/com/dtstack/flink/sql/side/BaseAsyncReqRow.java‎

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -25,23 +25,21 @@
2525
import com.dtstack.flink.sql.side.cache.AbstractSideCache;
2626
import com.dtstack.flink.sql.side.cache.CacheObj;
2727
import com.dtstack.flink.sql.side.cache.LRUSideCache;
28-
import com.dtstack.flink.sql.util.RowDataComplete;
29-
import com.dtstack.flink.sql.util.RowDataConvert;
3028
import com.dtstack.flink.sql.util.ReflectionUtils;
29+
import com.dtstack.flink.sql.util.RowDataComplete;
3130
import com.google.common.collect.Lists;
3231
import com.google.common.collect.Maps;
3332
import org.apache.calcite.sql.JoinType;
3433
import org.apache.commons.collections.MapUtils;
3534
import org.apache.flink.api.common.functions.RuntimeContext;
36-
import org.apache.flink.api.java.tuple.Tuple2;
3735
import org.apache.flink.configuration.Configuration;
3836
import org.apache.flink.metrics.Counter;
3937
import org.apache.flink.streaming.api.functions.async.ResultFuture;
4038
import org.apache.flink.streaming.api.functions.async.RichAsyncFunction;
41-
import org.apache.flink.table.dataformat.BaseRow;
4239
import org.apache.flink.streaming.api.operators.StreamingRuntimeContext;
4340
import org.apache.flink.streaming.runtime.tasks.ProcessingTimeService;
4441
import org.apache.flink.table.api.DataTypes;
42+
import org.apache.flink.table.dataformat.BaseRow;
4543
import org.apache.flink.types.Row;
4644
import org.slf4j.Logger;
4745
import org.slf4j.LoggerFactory;

‎hbase/hbase-side/hbase-async-side/src/main/java/com/dtstack/flink/sql/side/hbase/rowkeydealer/AbstractRowKeyModeDealer.java‎

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -23,9 +23,8 @@
2323
import com.dtstack.flink.sql.side.FieldInfo;
2424
import com.dtstack.flink.sql.side.cache.AbstractSideCache;
2525
import com.dtstack.flink.sql.util.RowDataComplete;
26-
import org.apache.calcite.sql.JoinType;
2726
import com.google.common.collect.Maps;
28-
import org.apache.flink.api.java.tuple.Tuple2;
27+
import org.apache.calcite.sql.JoinType;
2928
import org.apache.flink.streaming.api.functions.async.ResultFuture;
3029
import org.apache.flink.table.dataformat.BaseRow;
3130
import org.apache.flink.types.Row;

‎hbase/hbase-side/hbase-async-side/src/main/java/com/dtstack/flink/sql/side/hbase/rowkeydealer/PreRowKeyModeDealerDealer.java‎

Lines changed: 3 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -27,25 +27,18 @@
2727
import com.dtstack.flink.sql.side.cache.CacheObj;
2828
import com.dtstack.flink.sql.side.hbase.utils.HbaseUtils;
2929
import com.dtstack.flink.sql.util.RowDataComplete;
30+
import com.google.common.collect.Lists;
3031
import com.google.common.collect.Maps;
3132
import org.apache.calcite.sql.JoinType;
32-
import com.google.common.collect.Lists;
33-
import org.apache.flink.api.java.tuple.Tuple2;
3433
import org.apache.flink.streaming.api.functions.async.ResultFuture;
3534
import org.apache.flink.table.dataformat.BaseRow;
3635
import org.apache.flink.types.Row;
37-
import org.hbase.async.BinaryPrefixComparator;
38-
import org.hbase.async.Bytes;
39-
import org.hbase.async.CompareFilter;
40-
import org.hbase.async.HBaseClient;
41-
import org.hbase.async.KeyValue;
42-
import org.hbase.async.RowFilter;
43-
import org.hbase.async.ScanFilter;
44-
import org.hbase.async.Scanner;
36+
import org.hbase.async.*;
4537
import org.slf4j.Logger;
4638
import org.slf4j.LoggerFactory;
4739

4840
import java.util.ArrayList;
41+
import java.util.Collections;
4942
import java.util.List;
5043
import java.util.Map;
5144

‎hbase/hbase-side/hbase-async-side/src/main/java/com/dtstack/flink/sql/side/hbase/rowkeydealer/RowKeyEqualModeDealer.java‎

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -27,10 +27,9 @@
2727
import com.dtstack.flink.sql.side.cache.CacheObj;
2828
import com.dtstack.flink.sql.side.hbase.utils.HbaseUtils;
2929
import com.dtstack.flink.sql.util.RowDataComplete;
30+
import com.google.common.collect.Lists;
3031
import com.google.common.collect.Maps;
3132
import org.apache.calcite.sql.JoinType;
32-
import com.google.common.collect.Lists;
33-
import org.apache.flink.api.java.tuple.Tuple2;
3433
import org.apache.flink.streaming.api.functions.async.ResultFuture;
3534
import org.apache.flink.table.dataformat.BaseRow;
3635
import org.apache.flink.types.Row;

‎mongo/mongo-side/mongo-async-side/src/main/java/com/dtstack/flink/sql/side/mongo/MongoAsyncReqRow.java‎

Lines changed: 9 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -19,38 +19,35 @@
1919

2020
package com.dtstack.flink.sql.side.mongo;
2121

22-
import com.dtstack.flink.sql.util.RowDataComplete;
23-
import org.apache.flink.api.java.tuple.Tuple2;
24-
import org.apache.commons.lang3.StringUtils;
25-
import org.apache.flink.api.java.typeutils.RowTypeInfo;
26-
import org.apache.flink.configuration.Configuration;
27-
import org.apache.flink.streaming.api.functions.async.ResultFuture;
28-
import org.apache.flink.table.dataformat.BaseRow;
29-
import org.apache.flink.types.Row;
30-
3122
import com.dtstack.flink.sql.enums.ECacheContentType;
23+
import com.dtstack.flink.sql.side.AbstractSideTableInfo;
3224
import com.dtstack.flink.sql.side.BaseAsyncReqRow;
3325
import com.dtstack.flink.sql.side.FieldInfo;
3426
import com.dtstack.flink.sql.side.JoinInfo;
35-
import com.dtstack.flink.sql.side.AbstractSideTableInfo;
3627
import com.dtstack.flink.sql.side.cache.CacheObj;
3728
import com.dtstack.flink.sql.side.mongo.table.MongoSideTableInfo;
3829
import com.dtstack.flink.sql.side.mongo.utils.MongoUtil;
30+
import com.dtstack.flink.sql.util.RowDataComplete;
3931
import com.google.common.collect.Lists;
4032
import com.mongodb.BasicDBObject;
4133
import com.mongodb.Block;
4234
import com.mongodb.ConnectionString;
35+
import com.mongodb.MongoClientSettings;
4336
import com.mongodb.async.SingleResultCallback;
4437
import com.mongodb.async.client.MongoClient;
45-
import com.mongodb.MongoClientSettings;
4638
import com.mongodb.async.client.MongoClients;
4739
import com.mongodb.async.client.MongoCollection;
4840
import com.mongodb.async.client.MongoDatabase;
41+
import org.apache.commons.lang3.StringUtils;
42+
import org.apache.flink.api.java.typeutils.RowTypeInfo;
43+
import org.apache.flink.configuration.Configuration;
44+
import org.apache.flink.streaming.api.functions.async.ResultFuture;
45+
import org.apache.flink.table.dataformat.BaseRow;
46+
import org.apache.flink.types.Row;
4947
import org.bson.Document;
5048
import org.slf4j.Logger;
5149
import org.slf4j.LoggerFactory;
5250

53-
import java.util.Collection;
5451
import java.util.Collections;
5552
import java.util.List;
5653
import java.util.Map;

0 commit comments

Comments
 (0)