public class OneInputPerRoundWrapperOperator<IN,OUT> extends AbstractPerRoundWrapperOperator<OUT,org.apache.flink.streaming.api.operators.OneInputStreamOperator<IN,OUT>> implements org.apache.flink.streaming.api.operators.OneInputStreamOperator<IterationRecord<IN>,IterationRecord<OUT>>
latencyStats
containingTask, epochWatermarkSupplier, epochWatermarkTracker, eventBroadcastOutput, iterationContext, metrics, operatorFactory, output, parameters, proxyOutput, streamConfig, uniqueSenderId
Constructor and Description |
---|
OneInputPerRoundWrapperOperator(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.OneInputStreamOperator<IN,OUT> operator,
int epoch,
int epochWatermark) |
void |
processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IterationRecord<IN>> element) |
void |
processLatencyMarker(org.apache.flink.streaming.runtime.streamrecord.LatencyMarker latencyMarker) |
void |
processWatermark(org.apache.flink.streaming.api.watermark.Watermark mark) |
void |
processWatermarkStatus(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
setKeyContextElement
close, finish, getMetricGroup, getOperatorID, initializeState, open, prepareSnapshotPreBarrier, setKeyContextElement1, setKeyContextElement2, snapshotState
public OneInputPerRoundWrapperOperator(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.OneInputStreamOperator<IN,OUT> operator, int epoch, int epochWatermark) throws Exception
endInputAndEmitMaxWatermark
in class AbstractPerRoundWrapperOperator<OUT,org.apache.flink.streaming.api.operators.OneInputStreamOperator<IN,OUT>>
Exception
public void processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IterationRecord<IN>> element) throws Exception
processElement
in interface org.apache.flink.streaming.api.operators.Input<IterationRecord<IN>>
Exception
public void processWatermark(org.apache.flink.streaming.api.watermark.Watermark mark) throws Exception
processWatermark
in interface org.apache.flink.streaming.api.operators.Input<IterationRecord<IN>>
Exception
public void processWatermarkStatus(org.apache.flink.streaming.runtime.watermarkstatus.WatermarkStatus watermarkStatus) throws Exception
processWatermarkStatus
in interface org.apache.flink.streaming.api.operators.Input<IterationRecord<IN>>
Exception
public void processLatencyMarker(org.apache.flink.streaming.runtime.streamrecord.LatencyMarker latencyMarker) throws Exception
processLatencyMarker
in interface org.apache.flink.streaming.api.operators.Input<IterationRecord<IN>>
Exception
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.