IN1
- The input type of the operatorIN2
- The input type of the operatorOUT
- The output type of the operator@PublicEvolving public interface TwoInputStreamOperator<IN1,IN2,OUT> extends StreamOperator<OUT>
AbstractStreamOperator
as a base class if
you want to implement a custom operator.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. |
close, dispose, getChainingStrategy, getMetricGroup, getOperatorID, initializeState, notifyOfCompletedCheckpoint, open, setChainingStrategy, setKeyContextElement1, setKeyContextElement2, setup, snapshotState
void processElement1(StreamRecord<IN1> element) throws Exception
Exception
void processElement2(StreamRecord<IN2> element) throws Exception
Exception
void processWatermark1(Watermark mark) throws Exception
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.void processWatermark2(Watermark mark) throws Exception
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.void processLatencyMarker1(LatencyMarker latencyMarker) throws Exception
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
void processLatencyMarker2(LatencyMarker latencyMarker) throws Exception
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.Exception
LatencyMarker
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.