KIn- the type of input keys
VIn- the type of input values
KOut- the type of output keys
VOut- the type of output values
@FunctionalInterface public interface ProcessorSupplier<KIn,VIn,KOut,VOut> extends ConnectedStoreProvider, Supplier<Processor<KIn,VIn,KOut,VOut>>
It is used in
Topology for adding new processor operators, whose generated
topology can then be replicated (and thus creating one or more
and distributed to multiple stream threads.
The supplier should always generate a new instance each time
get() gets called. Creating
Processor object and returning the same object reference in
get() would be
a violation of the supplier pattern and leads to runtime exceptions.
Processorinstance. The supplier should always generate a new instance each time