RangeStreamer

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total313 of 1,27575%53 of 14864%459839220324
calculateRangesToFetchWithPreferredEndpoints(BiFunction, AbstractReplicationStrategy, ReplicaCollection, boolean, TokenMetadata, TokenMetadata, String, Collection)10019866%172761%1223135501
lambda$fetchAsync$8(String, InetAddressAndPort, Collection)6013969%3770%3663101
addRanges(String, ReplicaCollection)608859%91155%71172001
getOptimizedWorkMap(EndpointsByReplica, Collection, String)2610980%21083%2722401
lambda$static$0(Replica)230%80%554411
validateRangeFetchMap(EndpointsByRange, Multimap, String)184872%2466%243901
convertPreferredEndpointsToWorkMap(EndpointsByReplica)85587%2675%2501001
calculateRangesToFetchWithPreferredEndpoints(ReplicaCollection, Keyspace, boolean)54189%1375%1311001
lambda$fetchAsync$3(SystemKeyspace.AvailableRanges, RangeStreamer.FetchReplica)33291%3562%351701
toFetch()30%n/a111111
lambda$fetchAsync$7(RangeStreamer.FetchReplica)30%n/a111111
RangeStreamer(TokenMetadata, Collection, InetAddressAndPort, StreamOperation, boolean, IEndpointSnitch, StreamStateStore, IFailureDetector, boolean, int)7498%1375%1301601
useStrictSourcesForRanges(AbstractReplicationStrategy)6798%11392%1801201
buildErrorMessage(Collection, ReplicaCollection)3997%2466%241901
lambda$calculateRangesToFetchWithPreferredEndpoints$2(Replica, Replica)990%2250%230101
RangeStreamer(TokenMetadata, Collection, InetAddressAndPort, StreamOperation, boolean, IEndpointSnitch, StreamStateStore, boolean, int)13100%n/a010201
lambda$fetchAsync$9(String, Multimap)12100%n/a010301
fetchAsync()9100%n/a010201
addSourceFilter(RangeStreamer.SourceFilter)6100%n/a010201
lambda$calculateRangesToFetchWithPreferredEndpoints$1(BiFunction, InetAddressAndPort, EndpointsForRange)6100%n/a010101
static {...}6100%n/a010201
lambda$fetchAsync$6(RangeStreamer.FetchReplica)4100%n/a010101
lambda$fetchAsync$4(RangeStreamer.FetchReplica)4100%n/a010101
lambda$fetchAsync$5(RangeStreamer.FetchReplica)3100%n/a010101