Interface ProcessorContext<T>
- All Superinterfaces:
Serializable
- All Known Implementing Classes:
ChainedProcessorContext
,EmittingProcessorContext
,ForwardingProcessorContext
Context information passed to the
Processor
.-
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.
-
Method Details
-
forward
Forwards the input to all downstream processors.- Parameters:
input
- the input
-
forward
Forwards the input to downstream processors at specified stream.- Parameters:
input
- the inputstream
- the stream to forward
-
isWindowed
boolean isWindowed()Returns true if the processing is in a windowed context and should wait for punctuation before emitting results.- Returns:
- whether this is a windowed context or not
-
getWindowedParentStreams
Returns the windowed parent streams. These are the streams where punctuations arrive.- Returns:
- the windowed parent streams
-