Package org.apache.kafka.streams.kstream
Interface TransformerSupplier<K,V,R>
-
- Type Parameters:
K
- key typeV
- value typeR
-KeyValue
return type (both key and value type can be set arbitrarily)
- All Superinterfaces:
ConnectedStoreProvider
,Supplier<Transformer<K,V,R>>
public interface TransformerSupplier<K,V,R> extends ConnectedStoreProvider, Supplier<Transformer<K,V,R>>
ATransformerSupplier
interface which can create one or moreTransformer
instances.The supplier should always generate a new instance each time
get()
gets called. Creating a singleTransformer
object and returning the same object reference inget()
would be a violation of the supplier pattern and leads to runtime exceptions.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description Transformer<K,V,R>
get()
Return a newly constructedTransformer
instance.-
Methods inherited from interface org.apache.kafka.streams.processor.ConnectedStoreProvider
stores
-
-
-
-
Method Detail
-
get
Transformer<K,V,R> get()
Return a newly constructedTransformer
instance. The supplier should always generate a new instance each timegets called
.Creating a single
Transformer
object and returning the same object reference inget()
is a violation of the supplier pattern and leads to runtime exceptions.- Specified by:
get
in interfaceSupplier<K>
- Returns:
- a newly constructed
Transformer
instance
-
-