public class FailoverRegion extends Object
Constructor and Description |
---|
FailoverRegion(ExecutionGraph executionGraph,
Executor executor,
List<ExecutionVertex> connectedExecutions) |
Modifier and Type | Method and Description |
---|---|
List<ExecutionVertex> |
getAllExecutionVertexes()
get all execution vertexes contained in this region
|
JobStatus |
getState() |
void |
onExecutionFail(Execution taskExecution,
Throwable cause) |
public FailoverRegion(ExecutionGraph executionGraph, Executor executor, List<ExecutionVertex> connectedExecutions)
public JobStatus getState()
public List<ExecutionVertex> getAllExecutionVertexes()
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.