org.apache.flink.api.common.io

Interface FinalizeOnMaster.FinalizationContext

Enclosing interface:

FinalizeOnMaster

@Public
public static interface FinalizeOnMaster.FinalizationContext

A context that provides parallelism and finished attempts infos.

Method Summary

Modifier and Type	Method and Description
int	getFinishedAttempt(int subtaskIndex) Get the finished attempt number of subtask.
int	getParallelism() 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.