public class ProcessorParameters<K,V>
extends java.lang.Object
ProcessorSupplier
and the name
used to register it with the InternalTopologyBuilder
Used by the Join nodes as there are several parameters, this abstraction helps
keep the number of arguments more reasonable.Constructor and Description |
---|
ProcessorParameters(ProcessorSupplier<K,V> processorSupplier,
java.lang.String processorName) |
Modifier and Type | Method and Description |
---|---|
java.lang.String |
processorName() |
ProcessorSupplier<K,V> |
processorSupplier() |
java.lang.String |
toString() |
public ProcessorParameters(ProcessorSupplier<K,V> processorSupplier, java.lang.String processorName)
public ProcessorSupplier<K,V> processorSupplier()
public java.lang.String processorName()
public java.lang.String toString()
toString
in class java.lang.Object