@InterfaceAudience.Public @InterfaceStability.Stable public class FileSplit extends InputSplit implements Writable
InputFormat.getSplits(JobContext)
and passed to
InputFormat.createRecordReader(InputSplit,TaskAttemptContext)
.Constructor and Description |
---|
FileSplit() |
FileSplit(Path file,
long start,
long length,
String[] hosts)
Constructs a split with host information
|
Modifier and Type | Method and Description |
---|---|
long |
getLength()
The number of bytes in the file to process.
|
String[] |
getLocations()
Get the list of nodes by name where the data for the split would be local.
|
Path |
getPath()
The file containing this split's data.
|
long |
getStart()
The position of the first byte in the file to process.
|
void |
readFields(DataInput in)
Deserialize the fields of this object from
in . |
String |
toString() |
void |
write(DataOutput out)
Serialize the fields of this object to
out . |
public FileSplit()
public FileSplit(Path file, long start, long length, String[] hosts)
file
- the file namestart
- the position of the first byte in the file to processlength
- the number of bytes in the file to processhosts
- the list of hosts containing the block, possibly nullpublic long getStart()
public long getLength()
getLength
in class InputSplit
public void write(DataOutput out) throws IOException
Writable
out
.write
in interface Writable
out
- DataOuput
to serialize this object into.IOException
public void readFields(DataInput in) throws IOException
Writable
in
.
For efficiency, implementations should attempt to re-use storage in the existing object where possible.
readFields
in interface Writable
in
- DataInput
to deseriablize this object from.IOException
public String[] getLocations() throws IOException
InputSplit
getLocations
in class InputSplit
IOException
Copyright © 2014 Apache Software Foundation. All Rights Reserved.