Constructor and Description |
---|
FinishedOnRestoreInput(RecordWriterOutput<?>[] streamOutputs,
int inputCount) |
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 watermark)
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) |
public FinishedOnRestoreInput(RecordWriterOutput<?>[] streamOutputs, int inputCount)
public void processElement(StreamRecord<IN> element) throws Exception
Input
MultipleInputStreamOperator
.
This method is guaranteed to not be called concurrently with other methods of the operator.processElement
in interface Input<IN>
Exception
public void processWatermark(Watermark watermark)
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>
Watermark
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 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 setKeyContextElement(StreamRecord<IN> record) throws Exception
setKeyContextElement
in interface Input<IN>
Exception
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.