AbfsOutputStream(AbfsOutputStreamContext) |  | 0% |  | 0% | 2 | 2 | 45 | 45 | 1 | 1 |
writeAppendBlobCurrentBufferToService() |  | 0% |  | 0% | 2 | 2 | 25 | 25 | 1 | 1 |
lambda$uploadBlockAsync$0(boolean, boolean, long, int, DataBlocks.BlockUploadData, DataBlocks.DataBlock) |  | 0% |  | 0% | 3 | 3 | 17 | 17 | 1 | 1 |
flushWrittenBytesToServiceInternal(long, boolean, boolean) |  | 0% |  | 0% | 5 | 5 | 17 | 17 | 1 | 1 |
close() |  | 0% |  | 0% | 7 | 7 | 21 | 21 | 1 | 1 |
write(byte[], int, int) |  | 0% |  | 0% | 8 | 8 | 17 | 17 | 1 | 1 |
uploadBlockAsync(DataBlocks.DataBlock, boolean, boolean) |  | 0% |  | 0% | 3 | 3 | 17 | 17 | 1 | 1 |
waitForAppendsToComplete() |  | 0% |  | 0% | 5 | 5 | 14 | 14 | 1 | 1 |
shrinkWriteOperationQueue() |  | 0% |  | 0% | 4 | 4 | 14 | 14 | 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 |
createBlockIfNeeded() |  | 0% |  | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
uploadCurrentBlock() |  | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
clearActiveBlock() |  | 0% |  | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
smallWriteOptimizedflushInternal(boolean) |  | 0% | | n/a | 1 | 1 | 6 | 6 | 1 | 1 |
flushWrittenBytesToServiceAsync() |  | 0% |  | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
write(int) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
flushInternalAsync() |  | 0% |  | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
hasActiveBlockDataToUpload() |  | 0% |  | 0% | 3 | 3 | 1 | 1 | 1 | 1 |
hasCapability(String) |  | 0% |  | 0% | 3 | 3 | 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 |
incrementWriteOps() |  | 0% |  | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
hasActiveBlock() |  | 0% |  | 0% | 2 | 2 | 1 | 1 | 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 |
getWriteOperationsSize() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
isAppendBlobStream() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
static {...} |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getActiveBlock() |  | 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 |