Interface InProgressFileWriter.PendingFileRecoverable
-
- All Known Subinterfaces:
InProgressFileWriter.InProgressFileRecoverable
- All Known Implementing Classes:
OutputStreamBasedPartFileWriter.OutputStreamBasedInProgressFileRecoverable,OutputStreamBasedPartFileWriter.OutputStreamBasedPendingFileRecoverable
- Enclosing interface:
- InProgressFileWriter<IN,BucketID>
public static interface InProgressFileWriter.PendingFileRecoverableThe handle can be used to recover pending file.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description org.apache.flink.core.fs.PathgetPath()longgetSize()
-
-
-
Method Detail
-
getPath
@Nullable org.apache.flink.core.fs.Path getPath()
- Returns:
- The target path of the pending file, null if unavailable.
-
getSize
long getSize()
- Returns:
- The size of the pending file, -1 if unavailable.
-
-