logError(Throwable) |   | 51% |   | 50% | 2 | 4 | 4 | 9 | 0 | 1 |
receive(IncomingStreamMessage) |   | 67% |   | 50% | 3 | 4 | 3 | 17 | 0 | 1 |
progress(String, ProgressInfo.Direction, long, long, long) |   | 40% |   | 50% | 1 | 2 | 2 | 6 | 0 | 1 |
checkAvailableDiskSpaceAndCompactions(Collection) |   | 61% |   | 83% | 1 | 4 | 3 | 10 | 0 | 1 |
checkDiskSpace(Map, TimeUUID, Function) |   | 89% |   | 78% | 3 | 8 | 3 | 31 | 0 | 1 |
addStreamRequest(String, RangesAtEndpoint, RangesAtEndpoint, Collection) |   | 62% |   | 50% | 3 | 5 | 0 | 4 | 0 | 1 |
complete() |   | 51% |   | 50% | 1 | 2 | 1 | 5 | 0 | 1 |
prepareAck(PrepareAckMessage) |   | 35% |   | 50% | 1 | 2 | 1 | 4 | 0 | 1 |
messageReceived(StreamMessage) |   | 87% |   | 75% | 3 | 11 | 2 | 24 | 0 | 1 |
abort() |   | 81% |  | 100% | 0 | 3 | 2 | 11 | 0 | 1 |
abortTasks() |   | 63% | | n/a | 0 | 1 | 2 | 6 | 0 | 1 |
getOutgoingStreamsForRanges(RangesAtEndpoint, Collection, TimeUUID, PreviewKind) |   | 82% |  | 100% | 0 | 2 | 3 | 9 | 0 | 1 |
getAggregator(TableId) |   | 68% |   | 50% | 1 | 2 | 0 | 2 | 0 | 1 |
start() |   | 94% |   | 83% | 1 | 4 | 0 | 20 | 0 | 1 |
startStreamingFiles(StreamSession.PrepareDirection) |   | 94% |   | 75% | 2 | 5 | 1 | 14 | 0 | 1 |
maybeCompleted() |   | 95% |   | 87% | 1 | 5 | 1 | 11 | 0 | 1 |
streamOperation() |   | 90% |   | 75% | 1 | 3 | 0 | 4 | 0 | 1 |
createLogTag(StreamSession, StreamingChannel) |   | 77% |   | 50% | 1 | 2 | 0 | 1 | 0 | 1 |
createLogTag(StreamSession, Channel) |   | 77% |   | 50% | 1 | 2 | 0 | 1 | 0 | 1 |
attachOutbound(StreamingChannel) |  | 95% |   | 50% | 2 | 3 | 0 | 5 | 0 | 1 |
checkPendingCompactions(Map, Map, TimeUUID, String, boolean, long) |  | 100% |  | 100% | 0 | 5 | 0 | 32 | 0 | 1 |
prepareAsync(Collection, Collection) |  | 100% |  | 100% | 0 | 8 | 0 | 18 | 0 | 1 |
onError(Throwable) |  | 100% |   | 90% | 1 | 6 | 0 | 17 | 0 | 1 |
boundStackTrace(Throwable, int, int, Set, StringBuilder) |  | 100% |  | 100% | 0 | 6 | 0 | 14 | 0 | 1 |
StreamSession(StreamOperation, InetAddressAndPort, StreamingChannel.Factory, StreamingChannel, int, boolean, int, TimeUUID, PreviewKind) |  | 100% | | n/a | 0 | 1 | 0 | 19 | 0 | 1 |
checkAvailableDiskSpaceAndCompactions(Collection, TimeUUID, String, boolean) |  | 100% |   | 90% | 1 | 6 | 0 | 12 | 0 | 1 |
lambda$closeSession$5(StreamSession.State, Object) |  | 100% |  | 100% | 0 | 5 | 0 | 8 | 0 | 1 |
getSessionInfo() |  | 100% |  | 100% | 0 | 3 | 0 | 7 | 0 | 1 |
addTransferRanges(String, RangesAtEndpoint, Collection, boolean) |  | 100% |   | 75% | 1 | 3 | 0 | 13 | 0 | 1 |
prepareSynAck(PrepareSynAckMessage) |  | 100% |  | 100% | 0 | 6 | 0 | 11 | 0 | 1 |
addTransferStreams(Collection) |  | 100% |   | 83% | 1 | 4 | 0 | 12 | 0 | 1 |
streamSent(OutgoingStreamMessage) |  | 100% |   | 75% | 1 | 3 | 0 | 10 | 0 | 1 |
onInitializationComplete() |  | 100% |  | 100% | 0 | 2 | 0 | 8 | 0 | 1 |
getColumnFamilyStores(String, Collection) |  | 100% |  | 100% | 0 | 3 | 0 | 6 | 0 | 1 |
createLogTag(StreamSession, Object) |  | 100% |  | 100% | 0 | 3 | 0 | 8 | 0 | 1 |
state(StreamSession.State) |  | 100% |  | 100% | 0 | 2 | 0 | 5 | 0 | 1 |
completePreview() |  | 100% |  | 100% | 0 | 3 | 0 | 6 | 0 | 1 |
closeSession(StreamSession.State, String) |  | 100% |  | 100% | 0 | 2 | 0 | 6 | 0 | 1 |
sessionFailed() |  | 100% | | n/a | 0 | 1 | 0 | 5 | 0 | 1 |
flushSSTables(Iterable) |  | 100% |  | 100% | 0 | 2 | 0 | 5 | 0 | 1 |
lambda$closeSession$2(StreamSession.State, String) |  | 100% |  | 100% | 0 | 2 | 0 | 7 | 0 | 1 |
failIfFinished() |  | 100% |  | 100% | 0 | 2 | 0 | 3 | 0 | 1 |
attachInbound(StreamingChannel) |  | 100% |  | 100% | 0 | 3 | 0 | 5 | 0 | 1 |
prepareReceiving(StreamSummary) |  | 100% |   | 50% | 1 | 2 | 0 | 4 | 0 | 1 |
toString() |  | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
lambda$attachInbound$0(StreamingChannel) |  | 100% |   | 75% | 1 | 3 | 0 | 3 | 0 | 1 |
sessionTimeout() |  | 100% | | n/a | 0 | 1 | 0 | 3 | 0 | 1 |
initiatorCompleteOrWait() |  | 100% |  | 100% | 0 | 2 | 0 | 4 | 0 | 1 |
boundStackTrace(Throwable, int, StringBuilder) |  | 100% | | n/a | 0 | 1 | 0 | 2 | 0 | 1 |
lambda$prepare$6(Collection, Collection) |  | 100% | | n/a | 0 | 1 | 0 | 5 | 0 | 1 |
prepare(Collection, Collection) |  | 100% | | n/a | 0 | 1 | 0 | 3 | 0 | 1 |
taskCompleted(StreamReceiveTask) |  | 100% | | n/a | 0 | 1 | 0 | 3 | 0 | 1 |
taskCompleted(StreamTransferTask) |  | 100% | | n/a | 0 | 1 | 0 | 3 | 0 | 1 |
planId() |  | 100% |  | 100% | 0 | 2 | 0 | 1 | 0 | 1 |
static {...} |  | 100% | | n/a | 0 | 1 | 0 | 3 | 0 | 1 |
init(StreamResultFuture) |  | 100% | | n/a | 0 | 1 | 0 | 3 | 0 | 1 |
isSuccess() |  | 100% |  | 100% | 0 | 2 | 0 | 1 | 0 | 1 |
received(TableId, int) |  | 100% | | n/a | 0 | 1 | 0 | 2 | 0 | 1 |
lambda$attachOutbound$1(StreamingChannel) |  | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
lambda$checkDiskSpace$7(ColumnFamilyStore) |  | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
lambda$closeSession$4(List, StreamingChannel) |  | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
lambda$closeSession$3(List, StreamingChannel) |  | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
closeSession(StreamSession.State) |  | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
countStreamedIn(boolean) |  | 100% | | n/a | 0 | 1 | 0 | 2 | 0 | 1 |
isPreview() |  | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
getNumRequests() |  | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
getNumTransfers() |  | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
createLogTag(StreamSession) |  | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
isFollower() |  | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
sessionIndex() |  | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
getStreamOperation() |  | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
getPendingRepair() |  | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
getPreviewKind() |  | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
state() |  | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
getChannel() |  | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
lambda$checkPendingCompactions$8(Integer) |  | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |