org.apache.flink.api.common.io

Interface FinalizeOnMaster

All Known Implementing Classes:

FileSystemOutputFormat, HadoopOutputFormat, HadoopOutputFormat, HadoopOutputFormatBase, HadoopOutputFormatBase

@Public
public interface FinalizeOnMaster

This interface may be implemented by OutputFormats to have the master finalize them globally.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	FinalizeOnMaster.FinalizationContext A context that provides parallelism and finished attempts infos.

Method Summary

Modifier and Type	Method and Description
default void	finalizeGlobal(FinalizeOnMaster.FinalizationContext context) The method is invoked on the master (JobManager) after all (parallel) instances of an OutputFormat finished.
default void	finalizeGlobal(int parallelism) Deprecated. Use finalizeGlobal(FinalizationContext) instead.

Method Detail

finalizeGlobal

@Deprecated
default void finalizeGlobal(int parallelism)
                                 throws IOException

Deprecated. Use finalizeGlobal(FinalizationContext) instead.

The method is invoked on the master (JobManager) after all (parallel) instances of an OutputFormat finished.

Parameters:

parallelism - The parallelism with which the format or functions was run.

Throws:

IOException - The finalization may throw exceptions, which may cause the job to abort.

finalizeGlobal

default void finalizeGlobal(FinalizeOnMaster.FinalizationContext context)
                     throws IOException

The method is invoked on the master (JobManager) after all (parallel) instances of an OutputFormat finished.

Parameters:

context - The context to get finalization infos.

Throws:

IOException - The finalization may throw exceptions, which may cause the job to abort.