Class LocatedHadoopFileStatus

  • All Implemented Interfaces:
    org.apache.flink.core.fs.FileStatus, org.apache.flink.core.fs.LocatedFileStatus

    public final class LocatedHadoopFileStatus
    extends HadoopFileStatus
    implements org.apache.flink.core.fs.LocatedFileStatus
    Concrete implementation of the LocatedFileStatus interface for the Hadoop Distributed File System.
    • 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 org.apache.flink.core.fs.BlockLocation[] getBlockLocations()
        Specified by:
        getBlockLocations in interface org.apache.flink.core.fs.LocatedFileStatus