Interface FixedKeyProcessorSupplier<KIn,VIn,VOut>
- Type Parameters:
KIn
- the type of input keysVIn
- the type of input valuesVOut
- the type of output values
- All Superinterfaces:
ConnectedStoreProvider
,Supplier<FixedKeyProcessor<KIn,
VIn, VOut>>
- Functional Interface:
- This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.
@FunctionalInterface
public interface FixedKeyProcessorSupplier<KIn,VIn,VOut>
extends ConnectedStoreProvider, Supplier<FixedKeyProcessor<KIn,VIn,VOut>>
A processor supplier that can create one or more
FixedKeyProcessor
instances.
The supplier should always generate a new instance each time get()
gets called. Creating
a single FixedKeyProcessor
object and returning the same object reference in get()
would be
a violation of the supplier pattern and leads to runtime exceptions.
-
Method Summary
Methods inherited from interface org.apache.kafka.streams.processor.ConnectedStoreProvider
stores
-
Method Details
-
get
FixedKeyProcessor<KIn,VIn, get()VOut> Return a newly constructedFixedKeyProcessor
instance. The supplier should always generate a new instance each timeFixedKeyProcessorSupplier#get()
gets called.Creating a single
FixedKeyProcessor
object and returning the same object reference inFixedKeyProcessorSupplier#get()
is a violation of the supplier pattern and leads to runtime exceptions.- Specified by:
get
in interfaceSupplier<KIn>
- Returns:
- a new
FixedKeyProcessor
instance
-