Package org.apache.storm.streams.processors

Interface ProcessorContext<T>

All Superinterfaces:
Serializable
All Known Implementing Classes:
ChainedProcessorContext, EmittingProcessorContext, ForwardingProcessorContext
@Unstable public interface ProcessorContext<T> extends Serializable
Context information passed to the Processor.

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    forward(T input)
    Forwards the input to all downstream processors.
    void
    forward(T input, String stream)
    Forwards the input to downstream processors at specified stream.
    Set<String>
    getWindowedParentStreams()
    Returns the windowed parent streams.
    boolean
    isWindowed()
    Returns true if the processing is in a windowed context and should wait for punctuation before emitting results.

  • Method Details

    • forward

      void forward(T input)
      Forwards the input to all downstream processors.
      Parameters:
      input - the input

    • forward

      void forward(T input, String stream)
      Forwards the input to downstream processors at specified stream.
      Parameters:
      input - the input
      stream - the stream to forward

    • isWindowed

      boolean isWindowed()
      Returns true if the processing is in a windowed context and should wait for punctuation before emitting results.
      Returns:
      whether this is a windowed context or not

    • getWindowedParentStreams

      Set<String> getWindowedParentStreams()
      Returns the windowed parent streams. These are the streams where punctuations arrive.
      Returns:
      the windowed parent streams