Interface JobVertex.FinalizeOnMasterContext
-
- Enclosing class:
- JobVertex
public static interface JobVertex.FinalizeOnMasterContext
The context exposes some runtime infos for finalization.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description ClassLoader
getClassLoader()
The class loader for user defined code.int
getExecutionParallelism()
The actual parallelism this vertex will be run with.int
getFinishedAttempt(int subtaskIndex)
Get the finished attempt number of subtask.
-
-
-
Method Detail
-
getClassLoader
ClassLoader getClassLoader()
The class loader for user defined code.
-
getExecutionParallelism
int getExecutionParallelism()
The actual parallelism this vertex will be run with. In contrast, theJobVertex.getParallelism()
is the original parallelism set when creating theJobGraph
and might be updated e.g. by theAdaptiveScheduler
.
-
getFinishedAttempt
int getFinishedAttempt(int subtaskIndex)
Get the finished attempt number of subtask.- Parameters:
subtaskIndex
- the subtask index.- Returns:
- the finished attempt.
- Throws:
IllegalArgumentException
- Thrown, if subtaskIndex is invalid.
-
-