org.apache.flink.runtime.scheduler

Interface ExecutionVertexOperations

All Known Implementing Classes:

DefaultExecutionVertexOperations

public interface ExecutionVertexOperations

Operations on the ExecutionVertex.

Method Summary

Modifier and Type	Method and Description
CompletableFuture<?>	cancel(ExecutionVertex executionVertex)
void	deploy(ExecutionVertex executionVertex)
void	markFailed(ExecutionVertex executionVertex, Throwable cause)

Method Detail

deploy

void deploy(ExecutionVertex executionVertex)
     throws JobException

Throws:

JobException

cancel

CompletableFuture<?> cancel(ExecutionVertex executionVertex)

markFailed

void markFailed(ExecutionVertex executionVertex,
                Throwable cause)