Class ForwardingProcessorContext<T>
java.lang.Object
org.apache.storm.streams.processors.ForwardingProcessorContext<T>
- All Implemented Interfaces:
- Serializable,- ProcessorContext<T>
A context that emits the results to downstream processors which are in the same bolt.
- See Also:
- 
Constructor SummaryConstructorsConstructorDescriptionForwardingProcessorContext(ProcessorNode processorNode, org.apache.storm.shade.com.google.common.collect.Multimap<String, ProcessorNode> streamToChildren) 
- 
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- 
ForwardingProcessorContextpublic ForwardingProcessorContext(ProcessorNode processorNode, org.apache.storm.shade.com.google.common.collect.Multimap<String, ProcessorNode> streamToChildren) 
 
- 
- 
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
 
 
-