public class IterationSynchronizationSinkTask extends AbstractInvokable implements Terminable
WorkerDoneEvent
from each head and will send back
an AllWorkersDoneEvent
to signal that the next superstep can begin.Constructor and Description |
---|
IterationSynchronizationSinkTask() |
Modifier and Type | Method and Description |
---|---|
void |
invoke()
Starts the execution.
|
void |
requestTermination() |
boolean |
terminationRequested() |
cancel, getCurrentNumberOfSubtasks, getEnvironment, getExecutionConfig, getIndexInSubtaskGroup, getJobConfiguration, getTaskConfiguration, getUserCodeClassLoader, setEnvironment
public void invoke() throws Exception
AbstractInvokable
Must be overwritten by the concrete task implementation. This method is called by the task manager when the actual execution of the task starts.
All resources should be cleaned up when the method returns. Make sure
to guard the code with try-finally
blocks where necessary.
invoke
in class AbstractInvokable
Exception
- Tasks may forward their exceptions for the TaskManager to handle through failure/recovery.public boolean terminationRequested()
terminationRequested
in interface Terminable
public void requestTermination()
requestTermination
in interface Terminable
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.