Class ProcessorParameters<K,V>
- java.lang.Object
-
- org.apache.kafka.streams.kstream.internals.graph.ProcessorParameters<K,V>
-
public class ProcessorParameters<K,V> extends Object
Class used to represent aProcessorSupplier
and the name used to register it with theInternalTopologyBuilder
Used by the Join nodes as there are several parameters, this abstraction helps keep the number of arguments more reasonable.
-
-
Constructor Summary
Constructors Constructor Description ProcessorParameters(ProcessorSupplier<K,V> processorSupplier, String processorName)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description String
processorName()
ProcessorSupplier<K,V>
processorSupplier()
String
toString()
-
-
-
Constructor Detail
-
ProcessorParameters
public ProcessorParameters(ProcessorSupplier<K,V> processorSupplier, String processorName)
-
-