RangeStreamer

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total570 of 1,27555%73 of 14850%6098862201024
lambda$fetchAsync$8(String, InetAddressAndPort, Collection)1990%100%66313111
calculateRangesToFetchWithPreferredEndpoints(BiFunction, AbstractReplicationStrategy, ReplicaCollection, boolean, TokenMetadata, TokenMetadata, String, Collection)7822073%152965%1223135501
addRanges(String, ReplicaCollection)608859%91155%71172001
useStrictSourcesForRanges(AbstractReplicationStrategy)561217%11321%7891201
lambda$fetchAsync$3(SystemKeyspace.AvailableRanges, RangeStreamer.FetchReplica)350%80%557711
getOptimizedWorkMap(EndpointsByReplica, Collection, String)2610980%21083%2722401
lambda$static$0(Replica)230%80%554411
validateRangeFetchMap(EndpointsByRange, Multimap, String)184872%2466%243901
calculateRangesToFetchWithPreferredEndpoints(ReplicaCollection, Keyspace, boolean)153167%2250%2331001
RangeStreamer(TokenMetadata, Collection, InetAddressAndPort, StreamOperation, boolean, IEndpointSnitch, StreamStateStore, boolean, int)130%n/a112211
lambda$fetchAsync$9(String, Multimap)120%n/a113311
fetchAsync()90%n/a112211
convertPreferredEndpointsToWorkMap(EndpointsByReplica)85587%2675%2501001
RangeStreamer(TokenMetadata, Collection, InetAddressAndPort, StreamOperation, boolean, IEndpointSnitch, StreamStateStore, IFailureDetector, boolean, int)47194%3125%2301601
lambda$fetchAsync$6(RangeStreamer.FetchReplica)40%n/a111111
lambda$fetchAsync$4(RangeStreamer.FetchReplica)40%n/a111111
lambda$fetchAsync$7(RangeStreamer.FetchReplica)30%n/a111111
lambda$fetchAsync$5(RangeStreamer.FetchReplica)30%n/a111111
buildErrorMessage(Collection, ReplicaCollection)40100%1583%140901
lambda$calculateRangesToFetchWithPreferredEndpoints$2(Replica, Replica)10100%4100%030101
addSourceFilter(RangeStreamer.SourceFilter)6100%n/a010201
lambda$calculateRangesToFetchWithPreferredEndpoints$1(BiFunction, InetAddressAndPort, EndpointsForRange)6100%n/a010101
static {...}6100%n/a010201
toFetch()3100%n/a010101