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(Environment environment)
Create an Invokable task and set its environment.
|
Modifier and Type | Method and Description |
---|---|
void |
invoke()
Starts the execution.
|
void |
requestTermination() |
void |
terminationCompleted() |
boolean |
terminationRequested() |
abortCheckpointOnBarrier, cancel, dispatchOperatorEvent, getCurrentNumberOfSubtasks, getEnvironment, getExecutionConfig, getIndexInSubtaskGroup, getJobConfiguration, getTaskConfiguration, getUserCodeClassLoader, isUsingNonBlockingInput, notifyCheckpointAbortAsync, notifyCheckpointCompleteAsync, restore, setShouldInterruptOnCancel, shouldInterruptOnCancel, triggerCheckpointAsync, triggerCheckpointOnBarrier
public IterationSynchronizationSinkTask(Environment environment)
environment
- The environment assigned to this invokable.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
public void terminationCompleted()
terminationCompleted
in interface Terminable
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.