Package org.apache.flink.runtime.fs.hdfs
Class HadoopBlockLocation
- java.lang.Object
-
- org.apache.flink.runtime.fs.hdfs.HadoopBlockLocation
-
- All Implemented Interfaces:
Comparable<org.apache.flink.core.fs.BlockLocation>,org.apache.flink.core.fs.BlockLocation
public final class HadoopBlockLocation extends Object implements org.apache.flink.core.fs.BlockLocation
Implementation of theBlockLocationinterface for the Hadoop Distributed File System.
-
-
Constructor Summary
Constructors Constructor Description HadoopBlockLocation(org.apache.hadoop.fs.BlockLocation blockLocation)Creates a new block location.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description intcompareTo(org.apache.flink.core.fs.BlockLocation o)String[]getHosts()longgetLength()longgetOffset()
-
-
-
Method Detail
-
getHosts
public String[] getHosts() throws IOException
- Specified by:
getHostsin interfaceorg.apache.flink.core.fs.BlockLocation- Throws:
IOException
-
getLength
public long getLength()
- Specified by:
getLengthin interfaceorg.apache.flink.core.fs.BlockLocation
-
getOffset
public long getOffset()
- Specified by:
getOffsetin interfaceorg.apache.flink.core.fs.BlockLocation
-
compareTo
public int compareTo(org.apache.flink.core.fs.BlockLocation o)
- Specified by:
compareToin interfaceComparable<org.apache.flink.core.fs.BlockLocation>
-
-