Package org.apache.flink.runtime.fs.hdfs

Class HadoopFsRecoverable

java.lang.Object

org.apache.flink.runtime.fs.hdfs.HadoopFsRecoverable

All Implemented Interfaces:

RecoverableWriter.CommitRecoverable, RecoverableWriter.ResumeRecoverable

@Internal
public class HadoopFsRecoverable
extends Object
implements RecoverableWriter.CommitRecoverable, 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

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