Class ProcessorNode<K,​V>

  • Direct Known Subclasses:
    SinkNode, SourceNode

    public class ProcessorNode<K,​V>
    extends java.lang.Object
    • Field Detail

      • stateStores

        public final java.util.Set<java.lang.String> stateStores
    • Constructor Detail

      • ProcessorNode

        public ProcessorNode​(java.lang.String name)
      • ProcessorNode

        public ProcessorNode​(java.lang.String name,
                             Processor<K,​V> processor,
                             java.util.Set<java.lang.String> stateStores)
    • Method Detail

      • name

        public final java.lang.String name()
      • processor

        public final Processor<K,​V> processor()
      • children

        public java.util.List<ProcessorNode<?,​?>> children()
      • addChild

        public void addChild​(ProcessorNode<?,​?> child)
      • close

        public void close()
      • process

        public void process​(K key,
                            V value)
      • punctuate

        public void punctuate​(long timestamp,
                              Punctuator punctuator)
      • isTerminalNode

        public boolean isTerminalNode()
      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object
        Returns:
        a string representation of this node, useful for debugging.
      • toString

        public java.lang.String toString​(java.lang.String indent)
        Returns:
        a string representation of this node starting with the given indent, useful for debugging.