Package org.apache.kafka.streams.kstream
Interface ValueTransformerSupplier<V,VR>
-
- Type Parameters:
V
- value typeVR
- transformed value type
- All Superinterfaces:
ConnectedStoreProvider
public interface ValueTransformerSupplier<V,VR> extends ConnectedStoreProvider
AValueTransformerSupplier
interface which can create one or moreValueTransformer
instances.The supplier should always generate a new instance each time
get()
gets called. Creating a singleValueTransformer
object and returning the same object reference inget()
would be a violation of the supplier pattern and leads to runtime exceptions.- See Also:
ValueTransformer
,ValueTransformerWithKey
,ValueTransformerWithKeySupplier
,KStream.transformValues(ValueTransformerSupplier, String...)
,KStream.transformValues(ValueTransformerWithKeySupplier, String...)
,Transformer
,TransformerSupplier
,KStream.transform(TransformerSupplier, String...)
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description ValueTransformer<V,VR>
get()
Return a newly constructedValueTransformer
instance.-
Methods inherited from interface org.apache.kafka.streams.processor.ConnectedStoreProvider
stores
-
-
-
-
Method Detail
-
get
ValueTransformer<V,VR> get()
Return a newly constructedValueTransformer
instance. The supplier should always generate a new instance each timeget()
gets called.Creating a single
ValueTransformer
object and returning the same object reference inget()
is a violation of the supplier pattern and leads to runtime exceptions.- Returns:
- a new
ValueTransformer
instance
-
-