DFSOutputStream

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total2,050 of 2,0500%182 of 1820%1531534894896262
flushOrSync(boolean, EnumSet)3100%480%2525676711
DFSOutputStream(DFSClient, String, EnumSet, Progressable, HdfsFileStatus, DataChecksum)1620%140%88404011
newStreamForCreate(DFSClient, String, FsPermission, EnumSet, boolean, short, long, Progressable, DataChecksum, String[], String, String)1430%80%55242411
completeFile(ExtendedBlock)1160%140%88323211
addBlock(DatanodeInfo[], DFSClient, String, ExtendedBlock, long, String[], EnumSet)1130%80%55282811
writeChunkPrepare(int, int, int)900%80%55141411
DFSOutputStream(DFSClient, String, EnumSet, Progressable, LocatedBlock, HdfsFileStatus, DataChecksum, String[])880%60%44141411
closeImpl()770%100%66292911
adjustPacketChunkSize(LocatedBlock)620%60%44131311
adjustChunkBoundary()550%80%55121211
computePacketChunkSize(int, int)500%n/a117711
enqueueCurrentPacketFull()470%n/a118811
abort()470%40%33151511
writeChunk(byte[], int, int, byte[], int, int)420%40%339911
DFSOutputStream(DFSClient, String, HdfsFileStatus, EnumSet, Progressable, DataChecksum, String[], boolean)410%20%226611
writeChunk(ByteBuffer, int, byte[], int, int)410%40%339911
newStreamForAppend(DFSClient, String, EnumSet, Progressable, LocatedBlock, HdfsFileStatus, DataChecksum, String[])390%20%227711
createPacket(int, int, long, long, boolean)340%n/a119911
close()330%20%22121211
getPipeline()270%40%338811
flushInternalWithoutWaitingAck()260%n/a118811
recoverLease(boolean)250%20%228811
getCurrentBlockReplication()240%40%338811
cleanupAndRethrowIOException(IOException)230%20%229911
closeThreads(boolean)220%n/a118811
initWritePacketSize()210%20%226611
setDropBehind(Boolean)200%20%225511
setCurrentPacketToEmpty()190%n/a114411
endBlock()190%20%226611
setChunksPerPacket(int)170%n/a113311
getChecksum4Compute(DataChecksum, HdfsFileStatus)140%40%334411
completeFile()140%n/a115511
hflush()130%n/a113311
hsync()130%n/a113311
static {...}130%20%224411
hsync(EnumSet)120%n/a113311
setClosed()120%n/a114411
isClosed()110%40%331111
exceptionNeedsCleanup(IOException)100%40%331111
enqueueCurrentPacket()90%n/a113311
checkClosed()80%20%223311
flushInternal()80%n/a113311
createWriteTraceScope()70%n/a111111
toString()70%n/a111111
calculateDelayForNextRetry(long, long)60%n/a111111
setAppendChunk(boolean)50%n/a112211
setBytesCurBlock(long)50%n/a112211
setArtificialSlowdown(long)50%n/a112211
start()40%n/a112211
getBlockToken()40%n/a111111
getBlock()40%n/a111111
hasCapability(String)30%n/a111111
getNumCurrentReplicas()30%n/a111111
getInitialLen()30%n/a111111
getAddBlockFlags()30%n/a111111
getFileEncryptionInfo()30%n/a111111
getFileId()30%n/a111111
getNamespace()30%n/a111111
getUniqKey()30%n/a111111
getSrc()30%n/a111111
getStreamer()30%n/a111111
isLeaseRecovered()30%n/a111111