RangeStreamer

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total333 of 1,27573%65 of 14856%539843220324
calculateRangesToFetchWithPreferredEndpoints(BiFunction, AbstractReplicationStrategy, ReplicaCollection, boolean, TokenMetadata, TokenMetadata, String, Collection)11418461%212352%1423165501
lambda$fetchAsync$8(String, InetAddressAndPort, Collection)6013969%3770%3663101
addRanges(String, ReplicaCollection)608859%101050%81172001
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)73984%3125%2321001
RangeStreamer(TokenMetadata, Collection, InetAddressAndPort, StreamOperation, boolean, IEndpointSnitch, StreamStateStore, IFailureDetector, boolean, int)47194%3125%2301601
lambda$fetchAsync$3(SystemKeyspace.AvailableRanges, RangeStreamer.FetchReplica)33291%3562%351701
toFetch()30%n/a111111
lambda$fetchAsync$7(RangeStreamer.FetchReplica)30%n/a111111
useStrictSourcesForRanges(AbstractReplicationStrategy)6697%41071%4801201
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