OlapTableStream

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total155 of 63575%24 of 8270%206826130227
appendConsumptionRow(List, String, String, long, String, boolean, long, long, boolean, long)900%40%33141411
fillTableStreamConsumptionInfo(List)350%60%449911
snapshotPartition(Partition)183666%8642%780901
fillTableStreamConsumptionInfo(List, Predicate)91866%1375%131501
snapshotTableStreamConsumptionInfo()23494%2466%2411001
initializeLocalOffsets()12395%1375%1311101
generateDynamicSchema()73100%8100%0501901
unprotectedUpdateStreamUpdate(AbstractTableStreamUpdate, Long)33100%2100%020501
unprotectedCollectStalePartitionOffsetIds(Set)31100%4100%030701
getStreamUpdate(Long)28100%4100%030401
hasData(Partition)26100%1787%150301
hasConsumedData(long)22100%6100%040201
unprotectedPrunePartitionOffsets(Set)21100%2100%020501
hasHistoricalData(long)16100%4100%030201
lambda$initializeLocalOffsets$2(Partition)15100%n/a010201
lambda$initializeLocalOffsets$0(Partition)15100%n/a010101
OlapTableStream(long, String, TableIf)14100%n/a010401
getBaseTableNullable()13100%1375%130401
unprotectedCheckStreamUpdate(AbstractTableStreamUpdate)13100%n/a010301
lambda$initializeLocalOffsets$1(Partition)9100%2100%020101
OlapTableStream()8100%n/a010301
read(DataInput)7100%n/a010101
write(DataOutput)7100%n/a010201
OlapTableStream(String, TableIf)6100%n/a010201
setProperties(Map)6100%n/a010301
setPropertiesWithoutOffsetInitialization(Map)4100%n/a010201
getTableStreamType()2100%n/a010101