org.apache.cassandra.streaming

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethodsMissedClasses
Total7,826 of 7,9561%572 of 5720%6856931,5721,5983934015054
StreamSession2,5270%2280%194194485485767611
StreamingState5330%320%4646108108282811
StreamResultFuture5250%320%3737102102212111
StreamCoordinator3820%300%38389797232311
StreamManager3337818%200%39447799293401
StreamTransferTask3260%240%25257373131311
StreamRequest.StreamRequestSerializer2780%120%131347477711
SessionInfo2360%140%29294747222211
StreamCoordinator.HostStreamingData2310%120%18183636121211
SessionSummary.new IVersionedSerializer() {...}1980%120%101035354411
ProgressInfo1960%200%171729297711
StreamReceiveTask1900%100%131339398811
StreamPlan1830%120%25253939191911
StreamDeserializingTask1680%160%131338385511
StreamOperation1560%40%8821216611
StreamManager.StreamRateLimiter1300%140%24244242171711
SessionSummary1250%200%141423234411
PreviewKind1160%80%14141717101011
StreamSummary1090%120%111117175511
StreamingState.Sessions1001%120%111217185601
StreamSession.State920%n/a3312123311
StreamSummary.StreamSummarySerializer530%n/a4413134411
PreviewKind.PreviewRepairedSSTablePredicate530%100%6610101111
StreamManager.new StreamManager.StreamListener() {...}4711%40%3413141201
StreamReceiveTask.OnCompletionRunnable460%20%3314142211
ProgressInfo.Direction410%20%44773311
StreamRequest400%20%3310102211
StreamingDataOutputPlusFixed400%20%55884411
StreamEvent.Type340%n/a11441111
StreamEvent.SessionCompleteEvent320%n/a11881111
StreamState310%n/a55995511
ReplicationDoneVerbHandler300%n/a33773311
StreamingChannel.Kind240%n/a11111111
StreamSession.PrepareDirection240%n/a11111111
StreamCoordinator.new StreamEventHandler() {...}0%40%66664411
StreamTask0%n/a22552211
StreamHook0%20%33552211
StreamException0%n/a22662211
StreamReceiveException0%n/a22662211
StreamingChannel.Factory.Global0%n/a44554411
StreamEvent.ProgressEvent0%n/a22442211
StreamEvent.SessionPreparedEvent0%n/a11441111
StreamingState.Phase0%n/a22332211
StreamManager.new Function() {...}0%n/a22222211
StreamEvent0%n/a11441111
SessionInfo.new Predicate() {...}0%n/a22222211
StreamManager.StreamingStateWeigher0%n/a11221111
StreamingChannel.Factory0%n/a22222211
StreamHook.new StreamHook() {...}0%n/a44444411
StreamSession.MessageStateSink.new StreamSession.MessageStateSink() {...}0%n/a44444411
StreamSession.MessageStateSink0%n/a11111111
StreamManager.StreamListener0%n/a11111111
StreamingDataOutputPlus0%n/a11111111
StreamingState.Status44100%n/a01020101