Class ProcessorNode

All Implemented Interfaces:

public class ProcessorNode extends Object
Node that wraps a processor in the stream.
See Also:
  • Field Details

    • outputFields

      protected final Fields outputFields
    • groupingInfo

      protected org.apache.storm.streams.GroupingInfo groupingInfo
    • componentId

      protected String componentId
    • parallelism

      protected int parallelism
  • Constructor Details

    • ProcessorNode

      public ProcessorNode(Processor<?> processor, String outputStream, Fields outputFields, boolean preservesKey)
    • ProcessorNode

      public ProcessorNode(Processor<?> processor, String outputStream, Fields outputFields)
  • Method Details

    • getProcessor

      public Processor<?> getProcessor()
    • isBatch

      public boolean isBatch()
    • getWindowedParentStreams

      public Set<String> getWindowedParentStreams()
    • isPreservesKey

      public boolean isPreservesKey()
    • toString

      public String toString()
    • getOutputFields

      public Fields getOutputFields()
    • isWindowed

      public boolean isWindowed()
    • setWindowed

      public void setWindowed(boolean windowed)
    • emitsPair

      public boolean emitsPair()
    • setEmitsPair

      public void setEmitsPair(boolean emitsPair)