Class ChainedProcessorContext<T>
java.lang.Object
org.apache.storm.streams.processors.ChainedProcessorContext<T>
- All Implemented Interfaces:
- Serializable,- ProcessorContext<T>
A composite context that holds a chain of 
ProcessorContext.- See Also:
- 
Constructor SummaryConstructorsConstructorDescriptionChainedProcessorContext(ProcessorNode processorNode, List<? extends ProcessorContext> contexts) ChainedProcessorContext(ProcessorNode processorNode, ProcessorContext... contexts) 
- 
Method SummaryModifier and TypeMethodDescriptionvoidForwards the input to all downstream processors.voidForwards the input to downstream processors at specified stream.Returns the windowed parent streams.booleanReturns true if the processing is in a windowed context and should wait for punctuation before emitting results.
- 
Constructor Details- 
ChainedProcessorContextpublic ChainedProcessorContext(ProcessorNode processorNode, List<? extends ProcessorContext> contexts) 
- 
ChainedProcessorContext
 
- 
- 
Method Details- 
forwardDescription copied from interface:ProcessorContextForwards the input to all downstream processors.- Specified by:
- forwardin interface- ProcessorContext<T>
- Parameters:
- input- the input
 
- 
forwardDescription copied from interface:ProcessorContextForwards the input to downstream processors at specified stream.- Specified by:
- forwardin interface- ProcessorContext<T>
- Parameters:
- input- the input
- stream- the stream to forward
 
- 
isWindowedpublic 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 interface- ProcessorContext<T>
- Returns:
- whether this is a windowed context or not
 
- 
getWindowedParentStreamsDescription copied from interface:ProcessorContextReturns the windowed parent streams. These are the streams where punctuations arrive.- Specified by:
- getWindowedParentStreamsin interface- ProcessorContext<T>
- Returns:
- the windowed parent streams
 
 
-