27
27
28
28
import javax .inject .Inject ;
29
29
30
- import com .google .common .collect .ImmutableList ;
31
-
32
30
import io .trino .spi .HostAddress ;
33
31
import io .trino .spi .connector .ConnectorSession ;
34
32
import io .trino .spi .connector .ConnectorSplitManager ;
35
33
import io .trino .spi .connector .ConnectorSplitSource ;
36
34
import io .trino .spi .connector .ConnectorTableHandle ;
37
35
import io .trino .spi .connector .ConnectorTransactionHandle ;
38
- import io .trino .spi .connector .Constraint ;
39
36
import io .trino .spi .connector .DynamicFilter ;
40
37
import io .trino .spi .connector .FixedSplitSource ;
41
38
@@ -48,16 +45,10 @@ public RediSearchSplitManager(RediSearchSession session) {
48
45
this .addresses = session .getAddresses ();
49
46
}
50
47
51
- @ Override
52
- public ConnectorSplitSource getSplits (
53
- ConnectorTransactionHandle transaction ,
54
- ConnectorSession session ,
55
- ConnectorTableHandle tableHandle ,
56
- DynamicFilter dynamicFilter ,
57
- Constraint constraint )
58
- {
48
+ @ Override
49
+ public ConnectorSplitSource getSplits (ConnectorTransactionHandle transaction , ConnectorSession session ,
50
+ ConnectorTableHandle table , SplitSchedulingStrategy splitSchedulingStrategy , DynamicFilter dynamicFilter ) {
59
51
RediSearchSplit split = new RediSearchSplit (addresses );
60
-
61
- return new FixedSplitSource (ImmutableList .of (split ));
52
+ return new FixedSplitSource (List .of (split ));
62
53
}
63
54
}
0 commit comments