@PublicEvolving public interface Input<IN>
Input
interface used in MultipleInputStreamOperator
.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 |
setKeyContextElement(StreamRecord<IN> 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 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
Exception
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.