Interface ProcessorContext<T>
- All Superinterfaces:
Serializable
- All Known Implementing Classes:
ChainedProcessorContext,EmittingProcessorContext,ForwardingProcessorContext
Context information passed to the
Processor.-
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.
-
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
-