IterationSynchronizationSinkTask (Flink : 2.0-SNAPSHOT API)

java.lang.Object
- org.apache.flink.runtime.jobgraph.tasks.AbstractInvokable
- - org.apache.flink.runtime.iterative.task.IterationSynchronizationSinkTask

All Implemented Interfaces:

Terminable, CheckpointableTask, CoordinatedTask, TaskInvokable
```
public class IterationSynchronizationSinkTask
extends AbstractInvokable
implements Terminable
```
The task responsible for synchronizing all iteration heads, implemented as an output task. This task will never see any data. In each superstep, it simply waits until it has received a WorkerDoneEvent from each head and will send back an AllWorkersDoneEvent to signal that the next superstep can begin.

- Constructor Summary
  
  Constructors
  Constructor Description
  
  IterationSynchronizationSinkTask(Environment environment)
  Create an Invokable task and set its environment.
- Method Summary
  
  All Methods Instance Methods Concrete Methods
  Modifier and Type Method Description
  
  void invoke()
  Starts the execution.
  
  void requestTermination()
  
  boolean terminationRequested()
  - Methods inherited from class org.apache.flink.runtime.jobgraph.tasks.AbstractInvokable
    abortCheckpointOnBarrier, cancel, cleanUp, dispatchOperatorEvent, getCurrentNumberOfSubtasks, getEnvironment, getExecutionConfig, getIndexInSubtaskGroup, getJobConfiguration, getTaskConfiguration, getUserCodeClassLoader, isUsingNonBlockingInput, maybeInterruptOnCancel, notifyCheckpointAbortAsync, notifyCheckpointCompleteAsync, notifyCheckpointSubsumedAsync, restore, triggerCheckpointAsync, triggerCheckpointOnBarrier
  - Methods inherited from class java.lang.Object
    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - IterationSynchronizationSinkTask
```
public IterationSynchronizationSinkTask(Environment environment)
```
    Create an Invokable task and set its environment.
    
    Parameters:
    
    environment - The environment assigned to this invokable.
- Method Detail
  - invoke
```
public void invoke()
            throws Exception
```
    Description copied from interface: TaskInvokable
    
    Starts the execution.
    This method is called by the task manager when the actual execution of the task starts.
    All resources should be cleaned up by calling TaskInvokable.cleanUp(Throwable) after the method returns.
    
    Specified by:
    
    invoke in interface TaskInvokable
    
    Specified by:
    
    invoke in class AbstractInvokable
    
    Throws:
    
    Exception
  - terminationRequested
```
public boolean terminationRequested()
```
    Specified by:
    
    terminationRequested in interface Terminable
  - requestTermination
```
public void requestTermination()
```
    Specified by:
    
    requestTermination in interface Terminable