Class ProcessorParameters<K,​V>


  • public class ProcessorParameters<K,​V>
    extends java.lang.Object
    Class used to represent a 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 Detail

      • ProcessorParameters

        public ProcessorParameters​(ProcessorSupplier<K,​V> processorSupplier,
                                   java.lang.String processorName)
    • Method Detail

      • processorName

        public java.lang.String processorName()
      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object