Package org.apache.flink.api.common.io
Interface OutputFormat.InitializationContext
-
- Enclosing interface:
- OutputFormat<IT>
@Public public static interface OutputFormat.InitializationContextThe context exposes some runtime info for initializing output format.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description intgetAttemptNumber()Gets the attempt number of this parallel subtask.intgetNumTasks()Gets the parallelism with which the parallel task runs.intgetTaskNumber()Gets the number of this parallel subtask.
-
-
-
Method Detail
-
getNumTasks
int getNumTasks()
Gets the parallelism with which the parallel task runs.- Returns:
- The parallelism with which the parallel task runs.
-
getTaskNumber
int getTaskNumber()
Gets the number of this parallel subtask. The numbering starts from 0 and goes up to parallelism-1 (parallelism as returned bygetNumTasks()).- Returns:
- The index of the parallel subtask.
-
getAttemptNumber
int getAttemptNumber()
Gets the attempt number of this parallel subtask. First attempt is numbered 0.- Returns:
- Attempt number of the subtask.
-
-