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:

CheckpointListener, Disposable, KeyContext, Serializable, StreamOperator<OUT>

All Known Implementing Classes:

CoBroadcastWithKeyedOperator, CoBroadcastWithNonKeyedOperator, CoProcessOperator, CoStreamFlatMap, CoStreamMap, IntervalJoinOperator, KeyedCoProcessOperator

@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 and 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.

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

close, dispose, getChainingStrategy, getMetricGroup, getOperatorID, initializeState, open, prepareSnapshotPreBarrier, setChainingStrategy, setKeyContextElement1, setKeyContextElement2, setup, snapshotState

Methods inherited from interface org.apache.flink.runtime.state.CheckpointListener

notifyCheckpointComplete

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

getCurrentKey, setCurrentKey

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