|
23 | 23 | import io.airlift.slice.Slice; |
24 | 24 | import redis.clients.jedis.Jedis; |
25 | 25 | import redis.clients.jedis.JedisPool; |
26 | | -import redis.clients.jedis.ScanParams; |
27 | | -import redis.clients.jedis.ScanResult; |
| 26 | +import redis.clients.jedis.params.ScanParams; |
| 27 | +import redis.clients.jedis.resps.ScanResult; |
28 | 28 |
|
29 | 29 | import java.nio.charset.StandardCharsets; |
30 | 30 | import java.util.HashMap; |
31 | 31 | import java.util.Iterator; |
32 | 32 | import java.util.List; |
33 | 33 | import java.util.Map; |
34 | 34 | import java.util.Optional; |
35 | | -import java.util.Set; |
36 | 35 | import java.util.concurrent.atomic.AtomicBoolean; |
37 | 36 |
|
38 | 37 | import static com.facebook.presto.decoder.FieldValueProviders.booleanValueProvider; |
39 | 38 | import static com.facebook.presto.decoder.FieldValueProviders.bytesValueProvider; |
40 | 39 | import static com.facebook.presto.decoder.FieldValueProviders.longValueProvider; |
41 | 40 | import static com.google.common.base.Preconditions.checkArgument; |
42 | 41 | import static java.lang.String.format; |
43 | | -import static redis.clients.jedis.ScanParams.SCAN_POINTER_START; |
| 42 | +import static redis.clients.jedis.params.ScanParams.SCAN_POINTER_START; |
44 | 43 |
|
45 | 44 | public class RedisRecordCursor |
46 | 45 | implements RecordCursor |
@@ -310,7 +309,7 @@ private boolean fetchKeys() |
310 | 309 | } |
311 | 310 | break; |
312 | 311 | case ZSET: |
313 | | - Set<String> keys = jedis.zrange(split.getKeyName(), split.getStart(), split.getEnd()); |
| 312 | + List<String> keys = jedis.zrange(split.getKeyName(), split.getStart(), split.getEnd()); |
314 | 313 | keysIterator = keys.iterator(); |
315 | 314 | break; |
316 | 315 | default: |
|
0 commit comments