AbfsOutputStream(AbfsOutputStreamContext) |  | 0% |  | 0% | 3 | 3 | 60 | 60 | 1 | 1 |
write(byte[], int, int) |  | 0% |  | 0% | 10 | 10 | 24 | 24 | 1 | 1 |
lambda$uploadBlockAsync$0(boolean, boolean, long, int, String, AbfsBlock, DataBlocks.BlockUploadData) |  | 0% |  | 0% | 3 | 3 | 21 | 21 | 1 | 1 |
flushWrittenBytesToServiceInternal(long, boolean, boolean) |  | 0% |  | 0% | 6 | 6 | 21 | 21 | 1 | 1 |
createNewHandler(AbfsServiceType, DataBlocks.BlockFactory, int, boolean, AzureBlockManager) |  | 0% |  | 0% | 7 | 7 | 11 | 11 | 1 | 1 |
uploadBlockAsync(AbfsBlock, boolean, boolean) |  | 0% |  | 0% | 3 | 3 | 18 | 18 | 1 | 1 |
close() |  | 0% |  | 0% | 6 | 6 | 20 | 20 | 1 | 1 |
waitForAppendsToComplete() |  | 0% |  | 0% | 5 | 5 | 14 | 14 | 1 | 1 |
shrinkWriteOperationQueue() |  | 0% |  | 0% | 4 | 4 | 14 | 14 | 1 | 1 |
switchHandler() |  | 0% |  | 0% | 3 | 3 | 10 | 10 | 1 | 1 |
createIngressHandler(AbfsServiceType, DataBlocks.BlockFactory, int, boolean, AzureBlockManager) |  | 0% |  | 0% | 4 | 4 | 9 | 9 | 1 | 1 |
flushInternal(boolean) |  | 0% |  | 0% | 7 | 7 | 11 | 11 | 1 | 1 |
failureWhileSubmit(Exception) |  | 0% |  | 0% | 4 | 4 | 7 | 7 | 1 | 1 |
toString() |  | 0% | | n/a | 1 | 1 | 6 | 6 | 1 | 1 |
uploadCurrentBlock() |  | 0% |  | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
areWriteOperationsTasksDone() |  | 0% |  | 0% | 3 | 3 | 5 | 5 | 1 | 1 |
smallWriteOptimizedflushInternal(boolean) |  | 0% | | n/a | 1 | 1 | 6 | 6 | 1 | 1 |
hasActiveBlockDataToUpload() |  | 0% |  | 0% | 3 | 3 | 3 | 3 | 1 | 1 |
flushWrittenBytesToServiceAsync() |  | 0% |  | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
getMd5() |  | 0% |  | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
write(int) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
flushInternalAsync() |  | 0% |  | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
hasCapability(String) |  | 0% |  | 0% | 3 | 3 | 1 | 1 | 1 | 1 |
remoteFlush(long, boolean, boolean, String, TracingContext) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
registerListener(Listener) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
flushWrittenBytesToService(boolean) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
isLeaseFreed() |  | 0% |  | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
bufferData(AbfsBlock, byte[], int, int) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
remoteWrite(AbfsBlock, DataBlocks.BlockUploadData, AppendRequestParameters, TracingContext) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
incrementWriteOps() |  | 0% |  | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
maybeThrowLastError() |  | 0% |  | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
hsync() |  | 0% |  | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
hflush() |  | 0% |  | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
hasLease() |  | 0% |  | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
flush() |  | 0% |  | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
createOutputStreamId() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
createBlockIfNeeded(long) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getWriteOperationsSize() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
isAppendBlobStream() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
setPosition(long) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getCachedSasTokenString() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getBlockManager() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
static {...} |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getIngressHandler() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getStreamID() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
waitForPendingUploads() |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getOutputStreamStatistics() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getMaxConcurrentRequestCount() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getMaxRequestsThatCanBeQueued() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getIOStatistics() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getFsBackRef() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getExecutorService() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getClient() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getClientHandler() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getPath() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getPosition() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getContextEncryptionAdapter() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getTracingContext() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
isDFSToBlobFallbackEnabled() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
isExpectHeaderEnabled() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getLeaseId() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getCachedSasToken() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
isAppendBlob() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getMessageDigest() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getFullBlobContentMd5() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |