InternalProcessorContext
is the contract of ProcessorContexts that…FIXME
package org.apache.kafka.streams.processor.internals;
interface InternalProcessorContext extends ProcessorContext {
RecordContext recordContext();
void setRecordContext(RecordContext recordContext);
void setCurrentNode(ProcessorNode currentNode);
ProcessorNode currentNode();
ThreadCache getCache();
void initialized();
void uninitialize();
}
Method | Description |
---|---|