InternalProcessorContext Contract

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

Table 1. InternalProcessorContext Contract
Method Description

currentNode

ProcessorNode currentNode()

Used when…​FIXME

getCache

ThreadCache getCache()

Used when…​FIXME

initialize

void initialize()

Initializes the processor context

Used when:

metrics

StreamsMetricsImpl metrics()

Used when…​FIXME

recordContext

ProcessorRecordContext recordContext()

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:

Note
AbstractProcessorContext is the base implementation of the InternalProcessorContext Contract.

results matching ""

    No results matching ""