flushOrSync(boolean, EnumSet) |  | 0% |  | 0% | 25 | 25 | 67 | 67 | 1 | 1 |
DFSOutputStream(DFSClient, String, EnumSet, Progressable, HdfsFileStatus, DataChecksum) |  | 0% |  | 0% | 8 | 8 | 40 | 40 | 1 | 1 |
newStreamForCreate(DFSClient, String, FsPermission, EnumSet, boolean, short, long, Progressable, DataChecksum, String[], String, String) |  | 0% |  | 0% | 5 | 5 | 24 | 24 | 1 | 1 |
completeFile(ExtendedBlock) |  | 0% |  | 0% | 8 | 8 | 32 | 32 | 1 | 1 |
addBlock(DatanodeInfo[], DFSClient, String, ExtendedBlock, long, String[], EnumSet) |  | 0% |  | 0% | 5 | 5 | 28 | 28 | 1 | 1 |
writeChunkPrepare(int, int, int) |  | 0% |  | 0% | 5 | 5 | 14 | 14 | 1 | 1 |
DFSOutputStream(DFSClient, String, EnumSet, Progressable, LocatedBlock, HdfsFileStatus, DataChecksum, String[]) |  | 0% |  | 0% | 4 | 4 | 14 | 14 | 1 | 1 |
closeImpl() |  | 0% |  | 0% | 6 | 6 | 29 | 29 | 1 | 1 |
adjustPacketChunkSize(LocatedBlock) |  | 0% |  | 0% | 4 | 4 | 13 | 13 | 1 | 1 |
adjustChunkBoundary() |  | 0% |  | 0% | 5 | 5 | 12 | 12 | 1 | 1 |
computePacketChunkSize(int, int) |  | 0% | | n/a | 1 | 1 | 7 | 7 | 1 | 1 |
enqueueCurrentPacketFull() |  | 0% | | n/a | 1 | 1 | 8 | 8 | 1 | 1 |
abort() |  | 0% |  | 0% | 3 | 3 | 15 | 15 | 1 | 1 |
writeChunk(byte[], int, int, byte[], int, int) |  | 0% |  | 0% | 3 | 3 | 9 | 9 | 1 | 1 |
DFSOutputStream(DFSClient, String, HdfsFileStatus, EnumSet, Progressable, DataChecksum, String[], boolean) |  | 0% |  | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
writeChunk(ByteBuffer, int, byte[], int, int) |  | 0% |  | 0% | 3 | 3 | 9 | 9 | 1 | 1 |
newStreamForAppend(DFSClient, String, EnumSet, Progressable, LocatedBlock, HdfsFileStatus, DataChecksum, String[]) |  | 0% |  | 0% | 2 | 2 | 7 | 7 | 1 | 1 |
createPacket(int, int, long, long, boolean) |  | 0% | | n/a | 1 | 1 | 9 | 9 | 1 | 1 |
close() |  | 0% |  | 0% | 2 | 2 | 12 | 12 | 1 | 1 |
getPipeline() |  | 0% |  | 0% | 3 | 3 | 8 | 8 | 1 | 1 |
flushInternalWithoutWaitingAck() |  | 0% | | n/a | 1 | 1 | 8 | 8 | 1 | 1 |
recoverLease(boolean) |  | 0% |  | 0% | 2 | 2 | 8 | 8 | 1 | 1 |
getCurrentBlockReplication() |  | 0% |  | 0% | 3 | 3 | 8 | 8 | 1 | 1 |
cleanupAndRethrowIOException(IOException) |  | 0% |  | 0% | 2 | 2 | 9 | 9 | 1 | 1 |
closeThreads(boolean) |  | 0% | | n/a | 1 | 1 | 8 | 8 | 1 | 1 |
initWritePacketSize() |  | 0% |  | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
setDropBehind(Boolean) |  | 0% |  | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
setCurrentPacketToEmpty() |  | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
endBlock() |  | 0% |  | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
setChunksPerPacket(int) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
getChecksum4Compute(DataChecksum, HdfsFileStatus) |  | 0% |  | 0% | 3 | 3 | 4 | 4 | 1 | 1 |
completeFile() |  | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
hflush() |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
hsync() |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
static {...} |  | 0% |  | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
hsync(EnumSet) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
setClosed() |  | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
isClosed() |  | 0% |  | 0% | 3 | 3 | 1 | 1 | 1 | 1 |
exceptionNeedsCleanup(IOException) |  | 0% |  | 0% | 3 | 3 | 1 | 1 | 1 | 1 |
enqueueCurrentPacket() |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
checkClosed() |  | 0% |  | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
flushInternal() |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
createWriteTraceScope() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
toString() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
calculateDelayForNextRetry(long, long) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
setAppendChunk(boolean) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
setBytesCurBlock(long) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
setArtificialSlowdown(long) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
start() |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getBlockToken() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getBlock() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
hasCapability(String) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getNumCurrentReplicas() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getInitialLen() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getAddBlockFlags() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getFileEncryptionInfo() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getFileId() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getNamespace() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getUniqKey() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getSrc() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getStreamer() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
isLeaseRecovered() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |