public class ChainedProcessorContext<T> extends Object implements ProcessorContext<T>
ProcessorContext
.Constructor and Description |
---|
ChainedProcessorContext(ProcessorNode processorNode,
List<? extends ProcessorContext> contexts) |
ChainedProcessorContext(ProcessorNode processorNode,
ProcessorContext... contexts) |
Modifier and Type | Method and Description |
---|---|
void |
forward(T input)
Forwards the input to all downstream processors.
|
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.
|
public ChainedProcessorContext(ProcessorNode processorNode, List<? extends ProcessorContext> contexts)
public ChainedProcessorContext(ProcessorNode processorNode, ProcessorContext... contexts)
public void forward(T input)
ProcessorContext
forward
in interface ProcessorContext<T>
input
- the inputpublic void forward(T input, String stream)
ProcessorContext
forward
in interface ProcessorContext<T>
input
- the inputstream
- the stream to forwardpublic boolean isWindowed()
ProcessorContext
isWindowed
in interface ProcessorContext<T>
public Set<String> getWindowedParentStreams()
ProcessorContext
getWindowedParentStreams
in interface ProcessorContext<T>
Copyright © 2023 The Apache Software Foundation. All rights reserved.