Skip to content

Latest commit

 

History

History
25 lines (16 loc) · 706 Bytes

kafka-streams-ProcessorContextImpl.adoc

File metadata and controls

25 lines (16 loc) · 706 Bytes

ProcessorContextImpl

ProcessorContextImpl is a AbstractProcessorContext that…​FIXME

getStateStore Method

StateStore getStateStore(final String name)
Note
getStateStore is part of ProcessorContext Contract to get the state store per name.

getStateStore…​FIXME

schedule Method

Cancellable schedule(final long interval, final PunctuationType type, final Punctuator callback)
Note
schedule is part of ProcessorContext Contract to…​FIXME.

schedule…​FIXME