Interface WrappedFixedKeyProcessorSupplier<KIn,VIn,VOut>
- All Superinterfaces:
ConnectedStoreProvider,FixedKeyProcessorSupplier<KIn,,VIn, VOut> Supplier<FixedKeyProcessor<KIn,VIn, VOut>>
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