Interface ProcessorSupplier<K,V>
-
- Type Parameters:
K
- the type of keysV
- the type of values
- All Superinterfaces:
ConnectedStoreProvider
- All Known Subinterfaces:
KStreamAggProcessorSupplier<K,RK,V,T>
,KTableProcessorSupplier<K,V,T>
- All Known Implementing Classes:
ForeignJoinSubscriptionProcessorSupplier
,ForeignJoinSubscriptionSendProcessorSupplier
,KStreamAggregate
,KStreamFlatTransform
,KStreamFlatTransformValues
,KStreamPrint
,KStreamReduce
,KStreamSessionWindowAggregate
,KStreamTransformValues
,KStreamWindowAggregate
,KTableAggregate
,KTableKTableJoinMerger
,KTableReduce
,KTableRepartitionMap
,KTableSource
,KTableSuppressProcessorSupplier
,SubscriptionJoinForeignProcessorSupplier
,SubscriptionResolverJoinProcessorSupplier
,SubscriptionStoreReceiveProcessorSupplier
public interface ProcessorSupplier<K,V> extends ConnectedStoreProvider
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description Processor<K,V>
get()
Return a newProcessor
instance.-
Methods inherited from interface org.apache.kafka.streams.processor.ConnectedStoreProvider
stores
-
-