org.apache.flink.streaming.api.operators

接口 Input<IN>

所有已知子接口:

OneInputStreamOperator<IN,OUT>

所有已知实现类:

AbstractInput, AsyncWaitOperator, BatchGroupedReduceOperator, CollectSinkOperator, ContinuousFileReaderOperator, EvictingWindowOperator, FinishedOnRestoreInput, GenericWriteAheadSink, KeyedProcessOperator, LegacyKeyedProcessOperator, ProcessOperator, QueryableAppendingStateOperator, QueryableValueStateOperator, StreamFilter, StreamFlatMap, StreamGroupedReduceOperator, StreamMap, StreamProject, StreamSink, TimestampsAndWatermarksOperator, WindowOperator

@PublicEvolving
public interface Input<IN>

Input interface used in MultipleInputStreamOperator.

方法概要

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

方法详细资料

processElement

void processElement(StreamRecord<IN> element)
             throws Exception

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.

抛出:

Exception

processWatermark

void processWatermark(Watermark mark)
               throws Exception

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.

抛出:

Exception

另请参阅:

Watermark

processWatermarkStatus

void processWatermarkStatus(WatermarkStatus watermarkStatus)
                     throws Exception

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.

抛出:

Exception

另请参阅:

WatermarkStatus

processLatencyMarker

void processLatencyMarker(LatencyMarker latencyMarker)
                   throws Exception

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.

抛出:

Exception

另请参阅:

LatencyMarker

setKeyContextElement

void setKeyContextElement(StreamRecord<IN> record)
                   throws Exception

抛出:

Exception