org.apache.flink.api.common.io

Interface CleanupWhenUnsuccessful

All Known Implementing Classes:

AvroOutputFormat, BinaryOutputFormat, CsvOutputFormat, FileOutputFormat, ScalaCsvOutputFormat, SerializedOutputFormat, TextOutputFormat, TypeSerializerOutputFormat

@Public
public interface CleanupWhenUnsuccessful

OutputFormats may implement this interface to run a cleanup hook when the execution is not successful.

Method Summary

Modifier and Type	Method and Description
void	tryCleanupOnError() Hook that is called upon an unsuccessful execution.

Method Detail

tryCleanupOnError

void tryCleanupOnError()
                throws Exception

Hook that is called upon an unsuccessful execution.

Throws:

Exception - The method may forward exceptions when the cleanup fails.