Interface InternalProcessorContext
-
- All Superinterfaces:
ProcessorContext
- All Known Implementing Classes:
AbstractProcessorContext
,GlobalProcessorContextImpl
,ProcessorContextImpl
public interface InternalProcessorContext extends ProcessorContext
For internal use so we can update theRecordContext
and currentProcessorNode
when we are forwarding items that have been evicted or flushed fromThreadCache
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description ProcessorNode
currentNode()
ThreadCache
getCache()
Get the thread-global cachevoid
initialize()
Mark this context as being initializedStreamsMetricsImpl
metrics()
Returns Metrics instanceProcessorRecordContext
recordContext()
Returns the currentRecordContext
void
setCurrentNode(ProcessorNode currentNode)
void
setRecordContext(ProcessorRecordContext recordContext)
long
streamTime()
void
uninitialize()
Mark this context as being uninitialized-
Methods inherited from interface org.apache.kafka.streams.processor.ProcessorContext
appConfigs, appConfigsWithPrefix, applicationId, applicationInternalStream, commit, forward, forward, forward, forward, getStateStore, headers, keySerde, offset, partition, register, schedule, schedule, stateDir, taskId, timestamp, topic, valueSerde
-
-
-
-
Method Detail
-
metrics
StreamsMetricsImpl metrics()
Description copied from interface:ProcessorContext
Returns Metrics instance- Specified by:
metrics
in interfaceProcessorContext
- Returns:
- StreamsMetrics
-
recordContext
ProcessorRecordContext recordContext()
Returns the currentRecordContext
- Returns:
- the current
RecordContext
-
setRecordContext
void setRecordContext(ProcessorRecordContext recordContext)
- Parameters:
recordContext
- theProcessorRecordContext
for the record about to be processes
-
setCurrentNode
void setCurrentNode(ProcessorNode currentNode)
- Parameters:
currentNode
- the currentProcessorNode
-
currentNode
ProcessorNode currentNode()
-
getCache
ThreadCache getCache()
Get the thread-global cache
-
initialize
void initialize()
Mark this context as being initialized
-
uninitialize
void uninitialize()
Mark this context as being uninitialized
-
streamTime
long streamTime()
-
-