Package org.apache.flink.runtime.jobgraph.tasks

Interface CoordinatedTask

All Known Implementing Classes:

AbstractInvokable, AbstractIterativeTask, AbstractTwoInputStreamTask, BatchTask, DataSinkTask, DataSourceTask, IterationHeadTask, IterationIntermediateTask, IterationSynchronizationSinkTask, IterationTailTask, MultipleInputStreamTask, OneInputStreamTask, SourceOperatorStreamTask, SourceStreamTask, StreamIterationHead, StreamIterationTail, StreamTask, TwoInputStreamTask

@Internal
public interface CoordinatedTask

An task that is coordinated, i.e. contains operators coordinated by OperatorCoordinator.

Method Summary

Modifier and Type	Method	Description
void	dispatchOperatorEvent(OperatorID operator, SerializedValue<OperatorEvent> event)

Method Detail

dispatchOperatorEvent

void dispatchOperatorEvent(OperatorID operator,
                           SerializedValue<OperatorEvent> event)
                    throws FlinkException

Throws:

FlinkException