MemoryRecordsBuilder

Source file "org/apache/kafka/common/record/MemoryRecordsBuilder.java" was not found during generation of report.

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total1,477 of 1,4770%144 of 1440%1351353163166363
MemoryRecordsBuilder(ByteBufferOutputStream, byte, CompressionType, TimestampType, long, long, long, short, int, boolean, boolean, int, int)1630%120%77414111
appendWithOffset(long, boolean, long, ByteBuffer, ByteBuffer, Header[])1170%200%1111181811
writeDefaultBatchHeader()780%20%22141411
close()770%100%66181811
hasRoomFor(long, ByteBuffer, ByteBuffer, Header[])670%120%77101011
recordWritten(long, long, int)640%80%55111111
info()630%120%77111111
writeLegacyCompressedWrapperHeader()590%20%22111111
appendUncheckedWithOffset(long, SimpleRecord)590%40%33181811
validateProducerState()560%140%88101011
appendLegacyRecord(long, long, ByteBuffer, ByteBuffer, byte)520%60%44101011
appendUncheckedWithOffset(long, LegacyRecord)420%n/a11101011
appendControlRecordWithOffset(long, SimpleRecord)350%20%227711
appendDefaultRecord(long, long, ByteBuffer, ByteBuffer, Header[])290%n/a116611
appendEndTxnMarker(long, EndTransactionMarker)280%40%337711
appendLeaderChangeMessage(long, LeaderChangeMessage)250%20%225511
reopenAndRewriteProducerState(long, short, int, boolean)240%20%228811
appendControlRecord(long, ControlRecordType, ByteBuffer)230%n/a116611
estimatedBytesWritten()230%20%223311
setProducerState(long, short, int, boolean)210%20%227711
MemoryRecordsBuilder(ByteBuffer, byte, CompressionType, TimestampType, long, long, long, short, int, boolean, boolean, int, int)190%n/a112211
closeForRecordAppends()170%20%226611
ensureOpenForRecordBatchWrite()170%40%335511
isFull()160%60%441111
append(Record)150%n/a112211
toInnerOffset(long)140%40%333311
build()130%20%224411
overrideLastOffset(long)130%20%224411
abort()120%n/a114411
appendWithOffset(long, SimpleRecord)120%n/a112211
appendWithOffset(long, Record)120%n/a112211
nextSequentialOffset()120%20%221111
appendWithOffset(long, long, byte[], byte[], Header[])110%n/a112211
appendWithOffset(long, long, byte[], byte[])100%n/a112211
appendWithOffset(long, LegacyRecord)100%n/a112211
ensureOpenForRecordAppend()100%20%223311
estimatedSizeInBytes()100%20%221111
appendWithOffset(long, long, ByteBuffer, ByteBuffer, Header[])90%n/a112211
append(long, ByteBuffer, ByteBuffer, Header[])90%n/a112211
append(long, byte[], byte[])90%n/a112211
append(long, byte[], byte[], Header[])90%n/a112211
hasRoomFor(long, byte[], byte[], Header[])90%n/a111111
appendWithOffset(long, long, ByteBuffer, ByteBuffer)80%n/a112211
appendSnapshotHeaderMessage(long, SnapshotHeaderRecord)80%n/a113311
appendSnapshotFooterMessage(long, SnapshotFooterRecord)80%n/a113311
static {...}80%n/a111111
append(long, ByteBuffer, ByteBuffer)70%n/a112211
isClosed()70%20%221111
uncompressedBytesWritten()60%n/a111111
append(SimpleRecord)60%n/a112211
append(LegacyRecord)60%n/a112211
buffer()40%n/a111111
initialCapacity()40%n/a111111
compressionRatio()40%n/a111111
setEstimatedCompressionRatio(float)40%n/a112211
compressionType()30%n/a111111
isControlBatch()30%n/a111111
isTransactional()30%n/a111111
numRecords()30%n/a111111
magic()30%n/a111111
producerId()30%n/a111111
producerEpoch()30%n/a111111
baseSequence()30%n/a111111