InternalProcessorContext¶

InternalProcessorContext is an extension of ProcessorContext and StateStoreContext abstractions.

Contract (Subset)¶

currentNode¶

ProcessorNode<?, ?, ?, ?> currentNode()

Current ProcessorNode (as set by setCurrentNode)

initialize¶

void initialize()

Used when:

• GlobalStateUpdateTask is requested to initialize
• StandbyTask is requested to initializeIfNeeded
• StreamTask is requested to completeRestoration

setCurrentNode¶

void setCurrentNode(
  ProcessorNode<?, ?, ?, ?> currentNode)

Sets the given ProcessorNode as the current node

Implementations¶

• AbstractProcessorContext