Class OutputStreamBasedPartFileWriter.OutputStreamBasedInProgressFileRecoverable
- java.lang.Object
-
- org.apache.flink.streaming.api.functions.sink.filesystem.OutputStreamBasedPartFileWriter.OutputStreamBasedInProgressFileRecoverable
-
- All Implemented Interfaces:
InProgressFileWriter.InProgressFileRecoverable
,InProgressFileWriter.PendingFileRecoverable
- Enclosing class:
- OutputStreamBasedPartFileWriter<IN,BucketID>
public static final class OutputStreamBasedPartFileWriter.OutputStreamBasedInProgressFileRecoverable extends Object implements InProgressFileWriter.InProgressFileRecoverable
TheInProgressFileWriter.InProgressFileRecoverable
implementation forOutputStreamBasedPartFileWriter.OutputStreamBasedBucketWriter
.
-
-
Constructor Summary
Constructors Constructor Description OutputStreamBasedInProgressFileRecoverable(RecoverableWriter.ResumeRecoverable resumeRecoverable)
Deprecated.OutputStreamBasedInProgressFileRecoverable(RecoverableWriter.ResumeRecoverable resumeRecoverable, Path targetPath)
-
-
-
Constructor Detail
-
OutputStreamBasedInProgressFileRecoverable
@Deprecated public OutputStreamBasedInProgressFileRecoverable(RecoverableWriter.ResumeRecoverable resumeRecoverable)
Deprecated.
-
OutputStreamBasedInProgressFileRecoverable
public OutputStreamBasedInProgressFileRecoverable(RecoverableWriter.ResumeRecoverable resumeRecoverable, @Nullable Path targetPath)
-
-
Method Detail
-
getPath
public Path getPath()
- Specified by:
getPath
in interfaceInProgressFileWriter.PendingFileRecoverable
- Returns:
- The target path of the pending file, null if unavailable.
-
getSize
public long getSize()
- Specified by:
getSize
in interfaceInProgressFileWriter.PendingFileRecoverable
- Returns:
- The size of the pending file, -1 if unavailable.
-
-