KinesisShardTopology

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total861 of 8610%128 of 1280%1001001891893636
mergeShardInfos(List, String, Map)1440%300%1616323211
pruneExpiredCompletedShards(Set)970%160%99171711
reconcileNodeState(KinesisShardTopology.ShardNode)600%180%1010141411
mergeChildShardInfos(Map)440%60%44101011
getSourceShardIds(boolean)400%100%667711
getReadyShardIds()370%80%558811
getUnresolvedLatestShardIds()360%80%558811
resolveInitialPositions(Map)340%40%337711
reconcileConcretePositions(Map)330%60%447711
equals(Object)290%80%555511
completeVisibleShards(long)270%40%337711
resetInitialPosition(String, String)270%20%225511
markEndCommitted(String, long)250%20%227711
markCompleted(String)220%n/a116611
hashCode()200%n/a111111
markDraining(String)200%n/a115511
copy()190%n/a115511
addExplicitShard(String, String)170%n/a116611
reconcileStates()170%20%224411
addParent(KinesisShardTopology.ShardNode, String)140%n/a113311
isLatest(String)120%40%332211
reset()100%n/a114411
getStartPosition(String)90%n/a111111
lambda$getOrCreate$1(String)90%n/a113311
KinesisShardTopology()80%n/a112211
lambda$copy$0(KinesisShardTopology, String, KinesisShardTopology.ShardNode)80%n/a111111
getOrCreate(String)70%n/a111111
mergeShardInfos(List, String, String)60%n/a112211
setInitialSnapshotFinalized(boolean)40%n/a112211
getNodes()40%n/a111111
toJson()40%n/a111111
mergeChildShardInfos(Map, String)40%n/a112211
getOpenShardIds()40%n/a111111
getClosedShardIds()40%n/a111111
isInitialSnapshotFinalized()30%n/a111111
getLineageError()30%n/a111111