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

    All Methods Instance Methods Abstract Methods
    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 Detail

    - #### 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