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