AbfsOutputStream

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total1,113 of 1,1130%110 of 1100%1001002892894545
AbfsOutputStream(AbfsOutputStreamContext)1520%20%22454511
writeAppendBlobCurrentBufferToService()1170%20%22252511
lambda$uploadBlockAsync$0(boolean, boolean, long, int, DataBlocks.BlockUploadData, DataBlocks.DataBlock)900%40%33171711
flushWrittenBytesToServiceInternal(long, boolean, boolean)790%80%55171711
close()720%120%77212111
write(byte[], int, int)700%140%88171711
uploadBlockAsync(DataBlocks.DataBlock, boolean, boolean)660%40%33171711
waitForAppendsToComplete()570%80%55141411
shrinkWriteOperationQueue()570%60%44141411
flushInternal(boolean)340%120%77111111
failureWhileSubmit(Exception)310%60%447711
toString()300%n/a116611
createBlockIfNeeded()230%20%225511
uploadCurrentBlock()190%n/a115511
clearActiveBlock()170%20%226611
smallWriteOptimizedflushInternal(boolean)160%n/a116611
flushWrittenBytesToServiceAsync()150%20%224411
write(int)120%n/a112211
flushInternalAsync()120%20%226611
hasActiveBlockDataToUpload()110%40%331111
hasCapability(String)100%40%331111
registerListener(Listener)90%n/a113311
flushWrittenBytesToService(boolean)90%n/a113311
isLeaseFreed()90%20%223311
incrementWriteOps()80%20%223311
hasActiveBlock()70%20%221111
maybeThrowLastError()70%20%223311
hsync()70%20%223311
hflush()70%20%223311
hasLease()70%20%221111
flush()60%20%223311
createOutputStreamId()50%n/a111111
getWriteOperationsSize()40%n/a111111
isAppendBlobStream()40%n/a111111
static {...}40%n/a112211
getActiveBlock()30%n/a111111
getStreamID()30%n/a111111
waitForPendingUploads()30%n/a112211
getOutputStreamStatistics()30%n/a111111
getMaxConcurrentRequestCount()30%n/a111111
getMaxRequestsThatCanBeQueued()30%n/a111111
getIOStatistics()30%n/a111111
getFsBackRef()30%n/a111111
getExecutorService()30%n/a111111
getClient()30%n/a111111