Github user belliottsmith commented on a diff in the pull request:
https://github.com/apache/cassandra/pull/269#discussion_r218371266
--- Diff: test/unit/org/apache/cassandra/dht/BootStrapperTest.java ---
@@ -125,21 +125,19 @@ public boolean isAlive(InetAddressAndPort ep)
s.addRanges(keyspaceName,
Keyspace.open(keyspaceName).getReplicationStrategy().getPendingAddressRanges(tmd,
myToken, myEndpoint));
- Collection<Multimap<InetAddressAndPort, FetchReplica>> toFetch =
s.toFetch().get(keyspaceName);
+ Multimap<InetAddressAndPort, FetchReplica> toFetch =
s.toFetch().get(keyspaceName);
// Check we get get RF new ranges in total
- long rangesCount = toFetch.stream()
- .map(Multimap::values)
- .flatMap(Collection::stream)
- .map(f -> f.remote)
- .map(Replica::range)
- .count();
+ long rangesCount = toFetch.values().stream()
--- End diff --
surely we can just take toFetch.size()?
---
---------------------------------------------------------------------
To unsubscribe, e-mail: pr-unsubscr...@cassandra.apache.org
For additional commands, e-mail: pr-h...@cassandra.apache.org
