@@ -291,16 +291,16 @@ public void testDownloadStatsCorrectnessSinglePrimarySingleReplica() throws Exce
291
291
// Existing validation logic
292
292
List <RemoteStoreStats > primaryStatsList = Arrays .stream (response .getRemoteStoreStats ())
293
293
.filter (remoteStoreStats -> remoteStoreStats .getShardRouting ().primary ())
294
- .toList ();
294
+ .collect ( Collectors . toList () );
295
295
assertEquals (1 , primaryStatsList .size ());
296
296
297
297
List <RemoteStoreStats > replicaStatsList = Arrays .stream (response .getRemoteStoreStats ())
298
298
.filter (remoteStoreStats -> !remoteStoreStats .getShardRouting ().primary ())
299
- .toList ();
299
+ .collect ( Collectors . toList () );
300
300
assertEquals (1 , replicaStatsList .size ());
301
301
302
- RemoteSegmentTransferTracker .Stats primaryStats = primaryStatsList .getFirst ( ).getSegmentStats ();
303
- RemoteSegmentTransferTracker .Stats replicaStats = replicaStatsList .getFirst ( ).getSegmentStats ();
302
+ RemoteSegmentTransferTracker .Stats primaryStats = primaryStatsList .get ( 0 ).getSegmentStats ();
303
+ RemoteSegmentTransferTracker .Stats replicaStats = replicaStatsList .get ( 0 ).getSegmentStats ();
304
304
305
305
// Existing assertions
306
306
assertTrue (primaryStats .totalUploadsStarted > 0 );
@@ -409,15 +409,15 @@ private void validateZeroStatePrimaryStats(RemoteSegmentTransferTracker.Stats pr
409
409
private void validateZeroStateReplicaStats (RemoteStoreStatsResponse zeroStateResponse , boolean multipleShardsExpected ) {
410
410
List <RemoteStoreStats > zeroStateReplicaStats = Arrays .stream (zeroStateResponse .getRemoteStoreStats ())
411
411
.filter (remoteStoreStats -> !remoteStoreStats .getShardRouting ().primary ())
412
- .toList ();
412
+ .collect ( Collectors . toList () );
413
413
414
414
if (multipleShardsExpected ) {
415
415
zeroStateReplicaStats .forEach (stats -> {
416
416
assertEquals (0 , stats .getSegmentStats ().directoryFileTransferTrackerStats .transferredBytesStarted );
417
417
assertEquals (0 , stats .getSegmentStats ().directoryFileTransferTrackerStats .transferredBytesSucceeded );
418
418
});
419
419
} else {
420
- RemoteSegmentTransferTracker .Stats replicaStats = zeroStateReplicaStats .getFirst ( ).getSegmentStats ();
420
+ RemoteSegmentTransferTracker .Stats replicaStats = zeroStateReplicaStats .get ( 0 ).getSegmentStats ();
421
421
assertEquals (0 , replicaStats .directoryFileTransferTrackerStats .transferredBytesStarted );
422
422
assertEquals (0 , replicaStats .directoryFileTransferTrackerStats .transferredBytesSucceeded );
423
423
}
@@ -442,8 +442,8 @@ private SetOnce<RemoteSegmentTransferTracker.Stats> prepareZeroStateStats(
442
442
443
443
RemoteSegmentTransferTracker .Stats primaryStats = Arrays .stream (zeroStateResponse .getRemoteStoreStats ())
444
444
.filter (remoteStoreStats -> remoteStoreStats .getShardRouting ().primary ())
445
- .toList ()
446
- .getFirst ( )
445
+ .collect ( Collectors . toList () )
446
+ .get ( 0 )
447
447
.getSegmentStats ();
448
448
449
449
validateZeroStatePrimaryStats (primaryStats );
0 commit comments