Class ForwardingProcessorContext<T>

java.lang.Object
org.apache.storm.streams.processors.ForwardingProcessorContext<T>
All Implemented Interfaces:
Serializable, ProcessorContext<T>

public class ForwardingProcessorContext<T> extends Object implements ProcessorContext<T>
A context that emits the results to downstream processors which are in the same bolt.
See Also:
  • Constructor Details

    • ForwardingProcessorContext

      public ForwardingProcessorContext(ProcessorNode processorNode, org.apache.storm.shade.com.google.common.collect.Multimap<String,ProcessorNode> streamToChildren)
  • Method Details

    • forward

      public void forward(T input)
      Description copied from interface: ProcessorContext
      Forwards the input to all downstream processors.
      Specified by:
      forward in interface ProcessorContext<T>
      Parameters:
      input - the input
    • forward

      public void forward(T input, String stream)
      Description copied from interface: ProcessorContext
      Forwards the input to downstream processors at specified stream.
      Specified by:
      forward in interface ProcessorContext<T>
      Parameters:
      input - the input
      stream - the stream to forward
    • isWindowed

      public boolean isWindowed()
      Description copied from interface: ProcessorContext
      Returns true if the processing is in a windowed context and should wait for punctuation before emitting results.
      Specified by:
      isWindowed in interface ProcessorContext<T>
      Returns:
      whether this is a windowed context or not
    • getWindowedParentStreams

      public Set<String> getWindowedParentStreams()
      Description copied from interface: ProcessorContext
      Returns the windowed parent streams. These are the streams where punctuations arrive.
      Specified by:
      getWindowedParentStreams in interface ProcessorContext<T>
      Returns:
      the windowed parent streams