@PublicEvolving public interface Input<IN>
Input
interface used in MultipleInputStreamOperator
. Most likely you don't want
to implement this interface on your own. Instead you can use AbstractInput
and AbstractStreamOperatorV2
to implement MultipleInputStreamOperator
, or just AbstractStreamOperatorV2
to implement OneInputStreamOperator
.Modifier and Type | Method and Description |
---|---|
void |
processElement(StreamRecord<IN> element)
Processes one element that arrived on this input of the
MultipleInputStreamOperator . |
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<IN> record)
Set the correct key context before processing the
record . |
void processElement(StreamRecord<IN> element) throws Exception
MultipleInputStreamOperator
.
This method is guaranteed to not be called concurrently with other methods of the operator.Exception
void processWatermark(Watermark mark) throws Exception
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.void processWatermarkStatus(WatermarkStatus watermarkStatus) throws Exception
WatermarkStatus
that arrived on this input of the MultipleInputStreamOperator
. This method is guaranteed to not be called concurrently with
other methods of the operator.Exception
WatermarkStatus
void processLatencyMarker(LatencyMarker latencyMarker) throws Exception
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.Exception
LatencyMarker
void setKeyContextElement(StreamRecord<IN> record) throws Exception
record
. Used for example to extract
key from the record
and pass that key to the state backends. This method is
guaranteed to not be called concurrently with other methods of the operator.Exception
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.