AbfsOutputStream

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total1,341 of 1,3410%138 of 1380%1341343453456565
AbfsOutputStream(AbfsOutputStreamContext)2060%40%33606011
write(byte[], int, int)1010%180%1010242411
lambda$uploadBlockAsync$0(boolean, boolean, long, int, String, AbfsBlock, DataBlocks.BlockUploadData)980%40%33212111
flushWrittenBytesToServiceInternal(long, boolean, boolean)890%100%66212111
createNewHandler(AbfsServiceType, DataBlocks.BlockFactory, int, boolean, AzureBlockManager)730%120%77111111
uploadBlockAsync(AbfsBlock, boolean, boolean)710%40%33181811
close()700%100%66202011
waitForAppendsToComplete()570%80%55141411
shrinkWriteOperationQueue()570%60%44141411
switchHandler()430%40%33101011
createIngressHandler(AbfsServiceType, DataBlocks.BlockFactory, int, boolean, AzureBlockManager)410%60%449911
flushInternal(boolean)340%120%77111111
failureWhileSubmit(Exception)310%60%447711
toString()300%n/a116611
uploadCurrentBlock()270%20%226611
areWriteOperationsTasksDone()220%40%335511
smallWriteOptimizedflushInternal(boolean)170%n/a116611
hasActiveBlockDataToUpload()160%40%333311
flushWrittenBytesToServiceAsync()150%20%224411
getMd5()150%20%225511
write(int)120%n/a112211
flushInternalAsync()120%20%226611
hasCapability(String)100%40%331111
remoteFlush(long, boolean, boolean, String, TracingContext)90%n/a111111
registerListener(Listener)90%n/a113311
flushWrittenBytesToService(boolean)90%n/a113311
isLeaseFreed()90%20%223311
bufferData(AbfsBlock, byte[], int, int)80%n/a111111
remoteWrite(AbfsBlock, DataBlocks.BlockUploadData, AppendRequestParameters, TracingContext)80%n/a111111
incrementWriteOps()80%20%223311
maybeThrowLastError()70%20%223311
hsync()70%20%223311
hflush()70%20%223311
hasLease()70%20%221111
flush()60%20%223311
createOutputStreamId()50%n/a111111
createBlockIfNeeded(long)50%n/a111111
getWriteOperationsSize()40%n/a111111
isAppendBlobStream()40%n/a111111
setPosition(long)40%n/a112211
getCachedSasTokenString()40%n/a111111
getBlockManager()40%n/a111111
static {...}40%n/a112211
getIngressHandler()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
getClientHandler()30%n/a111111
getPath()30%n/a111111
getPosition()30%n/a111111
getContextEncryptionAdapter()30%n/a111111
getTracingContext()30%n/a111111
isDFSToBlobFallbackEnabled()30%n/a111111
isExpectHeaderEnabled()30%n/a111111
getLeaseId()30%n/a111111
getCachedSasToken()30%n/a111111
isAppendBlob()30%n/a111111
getMessageDigest()30%n/a111111
getFullBlobContentMd5()30%n/a111111