public class ReplayOperator<T> extends org.apache.flink.streaming.api.operators.AbstractStreamOperator<IterationRecord<T>> implements org.apache.flink.streaming.api.operators.TwoInputStreamOperator<IterationRecord<T>,IterationRecord<Void>,IterationRecord<T>>, OperatorEpochWatermarkTrackerListener, org.apache.flink.streaming.api.operators.BoundedMultiInput
Constructor and Description |
---|
ReplayOperator() |
Modifier and Type | Method and Description |
---|---|
void |
endInput(int i) |
void |
initializeState(org.apache.flink.runtime.state.StateInitializationContext context) |
void |
onEpochWatermarkIncrement(int epochWatermark)
Notifies a new round is aligned to a new epoch watermark.
|
void |
processElement1(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IterationRecord<T>> element) |
void |
processElement2(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IterationRecord<Void>> element) |
void |
setup(org.apache.flink.streaming.runtime.tasks.StreamTask<?,?> containingTask,
org.apache.flink.streaming.api.graph.StreamConfig config,
org.apache.flink.streaming.api.operators.Output<org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IterationRecord<T>>> output) |
void |
snapshotState(org.apache.flink.runtime.state.StateSnapshotContext context) |
close, finish, getChainingStrategy, getContainingTask, getCurrentKey, getExecutionConfig, getInternalTimerService, getKeyedStateBackend, getKeyedStateStore, getMetricGroup, getOperatorConfig, getOperatorID, getOperatorName, getOperatorStateBackend, getOrCreateKeyedState, getPartitionedState, getPartitionedState, getProcessingTimeService, getRuntimeContext, getTimeServiceManager, getUserCodeClassloader, initializeState, isUsingCustomRawKeyedState, notifyCheckpointAborted, notifyCheckpointComplete, open, prepareSnapshotPreBarrier, processLatencyMarker, processLatencyMarker1, processLatencyMarker2, processWatermark, processWatermark1, processWatermark2, processWatermarkStatus, processWatermarkStatus1, processWatermarkStatus2, reportOrForwardLatencyMarker, setChainingStrategy, setCurrentKey, setKeyContextElement1, setKeyContextElement2, setProcessingTimeService, snapshotState
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
processLatencyMarker1, processLatencyMarker2, processWatermark1, processWatermark2, processWatermarkStatus1, processWatermarkStatus2
close, finish, getMetricGroup, getOperatorID, initializeState, open, prepareSnapshotPreBarrier, setKeyContextElement1, setKeyContextElement2, snapshotState
public void setup(org.apache.flink.streaming.runtime.tasks.StreamTask<?,?> containingTask, org.apache.flink.streaming.api.graph.StreamConfig config, org.apache.flink.streaming.api.operators.Output<org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IterationRecord<T>>> output)
setup
in interface org.apache.flink.streaming.api.operators.SetupableStreamOperator<IterationRecord<T>>
setup
in class org.apache.flink.streaming.api.operators.AbstractStreamOperator<IterationRecord<T>>
public void initializeState(org.apache.flink.runtime.state.StateInitializationContext context) throws Exception
initializeState
in interface org.apache.flink.streaming.api.operators.StreamOperatorStateHandler.CheckpointedStreamOperator
initializeState
in class org.apache.flink.streaming.api.operators.AbstractStreamOperator<IterationRecord<T>>
Exception
public void snapshotState(org.apache.flink.runtime.state.StateSnapshotContext context) throws Exception
snapshotState
in interface org.apache.flink.streaming.api.operators.StreamOperatorStateHandler.CheckpointedStreamOperator
snapshotState
in class org.apache.flink.streaming.api.operators.AbstractStreamOperator<IterationRecord<T>>
Exception
public void processElement1(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IterationRecord<T>> element) throws Exception
processElement1
in interface org.apache.flink.streaming.api.operators.TwoInputStreamOperator<IterationRecord<T>,IterationRecord<Void>,IterationRecord<T>>
Exception
public void processElement2(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IterationRecord<Void>> element) throws Exception
processElement2
in interface org.apache.flink.streaming.api.operators.TwoInputStreamOperator<IterationRecord<T>,IterationRecord<Void>,IterationRecord<T>>
Exception
public void endInput(int i) throws Exception
endInput
in interface org.apache.flink.streaming.api.operators.BoundedMultiInput
Exception
public void onEpochWatermarkIncrement(int epochWatermark) throws IOException
OperatorEpochWatermarkTrackerListener
onEpochWatermarkIncrement
in interface OperatorEpochWatermarkTrackerListener
epochWatermark
- The new epoch watermark.IOException
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.