public class MultipleInputPerRoundWrapperOperator<OUT> extends AbstractPerRoundWrapperOperator<OUT,org.apache.flink.streaming.api.operators.MultipleInputStreamOperator<OUT>> implements org.apache.flink.streaming.api.operators.MultipleInputStreamOperator<IterationRecord<OUT>>
latencyStats
containingTask, epochWatermarkSupplier, epochWatermarkTracker, eventBroadcastOutput, iterationContext, metrics, operatorFactory, output, parameters, proxyOutput, streamConfig, uniqueSenderId
Constructor and Description |
---|
MultipleInputPerRoundWrapperOperator(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 |
closeStreamOperator(org.apache.flink.streaming.api.operators.MultipleInputStreamOperator<OUT> operator,
int epoch,
int epochWatermark) |
protected void |
endInputAndEmitMaxWatermark(org.apache.flink.streaming.api.operators.MultipleInputStreamOperator<OUT> operator,
int epoch,
int epochWatermark) |
List<org.apache.flink.streaming.api.operators.Input> |
getInputs() |
protected org.apache.flink.streaming.api.operators.MultipleInputStreamOperator<OUT> |
getWrappedOperator(int epoch) |
close, finish, getCurrentKey, getMetricGroup, getOperatorID, 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 MultipleInputPerRoundWrapperOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<IterationRecord<OUT>> parameters, org.apache.flink.streaming.api.operators.StreamOperatorFactory<OUT> operatorFactory)
protected org.apache.flink.streaming.api.operators.MultipleInputStreamOperator<OUT> getWrappedOperator(int epoch)
getWrappedOperator
in class AbstractPerRoundWrapperOperator<OUT,org.apache.flink.streaming.api.operators.MultipleInputStreamOperator<OUT>>
protected void endInputAndEmitMaxWatermark(org.apache.flink.streaming.api.operators.MultipleInputStreamOperator<OUT> operator, int epoch, int epochWatermark) throws Exception
endInputAndEmitMaxWatermark
in class AbstractPerRoundWrapperOperator<OUT,org.apache.flink.streaming.api.operators.MultipleInputStreamOperator<OUT>>
Exception
protected void closeStreamOperator(org.apache.flink.streaming.api.operators.MultipleInputStreamOperator<OUT> operator, int epoch, int epochWatermark) throws Exception
closeStreamOperator
in class AbstractPerRoundWrapperOperator<OUT,org.apache.flink.streaming.api.operators.MultipleInputStreamOperator<OUT>>
Exception
public List<org.apache.flink.streaming.api.operators.Input> getInputs()
getInputs
in interface org.apache.flink.streaming.api.operators.MultipleInputStreamOperator<IterationRecord<OUT>>
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.