Package org.apache.kafka.streams.kstream

Interface TransformerSupplier<K,V,R>

Type Parameters:

K - key type

V - value type

R - 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>>

A TransformerSupplier interface which can create one or more Transformer instances.

The supplier should always generate a new instance each time get() gets called. Creating a single Transformer object and returning the same object reference in get() would be a violation of the supplier pattern and leads to runtime exceptions.

See Also:

• Transformer
• KStream.transform(TransformerSupplier, String...)
• ValueTransformer
• ValueTransformerSupplier
• KStream.transformValues(ValueTransformerSupplier, String...)

Method Summary

Modifier and Type	Method	Description
Transformer<K,V,R>	get()	Return a newly constructed Transformer instance.

Methods inherited from interface org.apache.kafka.streams.processor.ConnectedStoreProvider

stores

Method Details

get

Transformer<K,V,R> get()

Return a newly constructed Transformer instance. The supplier should always generate a new instance each time gets called.

Creating a single Transformer object and returning the same object reference in get() is a violation of the supplier pattern and leads to runtime exceptions.

Specified by:

get in interface Supplier<K>

Returns:

a newly constructed Transformer instance