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