public abstract class AbstractWrapperOperator<T> extends Object implements org.apache.flink.streaming.api.operators.StreamOperator<IterationRecord<T>>, OperatorEpochWatermarkTrackerListener, org.apache.flink.streaming.api.operators.BoundedMultiInput
Modifier and Type | Field and Description |
---|---|
protected org.apache.flink.streaming.runtime.tasks.StreamTask<?,?> |
containingTask |
protected org.apache.flink.iteration.operator.AbstractWrapperOperator.EpochSupplier |
epochWatermarkSupplier |
protected OperatorEpochWatermarkTracker |
epochWatermarkTracker |
protected BroadcastOutput<IterationRecord<T>> |
eventBroadcastOutput |
protected org.apache.flink.iteration.operator.AbstractWrapperOperator.IterationContext |
iterationContext |
protected org.apache.flink.runtime.metrics.groups.InternalOperatorMetricGroup |
metrics
Metric group for the operator.
|
protected org.apache.flink.streaming.api.operators.StreamOperatorFactory<T> |
operatorFactory |
protected org.apache.flink.streaming.api.operators.Output<org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IterationRecord<T>>> |
output |
protected org.apache.flink.streaming.api.operators.StreamOperatorParameters<IterationRecord<T>> |
parameters |
protected ProxyOutput<T> |
proxyOutput |
protected org.apache.flink.streaming.api.graph.StreamConfig |
streamConfig |
protected String |
uniqueSenderId |
Constructor and Description |
---|
AbstractWrapperOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<IterationRecord<T>> parameters,
org.apache.flink.streaming.api.operators.StreamOperatorFactory<T> operatorFactory) |
Modifier and Type | Method and Description |
---|---|
protected void |
clearIterationContextRound() |
void |
endInput(int i) |
protected void |
notifyEpochWatermarkIncrement(IterationListener<?> listener,
int epochWatermark) |
protected void |
onEpochWatermarkEvent(int inputIndex,
IterationRecord<?> iterationRecord) |
void |
onEpochWatermarkIncrement(int epochWatermark)
Notifies a new round is aligned to a new epoch watermark.
|
protected void |
setIterationContextRound(Integer contextRound) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
close, finish, getMetricGroup, getOperatorID, initializeState, open, prepareSnapshotPreBarrier, setKeyContextElement1, setKeyContextElement2, snapshotState
protected final org.apache.flink.streaming.api.operators.StreamOperatorParameters<IterationRecord<T>> parameters
protected final org.apache.flink.streaming.api.graph.StreamConfig streamConfig
protected final org.apache.flink.streaming.runtime.tasks.StreamTask<?,?> containingTask
protected final org.apache.flink.streaming.api.operators.Output<org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IterationRecord<T>>> output
protected final org.apache.flink.streaming.api.operators.StreamOperatorFactory<T> operatorFactory
protected final org.apache.flink.iteration.operator.AbstractWrapperOperator.IterationContext iterationContext
protected final ProxyOutput<T> proxyOutput
protected final org.apache.flink.iteration.operator.AbstractWrapperOperator.EpochSupplier epochWatermarkSupplier
protected final org.apache.flink.runtime.metrics.groups.InternalOperatorMetricGroup metrics
protected final OperatorEpochWatermarkTracker epochWatermarkTracker
protected final String uniqueSenderId
protected final BroadcastOutput<IterationRecord<T>> eventBroadcastOutput
public AbstractWrapperOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<IterationRecord<T>> parameters, org.apache.flink.streaming.api.operators.StreamOperatorFactory<T> operatorFactory)
protected void onEpochWatermarkEvent(int inputIndex, IterationRecord<?> iterationRecord) throws IOException
IOException
protected void notifyEpochWatermarkIncrement(IterationListener<?> listener, int epochWatermark) throws Exception
Exception
public void onEpochWatermarkIncrement(int epochWatermark) throws IOException
OperatorEpochWatermarkTrackerListener
onEpochWatermarkIncrement
in interface OperatorEpochWatermarkTrackerListener
epochWatermark
- The new epoch watermark.IOException
protected void setIterationContextRound(Integer contextRound)
protected void clearIterationContextRound()
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.