Interface WrappedFixedKeyProcessorSupplier<KIn,VIn,VOut>
- All Superinterfaces:
ConnectedStoreProvider,FixedKeyProcessorSupplier<KIn,,VIn, VOut> 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 WrappedFixedKeyProcessorSupplier<KIn,VIn,VOut>
extends FixedKeyProcessorSupplier<KIn,VIn,VOut>
Marker interface for classes implementing
FixedKeyProcessorSupplier
that have been wrapped via a ProcessorWrapper.
To convert a FixedKeyProcessorSupplier instance into a WrappedFixedKeyProcessorSupplier,
use the ProcessorWrapper.asWrappedFixedKey(FixedKeyProcessorSupplier) method
-
Method Summary
Methods inherited from interface org.apache.kafka.streams.processor.ConnectedStoreProvider
storesMethods inherited from interface org.apache.kafka.streams.processor.api.FixedKeyProcessorSupplier
get