Class ChainedProcessorContext<T>
- java.lang.Object
-
- org.apache.storm.streams.processors.ChainedProcessorContext<T>
-
- All Implemented Interfaces:
Serializable,ProcessorContext<T>
public class ChainedProcessorContext<T> extends Object implements ProcessorContext<T>
A composite context that holds a chain ofProcessorContext.- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description ChainedProcessorContext(ProcessorNode processorNode, List<? extends ProcessorContext> contexts)ChainedProcessorContext(ProcessorNode processorNode, ProcessorContext... contexts)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidforward(T input)Forwards the input to all downstream processors.voidforward(T input, String stream)Forwards the input to downstream processors at specified stream.Set<String>getWindowedParentStreams()Returns the windowed parent streams.booleanisWindowed()Returns true if the processing is in a windowed context and should wait for punctuation before emitting results.
-
-
-
Constructor Detail
-
ChainedProcessorContext
public ChainedProcessorContext(ProcessorNode processorNode, List<? extends ProcessorContext> contexts)
-
ChainedProcessorContext
public ChainedProcessorContext(ProcessorNode processorNode, ProcessorContext... contexts)
-
-
Method Detail
-
forward
public void forward(T input)
Description copied from interface:ProcessorContextForwards the input to all downstream processors.- Specified by:
forwardin interfaceProcessorContext<T>- Parameters:
input- the input
-
forward
public void forward(T input, String stream)
Description copied from interface:ProcessorContextForwards the input to downstream processors at specified stream.- Specified by:
forwardin interfaceProcessorContext<T>- Parameters:
input- the inputstream- the stream to forward
-
isWindowed
public boolean isWindowed()
Description copied from interface:ProcessorContextReturns true if the processing is in a windowed context and should wait for punctuation before emitting results.- Specified by:
isWindowedin interfaceProcessorContext<T>- Returns:
- whether this is a windowed context or not
-
getWindowedParentStreams
public Set<String> getWindowedParentStreams()
Description copied from interface:ProcessorContextReturns the windowed parent streams. These are the streams where punctuations arrive.- Specified by:
getWindowedParentStreamsin interfaceProcessorContext<T>- Returns:
- the windowed parent streams
-
-