kafka-streams-internals-InternalProcessorContext.adoc

InternalProcessorContext Contract

InternalProcessorContext is the extension of the ProcessorContext contract for internal processor contexts.

Table 1. InternalProcessorContext Contract

Method	Description
currentNode	ProcessorNode currentNode() ProcessorNode Used when…​FIXME
getCache	ThreadCache getCache() ThreadCache Used when…​FIXME
initialize	void initialize() Initializes the processor context Used when: GlobalStateUpdateTask is requested to initialize StandbyTask is requested to initialize state stores StreamTask is requested to initialize a topology
metrics	StreamsMetricsImpl metrics() StreamsMetricsImpl Used when…​FIXME
recordContext	ProcessorRecordContext recordContext() ProcessorRecordContext Used when…​FIXME
setCurrentNode	void setCurrentNode(ProcessorNode currentNode) Sets the current ProcessorNode Used when…​FIXME
setRecordContext	void setRecordContext(ProcessorRecordContext recordContext) Sets the current ProcessorRecordContext Used when…​FIXME
streamTime	long streamTime() Stream time Used when…​FIXME
uninitialize	void uninitialize() Uninitializes the processor context Used when: AbstractStateManager is requested to reinitializeStateStoresForPartitions AbstractTask is requested to registerStateStores

Note	AbstractProcessorContext is the base implementation of the InternalProcessorContext Contract.