@InterfaceStability.Unstable public interface ProcessorContext extends Serializable
Context information passed to the Processor.
| Modifier and Type | Method and Description |
|---|---|
<T> void |
forward(T input)
Forwards the input to all downstream processors.
|
<T> void |
forward(T input,
String stream)
Forwards the input to downstream processors at specified stream.
|
Set<String> |
getWindowedParentStreams()
Returns the windowed parent streams.
|
boolean |
isWindowed()
Returns true if the processing is in a windowed context and should wait for punctuation before emitting results.
|
<T> void forward(T input)
Forwards the input to all downstream processors.
input - the inputT - the type of the input<T> void forward(T input,
String stream)
Forwards the input to downstream processors at specified stream.
input - the inputstream - the stream to forwardT - the type of the inputboolean isWindowed()
Returns true if the processing is in a windowed context and should wait for punctuation before emitting results.
Copyright © 2021 The Apache Software Foundation. All rights reserved.