HadoopFsRecoverable (Flink : FileSystems : Hadoop FS 2.2.0 API)

java.lang.Object
- org.apache.flink.runtime.fs.hdfs.HadoopFsRecoverable

All Implemented Interfaces:

org.apache.flink.core.fs.RecoverableWriter.CommitRecoverable, org.apache.flink.core.fs.RecoverableWriter.ResumeRecoverable
```
@Internal
public class HadoopFsRecoverable
extends Object
implements org.apache.flink.core.fs.RecoverableWriter.CommitRecoverable, org.apache.flink.core.fs.RecoverableWriter.ResumeRecoverable
```
An implementation of the resume and commit descriptor objects for Hadoop's/AzureBlob file system abstraction.

Constructor Summary

Constructors
Constructor	Description
`HadoopFsRecoverable(org.apache.hadoop.fs.Path targetFile, org.apache.hadoop.fs.Path tempFile, long offset)`	Creates a resumable for the given file at the given position.

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`long`	`offset()`
`org.apache.hadoop.fs.Path`	`targetFile()`
`org.apache.hadoop.fs.Path`	`tempFile()`
`String`	`toString()`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail
- HadoopFsRecoverable
```
public HadoopFsRecoverable(org.apache.hadoop.fs.Path targetFile,
                           org.apache.hadoop.fs.Path tempFile,
                           long offset)
```
  Creates a resumable for the given file at the given position.
  
  Parameters:
  
  targetFile - The file to resume.
  
  offset - The position to resume from.

Method Detail

targetFile

public org.apache.hadoop.fs.Path targetFile()

tempFile

public org.apache.hadoop.fs.Path tempFile()

offset
```
public long offset()
```

toString
```
public String toString()
```
Overrides:

toString in class Object