public interface InternalProcessorContext extends ProcessorContext
RecordContext
and current
ProcessorNode
when we are forwarding items that have been evicted or flushed from
ThreadCache
Modifier and Type | Method and Description |
---|---|
ProcessorNode |
currentNode() |
ThreadCache |
getCache()
Get the thread-global cache
|
void |
initialize()
Mark this context as being initialized
|
StreamsMetricsImpl |
metrics()
Returns Metrics instance
|
ProcessorRecordContext |
recordContext()
Returns the current
RecordContext |
void |
setCurrentNode(ProcessorNode currentNode) |
void |
setRecordContext(ProcessorRecordContext recordContext) |
long |
streamTime() |
void |
uninitialize()
Mark this context as being uninitialized
|
appConfigs, appConfigsWithPrefix, applicationId, applicationInternalStream, commit, forward, forward, forward, forward, getStateStore, headers, keySerde, offset, partition, register, schedule, schedule, stateDir, taskId, timestamp, topic, valueSerde
StreamsMetricsImpl metrics()
ProcessorContext
metrics
in interface ProcessorContext
ProcessorRecordContext recordContext()
RecordContext
RecordContext
void setRecordContext(ProcessorRecordContext recordContext)
recordContext
- the ProcessorRecordContext
for the record about to be processesvoid setCurrentNode(ProcessorNode currentNode)
currentNode
- the current ProcessorNode
ProcessorNode currentNode()
ThreadCache getCache()
void initialize()
void uninitialize()
long streamTime()