Package org.apache.flink.streaming.api.operators

Interface TwoInputStreamOperator<IN1,IN2,OUT>

Type Parameters:

IN1 - The input type of the operator

IN2 - The input type of the operator

OUT - The output type of the operator

All Superinterfaces:

org.apache.flink.api.common.state.CheckpointListener, KeyContext, Serializable, StreamOperator<OUT>

All Known Implementing Classes:

BatchCoBroadcastWithKeyedOperator, BatchCoBroadcastWithNonKeyedOperator, CoBroadcastWithKeyedOperator, CoBroadcastWithNonKeyedOperator, CoProcessOperator, CoStreamFlatMap, CoStreamMap, IntervalJoinOperator, KeyedCoProcessOperator, LegacyKeyedCoProcessOperator

@PublicEvolving
public interface TwoInputStreamOperator<IN1,IN2,OUT>
extends StreamOperator<OUT>

Interface for stream operators with two inputs. Use AbstractStreamOperator as a base class if you want to implement a custom operator.

Method Summary

Modifier and Type	Method	Description
void	processElement1(StreamRecord<IN1> element)	Processes one element that arrived on the first input of this two-input operator.
void	processElement2(StreamRecord<IN2> element)	Processes one element that arrived on the second input of this two-input operator.
void	processLatencyMarker1(LatencyMarker latencyMarker)	Processes a LatencyMarker that arrived on the first input of this two-input operator.
void	processLatencyMarker2(LatencyMarker latencyMarker)	Processes a LatencyMarker that arrived on the second input of this two-input operator.
void	processWatermark1(Watermark mark)	Processes a Watermark that arrived on the first input of this two-input operator.
void	processWatermark2(Watermark mark)	Processes a Watermark that arrived on the second input of this two-input operator.
void	processWatermarkStatus1(WatermarkStatus watermarkStatus)	Processes a WatermarkStatus that arrived on the first input of this two-input operator.
void	processWatermarkStatus2(WatermarkStatus watermarkStatus)	Processes a WatermarkStatus that arrived on the second input of this two-input operator.

Methods inherited from interface org.apache.flink.api.common.state.CheckpointListener

notifyCheckpointAborted, notifyCheckpointComplete

Methods inherited from interface org.apache.flink.streaming.api.operators.KeyContext

getCurrentKey, setCurrentKey

Methods inherited from interface org.apache.flink.streaming.api.operators.StreamOperator

close, finish, getMetricGroup, getOperatorID, initializeState, open, prepareSnapshotPreBarrier, setKeyContextElement1, setKeyContextElement2, snapshotState

Method Detail

processElement1

void processElement1(StreamRecord<IN1> element)
              throws Exception

Processes one element 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.

Throws:

Exception

processElement2

void processElement2(StreamRecord<IN2> element)
              throws Exception

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

Throws:

Exception

processWatermark1

void processWatermark1(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.

Throws:

Exception

See Also:

Watermark

processWatermark2

void processWatermark2(Watermark mark)
                throws Exception

Processes a Watermark that arrived on the second input of this two-input operator. This method is guaranteed to not be called concurrently with other methods of the operator.

Throws:

Exception

See Also:

Watermark

processLatencyMarker1

void processLatencyMarker1(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.

Throws:

Exception

See Also:

LatencyMarker

processLatencyMarker2

void processLatencyMarker2(LatencyMarker latencyMarker)
                    throws Exception

Processes a LatencyMarker that arrived on the second input of this two-input operator. This method is guaranteed to not be called concurrently with other methods of the operator.

Throws:

Exception

See Also:

LatencyMarker

processWatermarkStatus1

void processWatermarkStatus1(WatermarkStatus watermarkStatus)
                      throws Exception

Processes a WatermarkStatus 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.

Throws:

Exception

See Also:

WatermarkStatus

processWatermarkStatus2

void processWatermarkStatus2(WatermarkStatus watermarkStatus)
                      throws Exception

Processes a WatermarkStatus that arrived on the second input of this two-input operator. This method is guaranteed to not be called concurrently with other methods of the operator.

Throws:

Exception

See Also:

WatermarkStatus