Package org.apache.flink.api.common.io
Interface FinalizeOnMaster.FinalizationContext
-
- Enclosing interface:
- FinalizeOnMaster
@Public public static interface FinalizeOnMaster.FinalizationContextA context that provides parallelism and finished attempts infos.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description intgetFinishedAttempt(int subtaskIndex)Get the finished attempt number of subtask.intgetParallelism()Get the parallelism with which the format or functions was run.
-
-
-
Method Detail
-
getParallelism
int getParallelism()
Get the parallelism with which the format or functions was run.- Returns:
- the parallelism.
-
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.
-
-