Package org.apache.flink.api.common.io

Class FirstAttemptInitializationContext

java.lang.Object

org.apache.flink.api.common.io.FirstAttemptInitializationContext

All Implemented Interfaces:

OutputFormat.InitializationContext

@PublicEvolving
public class FirstAttemptInitializationContext
extends Object
implements OutputFormat.InitializationContext

Special OutputFormat.InitializationContext, whose attempt number always zero.

Method Summary

Modifier and Type	Method	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.
static FirstAttemptInitializationContext	of(int taskNumber, int numTasks)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

of

public static FirstAttemptInitializationContext of(int taskNumber,
                                                   int numTasks)

getNumTasks

public int getNumTasks()

Description copied from interface: OutputFormat.InitializationContext

Gets the parallelism with which the parallel task runs.

Specified by:

getNumTasks in interface OutputFormat.InitializationContext

Returns:

The parallelism with which the parallel task runs.

getTaskNumber

public int getTaskNumber()

Description copied from interface: OutputFormat.InitializationContext

Gets the number of this parallel subtask. The numbering starts from 0 and goes up to parallelism-1 (parallelism as returned by OutputFormat.InitializationContext.getNumTasks()).

Specified by:

getTaskNumber in interface OutputFormat.InitializationContext

Returns:

The index of the parallel subtask.

getAttemptNumber

public int getAttemptNumber()

Description copied from interface: OutputFormat.InitializationContext

Gets the attempt number of this parallel subtask. First attempt is numbered 0.

Specified by:

getAttemptNumber in interface OutputFormat.InitializationContext

Returns:

Attempt number of the subtask.