org.apache.flink.streaming.runtime.tasks

类 FinishedOnRestoreInput<IN>

java.lang.Object

org.apache.flink.streaming.runtime.tasks.FinishedOnRestoreInput<IN>

所有已实现的接口:

Input<IN>

public class FinishedOnRestoreInput<IN>
extends Object
implements Input<IN>

A fake Input for finished on restore tasks.

构造器概要

构造器

构造器和说明
FinishedOnRestoreInput(RecordWriterOutput<?>[] streamOutputs, int inputCount)

方法概要

限定符和类型	方法和说明
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)

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

FinishedOnRestoreInput

public FinishedOnRestoreInput(RecordWriterOutput<?>[] streamOutputs,
                              int inputCount)

方法详细资料

processElement

public void processElement(StreamRecord<IN> element)
                    throws Exception

从接口复制的说明: Input

Processes one element that arrived on this input of the MultipleInputStreamOperator. This method is guaranteed to not be called concurrently with other methods of the operator.

指定者:

processElement 在接口中 Input<IN>

抛出:

Exception

processWatermark

public void processWatermark(Watermark watermark)

从接口复制的说明: Input

Processes a 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 在接口中 Input<IN>

另请参阅:

Watermark

processWatermarkStatus

public void processWatermarkStatus(WatermarkStatus watermarkStatus)
                            throws Exception

从接口复制的说明: Input

Processes a 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 在接口中 Input<IN>

抛出:

Exception

另请参阅:

WatermarkStatus

processLatencyMarker

public void processLatencyMarker(LatencyMarker latencyMarker)
                          throws Exception

从接口复制的说明: Input

Processes a 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 在接口中 Input<IN>

抛出:

Exception

另请参阅:

LatencyMarker

setKeyContextElement

public void setKeyContextElement(StreamRecord<IN> record)
                          throws Exception

指定者:

setKeyContextElement 在接口中 Input<IN>

抛出:

Exception