Tasks

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

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total692 of 6920%42 of 420%52521361363131
createTasks(Map, Map)1490%180%1010242411
Tasks(String, InternalTopologyBuilder, StreamsMetricsImpl, ActiveTaskCreator, StandbyTaskCreator)850%n/a11191911
updateInputPartitionsAndResume(Task, Set)760%100%66131311
convertActiveToStandby(StreamTask, Set, Map)660%20%22121211
convertStandbyToActive(StandbyTask, Set)600%40%339911
removeTaskBeforeClosing(TaskId)370%n/a119911
cleanUpTaskProducerAndRemoveTask(TaskId, Map)290%n/a118811
addTask(Task)260%20%225511
standbyTask(TaskId)230%20%223311
task(TaskId)230%20%223311
tasks(Collection)230%20%225511
clear()130%n/a115511
lambda$convertActiveToStandby$0(StreamTask, Map.Entry)80%n/a111111
lambda$removeTaskBeforeClosing$1(TaskId, Map.Entry)70%n/a111111
closeAndRemoveTaskProducerIfNeeded(Task)60%n/a112211
activeTasksForInputPartition(TopicPartition)60%n/a111111
owned(TaskId)50%n/a111111
streamsProducerForTask(TaskId)50%n/a111111
setMainConsumer(Consumer)40%n/a112211
reInitializeThreadProducer()40%n/a112211
closeThreadProducerIfNeeded()40%n/a112211
threadProducer()40%n/a111111
producerMetrics()40%n/a111111
producerClientIds()40%n/a111111
activeTasks()30%n/a111111
allTasks()30%n/a111111
activeTaskIds()30%n/a111111
standbyTaskIds()30%n/a111111
activeTaskMap()30%n/a111111
standbyTaskMap()30%n/a111111
tasksPerId()30%n/a111111