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

Class HadoopFileStatus

java.lang.Object

org.apache.flink.runtime.fs.hdfs.HadoopFileStatus

All Implemented Interfaces:

FileStatus

Direct Known Subclasses:

LocatedHadoopFileStatus

public class HadoopFileStatus
extends Object
implements FileStatus

Concrete implementation of the FileStatus interface for the Hadoop Distributed File System.

Constructor Summary

Constructors

Constructor	Description
HadoopFileStatus(org.apache.hadoop.fs.FileStatus fileStatus)	Creates a new file status from an HDFS file status.

Method Summary

Modifier and Type	Method	Description
static HadoopFileStatus	fromHadoopStatus(org.apache.hadoop.fs.FileStatus fileStatus)	Creates a new HadoopFileStatus from Hadoop's FileStatus.
long	getAccessTime()	Get the access time of the file.
long	getBlockSize()	Get the block size of the file.
org.apache.hadoop.fs.FileStatus	getInternalFileStatus()
long	getLen()	Return the length of this file.
long	getModificationTime()	Get the modification time of the file.
Path	getPath()	Returns the corresponding Path to the FileStatus.
short	getReplication()	Get the replication factor of a file.
boolean	isDir()	Checks if this object represents a directory.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

HadoopFileStatus

public HadoopFileStatus(org.apache.hadoop.fs.FileStatus fileStatus)

Creates a new file status from an HDFS file status.

Parameters:

fileStatus - the HDFS file status

Method Detail

getLen

public long getLen()

Description copied from interface: FileStatus

Return the length of this file.

Specified by:

getLen in interface FileStatus

Returns:

the length of this file

getBlockSize

public long getBlockSize()

Description copied from interface: FileStatus

Get the block size of the file.

Specified by:

getBlockSize in interface FileStatus

Returns:

the number of bytes

getAccessTime

public long getAccessTime()

Description copied from interface: FileStatus

Get the access time of the file.

Specified by:

getAccessTime in interface FileStatus

Returns:

the access time of file in milliseconds since January 1, 1970 UTC.

getModificationTime

public long getModificationTime()

Description copied from interface: FileStatus

Get the modification time of the file.

Specified by:

getModificationTime in interface FileStatus

Returns:

the modification time of file in milliseconds since January 1, 1970 UTC.

getReplication

public short getReplication()

Description copied from interface: FileStatus

Get the replication factor of a file.

Specified by:

getReplication in interface FileStatus

Returns:

the replication factor of a file.

getPath

public Path getPath()

Description copied from interface: FileStatus

Returns the corresponding Path to the FileStatus.

Specified by:

getPath in interface FileStatus

Returns:

the corresponding Path to the FileStatus

isDir

public boolean isDir()

Description copied from interface: FileStatus

Checks if this object represents a directory.

Specified by:

isDir in interface FileStatus

Returns:

true if this is a directory, false otherwise

getInternalFileStatus

public org.apache.hadoop.fs.FileStatus getInternalFileStatus()

fromHadoopStatus

public static HadoopFileStatus fromHadoopStatus(org.apache.hadoop.fs.FileStatus fileStatus)

Creates a new HadoopFileStatus from Hadoop's FileStatus. If Hadoop's file status is located, i.e., it contains block information, then this method returns an implementation of Flink's LocatedFileStatus.