public class FileSplit extends BaseInputSplit
Modifier and Type | Field and Description |
---|---|
protected java.lang.String[] |
allowFormat |
protected java.util.Random |
random |
protected boolean |
randomize |
protected boolean |
recursive |
protected java.io.File |
rootDir |
iterationOrder, length, uriStrings
Modifier | Constructor and Description |
---|---|
|
FileSplit(java.io.File rootDir) |
|
FileSplit(java.io.File rootDir,
java.util.Random rng) |
|
FileSplit(java.io.File rootDir,
java.lang.String[] allowFormat) |
|
FileSplit(java.io.File rootDir,
java.lang.String[] allowFormat,
boolean recursive) |
protected |
FileSplit(java.io.File rootDir,
java.lang.String[] allowFormat,
boolean recursive,
java.util.Random random,
boolean runMain) |
|
FileSplit(java.io.File rootDir,
java.lang.String[] allowFormat,
java.util.Random rng) |
Modifier and Type | Method and Description |
---|---|
java.io.File |
getRootDir() |
protected void |
initialize() |
long |
length()
Length of the split
|
void |
readFields(java.io.DataInput in)
Deserialize the fields of this object from
in . |
void |
reset()
Reset the InputSplit without reinitializing it from scratch.
|
void |
write(java.io.DataOutput out)
Serialize the fields of this object to
out . |
locations, locationsIterator, locationsPathIterator, sample, toDouble, toFloat, toInt, toLong
protected java.io.File rootDir
protected java.lang.String[] allowFormat
protected boolean recursive
protected java.util.Random random
protected boolean randomize
protected FileSplit(java.io.File rootDir, java.lang.String[] allowFormat, boolean recursive, java.util.Random random, boolean runMain)
public FileSplit(java.io.File rootDir)
public FileSplit(java.io.File rootDir, java.util.Random rng)
public FileSplit(java.io.File rootDir, java.lang.String[] allowFormat)
public FileSplit(java.io.File rootDir, java.lang.String[] allowFormat, java.util.Random rng)
public FileSplit(java.io.File rootDir, java.lang.String[] allowFormat, boolean recursive)
protected void initialize()
public long length()
InputSplit
length
in interface InputSplit
length
in class BaseInputSplit
public void reset()
InputSplit
public void write(java.io.DataOutput out) throws java.io.IOException
Writable
out
.out
- DataOuput
to serialize this object into.java.io.IOException
public void readFields(java.io.DataInput in) throws java.io.IOException
Writable
in
.
For efficiency, implementations should attempt to re-use storage in the existing object where possible.
in
- DataInput
to deseriablize this object from.java.io.IOException
public java.io.File getRootDir()