org.apache.flink.runtime.fs.hdfs

Class LocatedHadoopFileStatus

java.lang.Object

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

org.apache.flink.runtime.fs.hdfs.LocatedHadoopFileStatus

All Implemented Interfaces:

FileStatus, LocatedFileStatus

public final class LocatedHadoopFileStatus
extends HadoopFileStatus
implements LocatedFileStatus

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

Constructor Summary

Constructors

Constructor and Description
LocatedHadoopFileStatus(org.apache.hadoop.fs.LocatedFileStatus fileStatus) Creates a new located file status from an HDFS file status.

Method Summary

Modifier and Type	Method and Description
BlockLocation[]	getBlockLocations() Gets the location information for the file.

Methods inherited from class org.apache.flink.runtime.fs.hdfs.HadoopFileStatus

fromHadoopStatus, getAccessTime, getBlockSize, getInternalFileStatus, getLen, getModificationTime, getPath, getReplication, isDir

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.core.fs.FileStatus

getAccessTime, getBlockSize, getLen, getModificationTime, getPath, getReplication, isDir

Constructor Detail

LocatedHadoopFileStatus

public LocatedHadoopFileStatus(org.apache.hadoop.fs.LocatedFileStatus fileStatus)

Creates a new located file status from an HDFS file status.

Method Detail

getBlockLocations

public BlockLocation[] getBlockLocations()

Description copied from interface: LocatedFileStatus

Gets the location information for the file. The location is per block, because each block may live potentially at a different location.

Files without location information typically expose one block with no host information for that block.

Specified by:

getBlockLocations in interface LocatedFileStatus