| getAckedLength() |  | 0% | | 0% | 15 | 15 | 39 | 39 | 1 | 1 |
| allocateNewBlock() | | 0% | | 0% | 12 | 12 | 35 | 35 | 1 | 1 |
| DFSStripedOutputStream(DFSClient, String, HdfsFileStatus, EnumSet, Progressable, DataChecksum, String[]) | | 0% | | 0% | 2 | 2 | 27 | 27 | 1 | 1 |
| checkStreamerFailures(boolean) | | 0% | | 0% | 15 | 15 | 33 | 33 | 1 | 1 |
| waitCreatingStreamers(Set) | | 0% | | 0% | 9 | 9 | 30 | 30 | 1 | 1 |
| closeImpl() | | 0% | | 0% | 9 | 9 | 46 | 46 | 1 | 1 |
| writeChunk(byte[], int, int, byte[], int, int) | | 0% | | 0% | 10 | 10 | 29 | 29 | 1 | 1 |
| updatePipeline(ExtendedBlock) | | 0% | | 0% | 6 | 6 | 21 | 21 | 1 | 1 |
| flushAllInternals() | | 0% | | 0% | 4 | 4 | 25 | 25 | 1 | 1 |
| replaceFailedStreamers() | | 0% | | 0% | 8 | 8 | 16 | 16 | 1 | 1 |
| writeParity(int, ByteBuffer, byte[]) | | 0% | | 0% | 4 | 4 | 22 | 22 | 1 | 1 |
| checkStreamers() | | 0% | | 0% | 6 | 6 | 15 | 15 | 1 | 1 |
| generateParityCellsForLastStripe() | | 0% | | 0% | 8 | 8 | 15 | 15 | 1 | 1 |
| updateBlockForPipeline(Set) | | 0% | | 0% | 3 | 3 | 13 | 13 | 1 | 1 |
| markExternalErrorOnStreamers() | | 0% | | 0% | 8 | 8 | 14 | 14 | 1 | 1 |
| abort() | | 0% | | 0% | 3 | 3 | 16 | 16 | 1 | 1 |
| logCorruptBlocks() | | 0% | | 0% | 3 | 3 | 11 | 11 | 1 | 1 |
| closeThreads(boolean) | | 0% | | 0% | 3 | 3 | 17 | 17 | 1 | 1 |
| getExcludedNodes() | | 0% | | 0% | 4 | 4 | 7 | 7 | 1 | 1 |
| enqueueCurrentPacketFull() | | 0% | | n/a | 1 | 1 | 7 | 7 | 1 | 1 |
| enqueueAllCurrentPackets() | | 0% | | 0% | 4 | 4 | 10 | 10 | 1 | 1 |
| isStreamerWriting(int) | | 0% | | 0% | 5 | 5 | 8 | 8 | 1 | 1 |
| checkStreamerUpdates(Set, Set) | | 0% | | 0% | 5 | 5 | 7 | 7 | 1 | 1 |
| getBlockLengths() | | 0% | | 0% | 4 | 4 | 9 | 9 | 1 | 1 |
| writeParityCells() | | 0% | | 0% | 3 | 3 | 8 | 8 | 1 | 1 |
| checkAnyParityStreamerIsHealthy() | | 0% | | 0% | 4 | 4 | 6 | 6 | 1 | 1 |
| setCurrentStreamer(int) | | 0% | | 0% | 3 | 3 | 8 | 8 | 1 | 1 |
| handleStreamerFailure(String, Exception, StripedDataStreamer) | | 0% | | n/a | 1 | 1 | 6 | 6 | 1 | 1 |
| encode(RawErasureEncoder, int, ByteBuffer[]) | | 0% | | n/a | 1 | 1 | 6 | 6 | 1 | 1 |
| isClosed() | | 0% | | 0% | 4 | 4 | 7 | 7 | 1 | 1 |
| DFSStripedOutputStream(DFSClient, String, EnumSet, Progressable, LocatedBlock, HdfsFileStatus, DataChecksum, String[]) | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
| waitEndBlocks(int) | | 0% | | 0% | 3 | 3 | 7 | 7 | 1 | 1 |
| shouldEndBlockGroup() | | 0% | | 0% | 3 | 3 | 2 | 2 | 1 | 1 |
| setClosed() | | 0% | | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
| closeAllStreamers() | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
| sleep(long, String) | | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
| start() | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
| static {...} | | 0% | | 0% | 2 | 2 | 2 | 2 | 1 | 1 |
| handleCurrentStreamerFailure(String, Exception) | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| getStripedDataStreamer(int) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| stripeDataSize() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| hsync(EnumSet) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| useDirectBuffer() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getCurrentIndex() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getCurrentStreamer() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| hflush() | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| hsync() | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| getBlock() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| hasCapability(String) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |