calculateRangesToFetchWithPreferredEndpoints(BiFunction, AbstractReplicationStrategy, ReplicaCollection, boolean, TokenMetadata, TokenMetadata, String, Collection) |  | 0% |  | 0% | 23 | 23 | 55 | 55 | 1 | 1 |
lambda$fetchAsync$8(String, InetAddressAndPort, Collection) |  | 0% |  | 0% | 6 | 6 | 31 | 31 | 1 | 1 |
addRanges(String, ReplicaCollection) |  | 0% |  | 0% | 11 | 11 | 20 | 20 | 1 | 1 |
getOptimizedWorkMap(EndpointsByReplica, Collection, String) |  | 0% |  | 0% | 7 | 7 | 24 | 24 | 1 | 1 |
RangeStreamer(TokenMetadata, Collection, InetAddressAndPort, StreamOperation, boolean, IEndpointSnitch, StreamStateStore, IFailureDetector, boolean, int) |  | 0% |  | 0% | 3 | 3 | 16 | 16 | 1 | 1 |
useStrictSourcesForRanges(AbstractReplicationStrategy) |  | 0% |  | 0% | 8 | 8 | 12 | 12 | 1 | 1 |
validateRangeFetchMap(EndpointsByRange, Multimap, String) |  | 0% |  | 0% | 4 | 4 | 9 | 9 | 1 | 1 |
convertPreferredEndpointsToWorkMap(EndpointsByReplica) |  | 0% |  | 0% | 5 | 5 | 10 | 10 | 1 | 1 |
calculateRangesToFetchWithPreferredEndpoints(ReplicaCollection, Keyspace, boolean) |  | 0% |  | 0% | 3 | 3 | 10 | 10 | 1 | 1 |
buildErrorMessage(Collection, ReplicaCollection) |  | 0% |  | 0% | 4 | 4 | 9 | 9 | 1 | 1 |
lambda$fetchAsync$3(SystemKeyspace.AvailableRanges, RangeStreamer.FetchReplica) |  | 0% |  | 0% | 5 | 5 | 7 | 7 | 1 | 1 |
lambda$static$0(Replica) |  | 0% |  | 0% | 5 | 5 | 4 | 4 | 1 | 1 |
RangeStreamer(TokenMetadata, Collection, InetAddressAndPort, StreamOperation, boolean, IEndpointSnitch, StreamStateStore, boolean, int) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
lambda$fetchAsync$9(String, Multimap) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
lambda$calculateRangesToFetchWithPreferredEndpoints$2(Replica, Replica) |  | 0% |  | 0% | 3 | 3 | 1 | 1 | 1 | 1 |
fetchAsync() |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
addSourceFilter(RangeStreamer.SourceFilter) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
lambda$calculateRangesToFetchWithPreferredEndpoints$1(BiFunction, InetAddressAndPort, EndpointsForRange) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
static {...} |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
lambda$fetchAsync$6(RangeStreamer.FetchReplica) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$fetchAsync$4(RangeStreamer.FetchReplica) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
toFetch() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$fetchAsync$7(RangeStreamer.FetchReplica) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$fetchAsync$5(RangeStreamer.FetchReplica) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |