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 byOperatorCoordinator
.
-
-
Method Summary
All Methods Instance Methods Abstract Methods 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
-
-