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 Summary
ConstructorsConstructorDescriptionForwardingProcessorContext(ProcessorNode processorNode, org.apache.storm.shade.com.google.common.collect.Multimap<String, ProcessorNode> streamToChildren) -
Method Summary
Modifier 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
-
ForwardingProcessorContext
public ForwardingProcessorContext(ProcessorNode processorNode, org.apache.storm.shade.com.google.common.collect.Multimap<String, ProcessorNode> streamToChildren)
-
-
Method Details
-
forward
Description copied from interface:ProcessorContextForwards the input to all downstream processors.- Specified by:
forwardin interfaceProcessorContext<T>- Parameters:
input- the input
-
forward
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
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
-