InternalProcessorContext Contract

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.

results matching ""