Skip to content

Commit 7bcb8ac

Browse files
committed
remove unuse class
1 parent c5c7460 commit 7bcb8ac

File tree

1 file changed

+13
-7
lines changed
  • redis5/redis5-side/redis-all-side/src/main/java/com/dtstack/flink/sql/side/redis

1 file changed

+13
-7
lines changed

redis5/redis5-side/redis-all-side/src/main/java/com/dtstack/flink/sql/side/redis/RedisAllReqRow.java

Lines changed: 13 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -36,21 +36,27 @@
3636
import org.apache.flink.table.runtime.types.CRow;
3737
import org.apache.flink.types.Row;
3838
import org.apache.flink.util.Collector;
39-
import org.apache.flink.api.java.typeutils.RowTypeInfo;
4039
import com.google.common.collect.Maps;
41-
import org.apache.flink.table.runtime.types.CRow;
42-
import org.apache.flink.types.Row;
43-
import org.apache.flink.util.Collector;
4440
import org.slf4j.Logger;
4541
import org.slf4j.LoggerFactory;
46-
import redis.clients.jedis.*;
42+
import redis.clients.jedis.HostAndPort;
43+
import redis.clients.jedis.Jedis;
44+
import redis.clients.jedis.JedisCluster;
45+
import redis.clients.jedis.JedisCommands;
46+
import redis.clients.jedis.JedisPool;
47+
import redis.clients.jedis.JedisSentinelPool;
4748

4849
import java.io.Closeable;
4950
import java.io.IOException;
5051
import java.sql.SQLException;
51-
import java.util.*;
52+
53+
import java.util.Calendar;
54+
import java.util.HashSet;
55+
import java.util.List;
56+
import java.util.Map;
57+
import java.util.Set;
58+
import java.util.TreeSet;
5259
import java.util.concurrent.atomic.AtomicReference;
53-
import java.util.stream.Collectors;
5460
/**
5561
* @author yanxi
5662
*/

0 commit comments

Comments
 (0)