Class EmittingProcessorContext<T>
java.lang.Object
org.apache.storm.streams.processors.EmittingProcessorContext<T>
- All Implemented Interfaces:
Serializable
,ProcessorContext<T>
A context that emits the results to downstream processors which are in another bolt.
- See Also:
-
Constructor Summary
ConstructorDescriptionEmittingProcessorContext
(ProcessorNode processorNode, OutputCollector collector, String outputStreamId) -
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.void
setAnchor
(RefCountedTuple anchor) void
setEventTimestamp
(long timestamp) void
setTimestampField
(String fieldName)
-
Constructor Details
-
EmittingProcessorContext
public EmittingProcessorContext(ProcessorNode processorNode, OutputCollector collector, String outputStreamId)
-
-
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
-
setTimestampField
-
setAnchor
-
setEventTimestamp
public void setEventTimestamp(long timestamp)
-