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 Summary
ConstructorDescriptionChainedProcessorContext
(ProcessorNode processorNode, List<? extends ProcessorContext> contexts) ChainedProcessorContext
(ProcessorNode processorNode, ProcessorContext... contexts) -
Method Summary
Modifier and TypeMethodDescriptionvoid
Forwards the input to all downstream processors.void
Forwards the input to downstream processors at specified stream.Returns the windowed parent streams.boolean
Returns true if the processing is in a windowed context and should wait for punctuation before emitting results.
-
Constructor Details
-
ChainedProcessorContext
public ChainedProcessorContext(ProcessorNode processorNode, List<? extends ProcessorContext> contexts) -
ChainedProcessorContext
-
-
Method Details
-
forward
Description copied from interface:ProcessorContext
Forwards the input to all downstream processors.- Specified by:
forward
in interfaceProcessorContext<T>
- Parameters:
input
- the input
-
forward
Description copied from interface:ProcessorContext
Forwards the input to downstream processors at specified stream.- Specified by:
forward
in interfaceProcessorContext<T>
- Parameters:
input
- the inputstream
- the stream to forward
-
isWindowed
public boolean isWindowed()Description copied from interface:ProcessorContext
Returns true if the processing is in a windowed context and should wait for punctuation before emitting results.- Specified by:
isWindowed
in interfaceProcessorContext<T>
- Returns:
- whether this is a windowed context or not
-
getWindowedParentStreams
Description copied from interface:ProcessorContext
Returns the windowed parent streams. These are the streams where punctuations arrive.- Specified by:
getWindowedParentStreams
in interfaceProcessorContext<T>
- Returns:
- the windowed parent streams
-