org.apache.flink.api.common.io

Interface OutputFormat.InitializationContext

Enclosing interface:

OutputFormat<IT>

@Public
public static interface OutputFormat.InitializationContext

The context exposes some runtime info for initializing output format.

Method Summary

Modifier and Type	Method and Description
int	getAttemptNumber() Gets the attempt number of this parallel subtask.
int	getNumTasks() Gets the parallelism with which the parallel task runs.
int	getTaskNumber() 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 by getNumTasks()).

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.