org.apache.flink.iteration.operator.allround

Class AbstractAllRoundWrapperOperator<T,S extends org.apache.flink.streaming.api.operators.StreamOperator<T>>

java.lang.Object

org.apache.flink.iteration.operator.AbstractWrapperOperator<T>

org.apache.flink.iteration.operator.allround.AbstractAllRoundWrapperOperator<T,S>

All Implemented Interfaces:

Serializable, org.apache.flink.api.common.state.CheckpointListener, OperatorEpochWatermarkTrackerListener, org.apache.flink.streaming.api.operators.BoundedMultiInput, org.apache.flink.streaming.api.operators.KeyContext, org.apache.flink.streaming.api.operators.StreamOperator<IterationRecord<T>>

Direct Known Subclasses:

MultipleInputAllRoundWrapperOperator, OneInputAllRoundWrapperOperator, TwoInputAllRoundWrapperOperator

public abstract class AbstractAllRoundWrapperOperator<T,S extends org.apache.flink.streaming.api.operators.StreamOperator<T>>
extends AbstractWrapperOperator<T>

The base class for the all-round wrapper operators.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected S	wrappedOperator

Fields inherited from class org.apache.flink.iteration.operator.AbstractWrapperOperator

containingTask, epochWatermarkSupplier, epochWatermarkTracker, eventBroadcastOutput, iterationContext, metrics, operatorFactory, output, parameters, proxyOutput, streamConfig, uniqueSenderId

Constructor Summary

Constructors

Constructor and Description
AbstractAllRoundWrapperOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<IterationRecord<T>> parameters, org.apache.flink.streaming.api.operators.StreamOperatorFactory<T> operatorFactory)

Method Summary

Modifier and Type	Method and Description
void	close()
void	finish()
Object	getCurrentKey()
org.apache.flink.metrics.groups.OperatorMetricGroup	getMetricGroup()
org.apache.flink.runtime.jobgraph.OperatorID	getOperatorID()
void	initializeState(org.apache.flink.streaming.api.operators.StreamTaskStateInitializer streamTaskStateManager)
void	notifyCheckpointAborted(long checkpointId)
void	notifyCheckpointComplete(long checkpointId)
void	onEpochWatermarkIncrement(int epochWatermark) Notifies a new round is aligned to a new epoch watermark.
void	open()
void	prepareSnapshotPreBarrier(long checkpointId)
void	setCurrentKey(Object key)
void	setKeyContextElement1(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<?> record)
void	setKeyContextElement2(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<?> record)
org.apache.flink.streaming.api.operators.OperatorSnapshotFutures	snapshotState(long checkpointId, long timestamp, org.apache.flink.runtime.checkpoint.CheckpointOptions checkpointOptions, org.apache.flink.runtime.state.CheckpointStreamFactory storageLocation)

Methods inherited from class org.apache.flink.iteration.operator.AbstractWrapperOperator

clearIterationContextRound, endInput, notifyEpochWatermarkIncrement, onEpochWatermarkEvent, setIterationContextRound

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

wrappedOperator

protected final S extends org.apache.flink.streaming.api.operators.StreamOperator<T> wrappedOperator

Constructor Detail

AbstractAllRoundWrapperOperator

public AbstractAllRoundWrapperOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<IterationRecord<T>> parameters,
                                       org.apache.flink.streaming.api.operators.StreamOperatorFactory<T> operatorFactory)

Method Detail

onEpochWatermarkIncrement

public void onEpochWatermarkIncrement(int epochWatermark)
                               throws IOException

Description copied from interface: OperatorEpochWatermarkTrackerListener

Notifies a new round is aligned to a new epoch watermark.

Specified by:

onEpochWatermarkIncrement in interface OperatorEpochWatermarkTrackerListener

Overrides:

onEpochWatermarkIncrement in class AbstractWrapperOperator<T>

Parameters:

epochWatermark - The new epoch watermark.

Throws:

IOException

initializeState

public void initializeState(org.apache.flink.streaming.api.operators.StreamTaskStateInitializer streamTaskStateManager)
                     throws Exception

Throws:

Exception

snapshotState

public org.apache.flink.streaming.api.operators.OperatorSnapshotFutures snapshotState(long checkpointId,
                                                                                      long timestamp,
                                                                                      org.apache.flink.runtime.checkpoint.CheckpointOptions checkpointOptions,
                                                                                      org.apache.flink.runtime.state.CheckpointStreamFactory storageLocation)
                                                                               throws Exception

Throws:

Exception

open

public void open()
          throws Exception

Throws:

Exception

finish

public void finish()
            throws Exception

Throws:

Exception

close

public void close()
           throws Exception

Throws:

Exception

prepareSnapshotPreBarrier

public void prepareSnapshotPreBarrier(long checkpointId)
                               throws Exception

Throws:

Exception

setKeyContextElement1

public void setKeyContextElement1(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<?> record)
                           throws Exception

Throws:

Exception

setKeyContextElement2

public void setKeyContextElement2(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<?> record)
                           throws Exception

Throws:

Exception

getMetricGroup

public org.apache.flink.metrics.groups.OperatorMetricGroup getMetricGroup()

getOperatorID

public org.apache.flink.runtime.jobgraph.OperatorID getOperatorID()

notifyCheckpointComplete

public void notifyCheckpointComplete(long checkpointId)
                              throws Exception

Throws:

Exception

notifyCheckpointAborted

public void notifyCheckpointAborted(long checkpointId)
                             throws Exception

Throws:

Exception

setCurrentKey

public void setCurrentKey(Object key)

getCurrentKey

public Object getCurrentKey()