org.apache.flink.iteration.operator.allround

Class OneInputAllRoundWrapperOperator<IN,OUT>

java.lang.Object

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

org.apache.flink.iteration.operator.allround.AbstractAllRoundWrapperOperator<OUT,org.apache.flink.streaming.api.operators.OneInputStreamOperator<IN,OUT>>

org.apache.flink.iteration.operator.allround.OneInputAllRoundWrapperOperator<IN,OUT>

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.BoundedOneInput, org.apache.flink.streaming.api.operators.Input<IterationRecord<IN>>, org.apache.flink.streaming.api.operators.KeyContext, org.apache.flink.streaming.api.operators.OneInputStreamOperator<IterationRecord<IN>,IterationRecord<OUT>>, org.apache.flink.streaming.api.operators.StreamOperator<IterationRecord<OUT>>

public class OneInputAllRoundWrapperOperator<IN,OUT>
extends AbstractAllRoundWrapperOperator<OUT,org.apache.flink.streaming.api.operators.OneInputStreamOperator<IN,OUT>>
implements org.apache.flink.streaming.api.operators.OneInputStreamOperator<IterationRecord<IN>,IterationRecord<OUT>>, org.apache.flink.streaming.api.operators.BoundedOneInput

All-round wrapper for the one-input operator.

See Also:

Serialized Form

Field Summary

Fields inherited from class org.apache.flink.iteration.operator.allround.AbstractAllRoundWrapperOperator

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
OneInputAllRoundWrapperOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<IterationRecord<OUT>> parameters, org.apache.flink.streaming.api.operators.StreamOperatorFactory<OUT> operatorFactory)

Method Summary

Modifier and Type	Method and Description
void	endInput()
void	processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IterationRecord<IN>> element)
void	processLatencyMarker(org.apache.flink.streaming.runtime.streamrecord.LatencyMarker latencyMarker)
void	processWatermark(org.apache.flink.streaming.api.watermark.Watermark mark)
void	processWatermarkStatus(org.apache.flink.streaming.runtime.watermarkstatus.WatermarkStatus watermarkStatus)
void	setKeyContextElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IterationRecord<IN>> record)

Methods inherited from class org.apache.flink.iteration.operator.allround.AbstractAllRoundWrapperOperator

close, finish, getCurrentKey, getMetricGroup, getOperatorID, initializeState, notifyCheckpointAborted, notifyCheckpointComplete, onEpochWatermarkIncrement, open, prepareSnapshotPreBarrier, setCurrentKey, setKeyContextElement1, setKeyContextElement2, snapshotState

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

Methods inherited from interface org.apache.flink.streaming.api.operators.StreamOperator

close, finish, getMetricGroup, getOperatorID, initializeState, open, prepareSnapshotPreBarrier, setKeyContextElement1, setKeyContextElement2, snapshotState

Methods inherited from interface org.apache.flink.api.common.state.CheckpointListener

notifyCheckpointAborted, notifyCheckpointComplete

Methods inherited from interface org.apache.flink.streaming.api.operators.KeyContext

getCurrentKey, setCurrentKey

Constructor Detail

OneInputAllRoundWrapperOperator

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

Method Detail

processElement

public void processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IterationRecord<IN>> element)
                    throws Exception

Specified by:

processElement in interface org.apache.flink.streaming.api.operators.Input<IterationRecord<IN>>

Throws:

Exception

processWatermark

public void processWatermark(org.apache.flink.streaming.api.watermark.Watermark mark)
                      throws Exception

Specified by:

processWatermark in interface org.apache.flink.streaming.api.operators.Input<IterationRecord<IN>>

Throws:

Exception

processWatermarkStatus

public void processWatermarkStatus(org.apache.flink.streaming.runtime.watermarkstatus.WatermarkStatus watermarkStatus)
                            throws Exception

Specified by:

processWatermarkStatus in interface org.apache.flink.streaming.api.operators.Input<IterationRecord<IN>>

Throws:

Exception

processLatencyMarker

public void processLatencyMarker(org.apache.flink.streaming.runtime.streamrecord.LatencyMarker latencyMarker)
                          throws Exception

Specified by:

processLatencyMarker in interface org.apache.flink.streaming.api.operators.Input<IterationRecord<IN>>

Throws:

Exception

setKeyContextElement

public void setKeyContextElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IterationRecord<IN>> record)
                          throws Exception

Specified by:

setKeyContextElement in interface org.apache.flink.streaming.api.operators.Input<IterationRecord<IN>>

Specified by:

setKeyContextElement in interface org.apache.flink.streaming.api.operators.OneInputStreamOperator<IterationRecord<IN>,IterationRecord<OUT>>

Throws:

Exception

endInput

public void endInput()
              throws Exception

Specified by:

endInput in interface org.apache.flink.streaming.api.operators.BoundedOneInput

Throws:

Exception