org.apache.flink.streaming.api.functions.sink.filesystem

Interface InProgressFileWriter.InProgressFileRecoverable

All Superinterfaces:

InProgressFileWriter.PendingFileRecoverable

All Known Implementing Classes:

OutputStreamBasedPartFileWriter.OutputStreamBasedInProgressFileRecoverable

Enclosing interface:

InProgressFileWriter<IN,BucketID>

public static interface InProgressFileWriter.InProgressFileRecoverable
extends InProgressFileWriter.PendingFileRecoverable

A handle can be used to recover in-progress file..