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 Summary

Modifier and Type	Method and Description
FixedKeyProcessor<KIn,VIn,VOut>	get() Return a newly constructed FixedKeyProcessor instance.

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

stores

Method Detail

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<FixedKeyProcessor<KIn,VIn,VOut>>

Returns:

a new FixedKeyProcessor instance