|
|
@@ -188,7 +188,6 @@ public class RoutingTable implements Iterable<IndexRoutingTable>, Diffable<Routi
|
|
|
private static Predicate<ShardRouting> ACTIVE_PREDICATE = shardRouting -> shardRouting.active();
|
|
|
private static Predicate<ShardRouting> ASSIGNED_PREDICATE = shardRouting -> shardRouting.assignedToNode();
|
|
|
|
|
|
- // TODO: replace with JDK 8 native java.util.function.Predicate
|
|
|
private GroupShardsIterator allSatisfyingPredicateShardsGrouped(String[] indices, boolean includeEmpty, boolean includeRelocationTargets, Predicate<ShardRouting> predicate) {
|
|
|
// use list here since we need to maintain identity across shards
|
|
|
ArrayList<ShardIterator> set = new ArrayList<>();
|
|
|
@@ -222,7 +221,6 @@ public class RoutingTable implements Iterable<IndexRoutingTable>, Diffable<Routi
|
|
|
return allShardsSatisfyingPredicate(indices, shardRouting -> true, true);
|
|
|
}
|
|
|
|
|
|
- // TODO: replace with JDK 8 native java.util.function.Predicate
|
|
|
private ShardsIterator allShardsSatisfyingPredicate(String[] indices, Predicate<ShardRouting> predicate, boolean includeRelocationTargets) {
|
|
|
// use list here since we need to maintain identity across shards
|
|
|
List<ShardRouting> shards = new ArrayList<>();
|