org.apache.storm.streams.processors

Interface ProcessorContext<T>

All Superinterfaces:

Serializable

All Known Implementing Classes:

ChainedProcessorContext, EmittingProcessorContext, ForwardingProcessorContext

@InterfaceStability.Unstable
public interface ProcessorContext<T>
extends Serializable

Context information passed to the Processor.

Method Summary

Modifier and Type	Method and 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