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