public class MultipleInputAllRoundWrapperOperator<OUT> extends AbstractAllRoundWrapperOperator<OUT,org.apache.flink.streaming.api.operators.MultipleInputStreamOperator<OUT>> implements org.apache.flink.streaming.api.operators.MultipleInputStreamOperator<IterationRecord<OUT>>, org.apache.flink.streaming.api.operators.BoundedMultiInput
wrappedOperator
containingTask, epochWatermarkSupplier, epochWatermarkTracker, eventBroadcastOutput, iterationContext, metrics, operatorFactory, output, parameters, proxyOutput, streamConfig, uniqueSenderId
Constructor and Description |
---|
MultipleInputAllRoundWrapperOperator(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 |
---|---|
void |
endInput(int i) |
List<org.apache.flink.streaming.api.operators.Input> |
getInputs() |
close, finish, getCurrentKey, getMetricGroup, getOperatorID, initializeState, notifyCheckpointAborted, notifyCheckpointComplete, onEpochWatermarkIncrement, open, prepareSnapshotPreBarrier, setCurrentKey, setKeyContextElement1, setKeyContextElement2, snapshotState
clearIterationContextRound, 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 MultipleInputAllRoundWrapperOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<IterationRecord<OUT>> parameters, org.apache.flink.streaming.api.operators.StreamOperatorFactory<OUT> operatorFactory)
public List<org.apache.flink.streaming.api.operators.Input> getInputs()
getInputs
in interface org.apache.flink.streaming.api.operators.MultipleInputStreamOperator<IterationRecord<OUT>>
public void endInput(int i) throws Exception
endInput
in interface org.apache.flink.streaming.api.operators.BoundedMultiInput
endInput
in class AbstractWrapperOperator<OUT>
Exception
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.