File tree Expand file tree Collapse file tree 4 files changed +4
-7
lines changed
integration-tests/src/test/java/com/datastax/oss/driver/core
test-infra/src/main/java/com/datastax/oss/driver/api/testinfra/simulacron Expand file tree Collapse file tree 4 files changed +4
-7
lines changed Original file line number Diff line number Diff line change @@ -103,7 +103,6 @@ public class DefaultRetryPolicyIT {
103
103
private Level oldLevel ;
104
104
private String logPrefix ;
105
105
106
- @ SuppressWarnings ("deprecation" )
107
106
private final QueryCounter counter =
108
107
QueryCounter .builder (SIMULACRON_RULE .cluster ())
109
108
.withFilter ((l ) -> l .getQuery ().equals (queryStr ))
Original file line number Diff line number Diff line change @@ -82,7 +82,6 @@ public class PerProfileRetryPolicyIT {
82
82
private static String QUERY_STRING = "select * from foo" ;
83
83
private static final SimpleStatement QUERY = SimpleStatement .newInstance (QUERY_STRING );
84
84
85
- @ SuppressWarnings ("deprecation" )
86
85
private final QueryCounter counter =
87
86
QueryCounter .builder (SIMULACRON_RULE .cluster ())
88
87
.withFilter ((l ) -> l .getQuery ().equals (QUERY_STRING ))
Original file line number Diff line number Diff line change @@ -52,15 +52,14 @@ public class SpeculativeExecutionIT {
52
52
// Note: it looks like shorter delays cause precision issues with Netty timers
53
53
private static final long SPECULATIVE_DELAY = 1000 ;
54
54
55
- private static String QUERY_STRING = "select * from foo" ;
55
+ private static final String QUERY_STRING = "select * from foo" ;
56
56
private static final SimpleStatement QUERY = SimpleStatement .newInstance (QUERY_STRING );
57
57
58
58
// Shared across all tests methods.
59
59
@ ClassRule
60
60
public static final SimulacronRule SIMULACRON_RULE =
61
61
new SimulacronRule (ClusterSpec .builder ().withNodes (3 ));
62
62
63
- @ SuppressWarnings ("deprecation" )
64
63
private final QueryCounter counter =
65
64
QueryCounter .builder (SIMULACRON_RULE .cluster ())
66
65
.withFilter ((l ) -> l .getQuery ().equals (QUERY_STRING ))
Original file line number Diff line number Diff line change @@ -112,11 +112,11 @@ public void assertNodeCounts(int... counts) {
112
112
113
113
public static class QueryCounterBuilder {
114
114
115
- @ SuppressWarnings ("deprecation" )
116
- private static Predicate <QueryLog > DEFAULT_FILTER = (q ) -> !q .getQuery ().isEmpty ();
115
+ private static final Predicate <QueryLog > DEFAULT_FILTER = (q ) -> !q .getQuery ().isEmpty ();
116
+
117
+ private final BoundTopic <?, ?> topic ;
117
118
118
119
private Predicate <QueryLog > queryLogFilter = DEFAULT_FILTER ;
119
- private BoundTopic <?, ?> topic ;
120
120
private NotificationMode notificationMode = NotificationMode .BEFORE_PROCESSING ;
121
121
private long beforeTimeout = 1 ;
122
122
private TimeUnit beforeUnit = TimeUnit .SECONDS ;
You can’t perform that action at this time.
0 commit comments