org.apache.storm.streams.processors

Class ChainedProcessorContext

java.lang.Object

org.apache.storm.streams.processors.ChainedProcessorContext

All Implemented Interfaces:

Serializable, ProcessorContext

public class ChainedProcessorContext
extends Object
implements ProcessorContext

A composite context that holds a chain of ProcessorContext.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
ChainedProcessorContext(ProcessorNode processorNode, List<? extends ProcessorContext> contexts)
ChainedProcessorContext(ProcessorNode processorNode, ProcessorContext... contexts)

Method Summary

Modifier and Type	Method and Description
<T> void	forward(T input) Forwards the input to all downstream processors.
<T> 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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ChainedProcessorContext

public ChainedProcessorContext(ProcessorNode processorNode,
                               List<? extends ProcessorContext> contexts)

ChainedProcessorContext

public ChainedProcessorContext(ProcessorNode processorNode,
                               ProcessorContext... contexts)

Method Detail

forward

public <T> void forward(T input)

Description copied from interface: ProcessorContext

Forwards the input to all downstream processors.

Specified by:

forward in interface ProcessorContext

Parameters:

input - the input

forward

public <T> 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

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

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

Returns:

the windowed parent streams