ProcessorContextImpl

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

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total464 of 4640%34 of 340%42421171172525
forward(Record, String)1020%140%88252511
getStateStore(String)550%60%44101011
transitionToActive(StreamTask, RecordCollector, ThreadCache)310%20%228811
transitionToStandby(ThreadCache)310%20%228811
forward(Object, Object, To)270%20%226611
schedule(Duration, PunctuationType, Punctuator)270%20%226611
logChange(String, Bytes, byte[], long)240%n/a117711
addAllFlushListenersToNewCache()230%20%224411
forwardInternal(ProcessorNode, Record)190%20%225511
throwUnsupportedOperationExceptionIfStandby(String)190%20%223311
ProcessorContextImpl(TaskId, StreamsConfig, ProcessorStateManager, StreamsMetricsImpl, ThreadCache)150%n/a114411
forward(Object, Object)140%n/a115511
registerCacheFlushListener(String, ThreadCache.DirtyEntryFlushListener)120%n/a113311
commit()70%n/a113311
setRecordContext(ProcessorRecordContext)70%n/a113311
topic()60%n/a112211
partition()60%n/a112211
offset()60%n/a112211
timestamp()60%n/a112211
currentNode()60%n/a112211
recordContext()60%n/a112211
forward(Record)50%n/a112211
currentStreamTimeMs()40%n/a111111
stateManager()30%n/a111111
recordCollector()30%n/a111111