Package org.apache.flink.runtime.scheduler

Class DefaultExecutionOperations

java.lang.Object

org.apache.flink.runtime.scheduler.DefaultExecutionOperations

All Implemented Interfaces:

ExecutionOperations

public class DefaultExecutionOperations
extends Object
implements ExecutionOperations

Default implementation of ExecutionOperations.

Constructor Summary

Constructors

Constructor	Description
DefaultExecutionOperations()

Method Summary

Modifier and Type	Method	Description
CompletableFuture<?>	cancel(Execution execution)	Cancel the execution.
void	deploy(Execution execution)	Deploy the execution.
void	markFailed(Execution execution, Throwable cause)	Mark the execution as FAILED.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DefaultExecutionOperations

public DefaultExecutionOperations()

Method Detail

deploy

public void deploy(Execution execution)
            throws JobException

Description copied from interface: ExecutionOperations

Deploy the execution.

Specified by:

deploy in interface ExecutionOperations

Parameters:

execution - to deploy.

Throws:

JobException - if the execution cannot be deployed to the assigned resource

cancel

public CompletableFuture<?> cancel(Execution execution)

Description copied from interface: ExecutionOperations

Cancel the execution.

Specified by:

cancel in interface ExecutionOperations

Parameters:

execution - to cancel

Returns:

Future which completes when the cancellation is done

markFailed

public void markFailed(Execution execution,
                       Throwable cause)

Description copied from interface: ExecutionOperations

Mark the execution as FAILED.

Specified by:

markFailed in interface ExecutionOperations

Parameters:

execution - to mark as failed.

cause - of the execution failure