Package org.apache.flink.core.fs

Interface RecoverableWriter.ResumeRecoverable

All Superinterfaces:

RecoverableWriter.CommitRecoverable

All Known Implementing Classes:

HadoopFsRecoverable, OSSRecoverable, S3Recoverable

Enclosing interface:

RecoverableWriter

public static interface RecoverableWriter.ResumeRecoverable
extends RecoverableWriter.CommitRecoverable

A handle to an in-progress stream with a defined and persistent amount of data. The handle can be used to recover the stream exactly as of that point and either publish the result file or keep appending data to the stream.