@Experimental public abstract class AbstractInput<IN,OUT> extends Object implements Input<IN>
Input
interface intended to be used when extending AbstractStreamOperatorV2
.Modifier and Type | Field and Description |
---|---|
protected int |
inputId |
protected Output<StreamRecord<OUT>> |
output |
protected AbstractStreamOperatorV2<OUT> |
owner |
protected KeySelector<?,?> |
stateKeySelector
KeySelector for extracting a key from an element being processed. |
Constructor and Description |
---|
AbstractInput(AbstractStreamOperatorV2<OUT> owner,
int inputId) |
Modifier and Type | Method and Description |
---|---|
void |
processLatencyMarker(LatencyMarker latencyMarker)
Processes a
LatencyMarker that arrived on the first input of this two-input operator. |
void |
processWatermark(Watermark mark)
Processes a
Watermark that arrived on the first input of this two-input operator. |
void |
processWatermarkStatus(WatermarkStatus watermarkStatus)
Processes a
WatermarkStatus that arrived on this input of the MultipleInputStreamOperator . |
void |
setKeyContextElement(StreamRecord record) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
processElement
@Nullable protected final KeySelector<?,?> stateKeySelector
KeySelector
for extracting a key from an element being processed. This is used to
scope keyed state to a key. This is null if the operator is not a keyed operator.
This is for elements from the first input.
protected final AbstractStreamOperatorV2<OUT> owner
protected final int inputId
protected final Output<StreamRecord<OUT>> output
public AbstractInput(AbstractStreamOperatorV2<OUT> owner, int inputId)
public void processWatermark(Watermark mark) throws Exception
Input
Watermark
that arrived on the first input of this two-input operator.
This method is guaranteed to not be called concurrently with other methods of the operator.processWatermark
in interface Input<IN>
Exception
Watermark
public void processLatencyMarker(LatencyMarker latencyMarker) throws Exception
Input
LatencyMarker
that arrived on the first input of this two-input operator.
This method is guaranteed to not be called concurrently with other methods of the operator.processLatencyMarker
in interface Input<IN>
Exception
LatencyMarker
public void processWatermarkStatus(WatermarkStatus watermarkStatus) throws Exception
Input
WatermarkStatus
that arrived on this input of the MultipleInputStreamOperator
. This method is guaranteed to not be called concurrently with
other methods of the operator.processWatermarkStatus
in interface Input<IN>
Exception
WatermarkStatus
public void setKeyContextElement(StreamRecord record) throws Exception
setKeyContextElement
in interface Input<IN>
Exception
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.