public class TwoInputPerRoundWrapperOperator<IN1,IN2,OUT> extends AbstractPerRoundWrapperOperator<OUT,org.apache.flink.streaming.api.operators.TwoInputStreamOperator<IN1,IN2,OUT>> implements org.apache.flink.streaming.api.operators.TwoInputStreamOperator<IterationRecord<IN1>,IterationRecord<IN2>,IterationRecord<OUT>>
latencyStats
containingTask, epochWatermarkSupplier, epochWatermarkTracker, eventBroadcastOutput, iterationContext, metrics, operatorFactory, output, parameters, proxyOutput, streamConfig, uniqueSenderId
Constructor and Description |
---|
TwoInputPerRoundWrapperOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<IterationRecord<OUT>> parameters,
org.apache.flink.streaming.api.operators.StreamOperatorFactory<OUT> operatorFactory) |
Modifier and Type | Method and Description |
---|---|
protected void |
endInputAndEmitMaxWatermark(org.apache.flink.streaming.api.operators.TwoInputStreamOperator<IN1,IN2,OUT> operator,
int epoch,
int epochWatermark) |
void |
processElement1(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IterationRecord<IN1>> element) |
void |
processElement2(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IterationRecord<IN2>> element) |
void |
processLatencyMarker1(org.apache.flink.streaming.runtime.streamrecord.LatencyMarker latencyMarker) |
void |
processLatencyMarker2(org.apache.flink.streaming.runtime.streamrecord.LatencyMarker latencyMarker) |
void |
processWatermark1(org.apache.flink.streaming.api.watermark.Watermark mark) |
void |
processWatermark2(org.apache.flink.streaming.api.watermark.Watermark mark) |
void |
processWatermarkStatus1(org.apache.flink.streaming.runtime.watermarkstatus.WatermarkStatus watermarkStatus) |
void |
processWatermarkStatus2(org.apache.flink.streaming.runtime.watermarkstatus.WatermarkStatus watermarkStatus) |
close, closeStreamOperator, finish, getCurrentKey, getMetricGroup, getOperatorID, getWrappedOperator, getWrappedOperators, initializeState, initializeState, isUsingCustomRawKeyedState, notifyCheckpointAborted, notifyCheckpointComplete, onEpochWatermarkIncrement, open, prepareSnapshotPreBarrier, processForEachWrappedOperator, reportOrForwardLatencyMarker, setCurrentKey, setKeyContextElement1, setKeyContextElement2, snapshotState, snapshotState
clearIterationContextRound, endInput, notifyEpochWatermarkIncrement, onEpochWatermarkEvent, setIterationContextRound
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
close, finish, getMetricGroup, getOperatorID, initializeState, open, prepareSnapshotPreBarrier, setKeyContextElement1, setKeyContextElement2, snapshotState
public TwoInputPerRoundWrapperOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<IterationRecord<OUT>> parameters, org.apache.flink.streaming.api.operators.StreamOperatorFactory<OUT> operatorFactory)
protected void endInputAndEmitMaxWatermark(org.apache.flink.streaming.api.operators.TwoInputStreamOperator<IN1,IN2,OUT> operator, int epoch, int epochWatermark) throws Exception
endInputAndEmitMaxWatermark
in class AbstractPerRoundWrapperOperator<OUT,org.apache.flink.streaming.api.operators.TwoInputStreamOperator<IN1,IN2,OUT>>
Exception
public void processElement1(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IterationRecord<IN1>> element) throws Exception
processElement1
in interface org.apache.flink.streaming.api.operators.TwoInputStreamOperator<IterationRecord<IN1>,IterationRecord<IN2>,IterationRecord<OUT>>
Exception
public void processElement2(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IterationRecord<IN2>> element) throws Exception
processElement2
in interface org.apache.flink.streaming.api.operators.TwoInputStreamOperator<IterationRecord<IN1>,IterationRecord<IN2>,IterationRecord<OUT>>
Exception
public void processWatermark1(org.apache.flink.streaming.api.watermark.Watermark mark) throws Exception
processWatermark1
in interface org.apache.flink.streaming.api.operators.TwoInputStreamOperator<IterationRecord<IN1>,IterationRecord<IN2>,IterationRecord<OUT>>
Exception
public void processWatermark2(org.apache.flink.streaming.api.watermark.Watermark mark) throws Exception
processWatermark2
in interface org.apache.flink.streaming.api.operators.TwoInputStreamOperator<IterationRecord<IN1>,IterationRecord<IN2>,IterationRecord<OUT>>
Exception
public void processLatencyMarker1(org.apache.flink.streaming.runtime.streamrecord.LatencyMarker latencyMarker) throws Exception
processLatencyMarker1
in interface org.apache.flink.streaming.api.operators.TwoInputStreamOperator<IterationRecord<IN1>,IterationRecord<IN2>,IterationRecord<OUT>>
Exception
public void processLatencyMarker2(org.apache.flink.streaming.runtime.streamrecord.LatencyMarker latencyMarker) throws Exception
processLatencyMarker2
in interface org.apache.flink.streaming.api.operators.TwoInputStreamOperator<IterationRecord<IN1>,IterationRecord<IN2>,IterationRecord<OUT>>
Exception
public void processWatermarkStatus1(org.apache.flink.streaming.runtime.watermarkstatus.WatermarkStatus watermarkStatus) throws Exception
processWatermarkStatus1
in interface org.apache.flink.streaming.api.operators.TwoInputStreamOperator<IterationRecord<IN1>,IterationRecord<IN2>,IterationRecord<OUT>>
Exception
public void processWatermarkStatus2(org.apache.flink.streaming.runtime.watermarkstatus.WatermarkStatus watermarkStatus) throws Exception
processWatermarkStatus2
in interface org.apache.flink.streaming.api.operators.TwoInputStreamOperator<IterationRecord<IN1>,IterationRecord<IN2>,IterationRecord<OUT>>
Exception
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.