Class ProcessorParameters<K,V>
- java.lang.Object
-
- org.apache.kafka.streams.kstream.internals.graph.ProcessorParameters<K,V>
-
public class ProcessorParameters<K,V> extends java.lang.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, java.lang.String processorName)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description java.lang.String
processorName()
ProcessorSupplier<K,V>
processorSupplier()
java.lang.String
toString()
-
-
-
Constructor Detail
-
ProcessorParameters
public ProcessorParameters(ProcessorSupplier<K,V> processorSupplier, java.lang.String processorName)
-
-
Method Detail
-
processorSupplier
public ProcessorSupplier<K,V> processorSupplier()
-
processorName
public java.lang.String processorName()
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-