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
AValueTransformerSupplierinterface which can create one or moreValueTransformerinstances.The supplier should always generate a new instance each time
get()gets called. Creating a singleValueTransformerobject 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 constructedValueTransformerinstance.-
Methods inherited from interface org.apache.kafka.streams.processor.ConnectedStoreProvider
stores
-
-
-
-
Method Detail
-
get
ValueTransformer<V,VR> get()
Return a newly constructedValueTransformerinstance. The supplier should always generate a new instance each timeget()gets called.Creating a single
ValueTransformerobject and returning the same object reference inget()is a violation of the supplier pattern and leads to runtime exceptions.- Returns:
- a new
ValueTransformerinstance
-
-