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, toLongprotected 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()
InputSplitlength in interface InputSplitlength in class BaseInputSplitpublic void reset()
InputSplitpublic void write(java.io.DataOutput out)
throws java.io.IOException
Writableout.out - DataOuput to serialize this object into.java.io.IOExceptionpublic void readFields(java.io.DataInput in)
throws java.io.IOException
Writablein.
For efficiency, implementations should attempt to re-use storage in the existing object where possible.
in - DataInput to deseriablize this object from.java.io.IOExceptionpublic java.io.File getRootDir()