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:

Serializable, StreamOperator<OUT>

All Known Implementing Classes:

CoStreamFlatMap, CoStreamMap

@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	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, isInputCopyingDisabled, notifyOfCompletedCheckpoint, open, restoreState, setChainingStrategy, setKeyContextElement1, setKeyContextElement2, setup, snapshotOperatorState

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