public class DefaultExecutionVertexOperations extends Object implements ExecutionVertexOperations
ExecutionVertexOperations
.Constructor and Description |
---|
DefaultExecutionVertexOperations() |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<?> |
cancel(ExecutionVertex executionVertex) |
void |
deploy(ExecutionVertex executionVertex) |
void |
markFailed(ExecutionVertex executionVertex,
Throwable cause) |
public void deploy(ExecutionVertex executionVertex) throws JobException
deploy
in interface ExecutionVertexOperations
JobException
public CompletableFuture<?> cancel(ExecutionVertex executionVertex)
cancel
in interface ExecutionVertexOperations
public void markFailed(ExecutionVertex executionVertex, Throwable cause)
markFailed
in interface ExecutionVertexOperations
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.