MemoryRecords

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

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total1,056 of 1,0560%62 of 620%83831881885252
filterTo(TopicPartition, Iterable, MemoryRecords.RecordFilter, ByteBuffer, int, BufferSupplier)2290%260%1414525211
buildRetainedRecordsInto(RecordBatch, List, ByteBufferOutputStream)740%80%55151511
withRecords(byte, long, CompressionType, TimestampType, long, short, int, int, boolean, SimpleRecord[])620%60%44111111
writeTo(TransferableChannel, long, int)560%40%336611
validBytes()300%40%337711
writeEndTransactionalMarker(ByteBuffer, long, long, int, long, short, EndTransactionMarker)270%n/a115511
writeLeaderChangeMessage(ByteBuffer, long, long, int, LeaderChangeMessage)250%n/a114411
writeSnapshotHeaderRecord(ByteBuffer, long, long, int, SnapshotHeaderRecord)250%n/a114411
writeSnapshotFooterRecord(ByteBuffer, long, long, int, SnapshotFooterRecord)250%n/a114411
writeFullyTo(GatheringByteChannel)240%20%226611
builder(ByteBuffer, CompressionType, TimestampType, long, int)240%20%224411
equals(Object)230%60%446611
withEndTransactionMarker(long, long, int, long, short, EndTransactionMarker)210%n/a115511
builder(ByteBuffer, byte, CompressionType, TimestampType, long)200%20%224411
builder(ByteBuffer, byte, CompressionType, TimestampType, long, long, long, short, int, boolean, boolean, int)180%n/a112211
MemoryRecords(ByteBuffer)170%n/a116611
toString()170%n/a111111
firstBatchSize()150%20%223311
builder(ByteBuffer, byte, CompressionType, TimestampType, long, long, long, short, int, boolean, int)140%n/a111111
builder(ByteBuffer, byte, CompressionType, TimestampType, long, long)130%n/a111111
builder(ByteBuffer, byte, CompressionType, TimestampType, long, long, int)130%n/a111111
builder(ByteBuffer, CompressionType, long, long, short, int, boolean)130%n/a111111
builder(ByteBuffer, byte, CompressionType, TimestampType, long, long, long, short, int)130%n/a111111
withRecords(long, CompressionType, Integer, SimpleRecord[])130%n/a112211
withRecords(CompressionType, int, SimpleRecord[])120%n/a111111
withIdempotentRecords(CompressionType, long, short, int, SimpleRecord[])120%n/a111111
withIdempotentRecords(byte, long, CompressionType, long, short, int, int, SimpleRecord[])120%n/a111111
withIdempotentRecords(long, CompressionType, long, short, int, int, SimpleRecord[])120%n/a111111
withTransactionalRecords(CompressionType, long, short, int, SimpleRecord[])120%n/a111111
withTransactionalRecords(byte, long, CompressionType, long, short, int, int, SimpleRecord[])120%n/a111111
withRecords(byte, long, CompressionType, TimestampType, SimpleRecord[])120%n/a111111
withLeaderChangeMessage(long, long, int, ByteBuffer, LeaderChangeMessage)120%n/a113311
withSnapshotHeaderRecord(long, long, int, ByteBuffer, SnapshotHeaderRecord)120%n/a113311
withSnapshotFooterRecord(long, long, int, ByteBuffer, SnapshotFooterRecord)120%n/a113311
batchIterator()110%n/a111111
idempotentBuilder(ByteBuffer, CompressionType, long, long, short, int)110%n/a112211
withTransactionalRecords(long, CompressionType, long, short, int, int, SimpleRecord[])100%n/a111111
filterTo(TopicPartition, MemoryRecords.RecordFilter, ByteBuffer, int, BufferSupplier)90%n/a111111
withEndTransactionMarker(long, short, EndTransactionMarker)80%n/a111111
withEndTransactionMarker(long, long, short, EndTransactionMarker)80%n/a111111
static {...}80%n/a112211
downConvert(byte, long, Time)70%n/a111111
builder(ByteBuffer, CompressionType, TimestampType, long)70%n/a111111
withRecords(byte, CompressionType, SimpleRecord[])70%n/a111111
withRecords(long, CompressionType, SimpleRecord[])70%n/a111111
withRecords(byte, long, CompressionType, SimpleRecord[])70%n/a111111
readableRecords(ByteBuffer)50%n/a111111
withRecords(CompressionType, SimpleRecord[])50%n/a111111
sizeInBytes()40%n/a111111
buffer()40%n/a111111
hashCode()40%n/a111111
batches()30%n/a111111