Class TransformerSupplierAdapter<KIn,VIn,KOut,VOut>
- java.lang.Object
-
- org.apache.kafka.streams.kstream.internals.TransformerSupplierAdapter<KIn,VIn,KOut,VOut>
-
- All Implemented Interfaces:
TransformerSupplier<KIn,VIn,Iterable<KeyValue<KOut,VOut>>>
,ConnectedStoreProvider
public class TransformerSupplierAdapter<KIn,VIn,KOut,VOut> extends Object implements TransformerSupplier<KIn,VIn,Iterable<KeyValue<KOut,VOut>>>
-
-
Constructor Summary
Constructors Constructor Description TransformerSupplierAdapter(TransformerSupplier<KIn,VIn,KeyValue<KOut,VOut>> transformerSupplier)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Transformer<KIn,VIn,Iterable<KeyValue<KOut,VOut>>>
get()
Return a newTransformer
instance.Set<StoreBuilder<?>>
stores()
-
-
-
Method Detail
-
get
public Transformer<KIn,VIn,Iterable<KeyValue<KOut,VOut>>> get()
Description copied from interface:TransformerSupplier
Return a newTransformer
instance.- Specified by:
get
in interfaceTransformerSupplier<KIn,VIn,KOut>
- Returns:
- a new
Transformer
instance
-
stores
public Set<StoreBuilder<?>> stores()
- Specified by:
stores
in interfaceConnectedStoreProvider
- Returns:
- the state stores to be connected and added, or null if no stores should be automatically connected and added.
-
-