Package org.apache.kafka.streams.processor.api

Interface FixedKeyProcessorSupplier<KIn,VIn,VOut>

Type Parameters:
KIn - the type of input keys
VIn - the type of input values
VOut - the type of output values
All Superinterfaces:
ConnectedStoreProvider, Supplier<FixedKeyProcessor<KIn,VIn,VOut>>
Functional Interface:
This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.
@FunctionalInterface public interface FixedKeyProcessorSupplier<KIn,VIn,VOut> extends ConnectedStoreProvider, Supplier<FixedKeyProcessor<KIn,VIn,VOut>>
A processor supplier that can create one or more FixedKeyProcessor instances.

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

  • Method Details

    • get

      FixedKeyProcessor<KIn,VIn,VOut> get()
      Return a newly constructed FixedKeyProcessor instance. The supplier should always generate a new instance each time FixedKeyProcessorSupplier#get() gets called.

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

      Specified by:
      get in interface Supplier<KIn>
      Returns:
      a new FixedKeyProcessor instance