ClientState

Source file "org/apache/kafka/streams/processor/internals/assignment/ClientState.java" was not found during generation of report.

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total1,099 of 1,0990%66 of 660%95951801806262
computeTaskLags(UUID, Map)1120%100%66161611
ClientState(Set, Set, Map, int)870%n/a11141411
ClientState(int)860%n/a11141411
initializeRemainingPrevTasksFromTaskOffsetSums()590%100%66131311
hasMoreAvailableCapacityThan(ClientState)530%100%66111111
toString()530%n/a117711
prevOwnedStandbyByConsumer()490%40%339911
initializePrevActiveTasksFromOwnedPartitions(Map)440%40%339911
assignActiveToConsumer(TaskId, String)310%20%225511
unassignActive(TaskId)290%20%225511
unassignStandby(TaskId)290%20%225511
assertNotAssigned(TaskId)290%40%333311
assignedTasks()240%n/a114411
previousAssignedTasks()230%n/a113311
lagFor(TaskId)230%20%224411
initializePrevTasks(Map)210%40%335511
currentAssignment()190%n/a112211
addOwnedPartitions(Collection, String)180%20%224411
hasAssignedTask(TaskId)160%40%331111
hasUnfulfilledQuota(int)130%20%221111
addPreviousTasksAndOffsetSums(String, Map)120%n/a113311
assignStandbyToConsumer(TaskId, String)110%n/a112211
revokeActiveFromConsumer(TaskId, String)110%n/a112211
statefulActiveTasks()110%n/a111111
statelessActiveTasks()110%n/a111111
assignActive(TaskId)100%n/a113311
assignStandby(TaskId)100%n/a113311
reachedCapacity()90%20%221111
lambda$previousAssignedTasks$4(Set, Set)90%n/a111111
lambda$assignedTasks$3(Set, Set)90%n/a111111
static {...}90%n/a112211
activeTaskLoad()80%n/a111111
assignedTaskLoad()80%n/a111111
lambda$statelessActiveTasks$5(TaskId)80%20%221111
incrementCapacity()70%n/a112211
assignActiveTasks(Collection)70%n/a112211
addPreviousActiveTask(TaskId)70%n/a112211
addPreviousActiveTasks(Set)70%n/a112211
addPreviousStandbyTask(TaskId)70%n/a112211
addPreviousStandbyTasks(Set)70%n/a112211
prevOwnedStatefulTasksByConsumer(String)60%n/a111111
hasStandbyTask(TaskId)60%n/a111111
assignedTaskCount()60%n/a111111
previousOwnerForPartition(TopicPartition)60%n/a111111
activeTasks()50%n/a111111
activeTaskCount()50%n/a111111
standbyTasks()50%n/a111111
standbyTaskCount()50%n/a111111
prevActiveTasks()50%n/a111111
prevStandbyTasks()50%n/a111111
consumers()50%n/a111111
isStateful(TaskId)50%n/a111111
ClientState()40%n/a112211
prevOwnedActiveTasksByConsumer()40%n/a111111
assignedActiveTasksByConsumer()40%n/a111111
revokingActiveTasksByConsumer()40%n/a111111
assignedStandbyTasksByConsumer()40%n/a111111
lambda$initializePrevActiveTasksFromOwnedPartitions$6(String)40%n/a111111
lambda$revokeActiveFromConsumer$2(String)40%n/a111111
lambda$assignStandbyToConsumer$1(String)40%n/a111111
lambda$assignActiveToConsumer$0(String)40%n/a111111
capacity()30%n/a111111