public class LocalTextInputPartitioner extends FileInputPartitioner<java.lang.String>
config, filePath, numSplits, READ_WHOLE_SPLIT_FLAG, stream
Constructor and Description |
---|
LocalTextInputPartitioner(Path filePath,
int numTasks) |
LocalTextInputPartitioner(Path filePath,
int numTasks,
Config config) |
Modifier and Type | Method and Description |
---|---|
protected TextInputSplit |
createSplit(int num,
Path file,
long start,
long length,
java.lang.String[] hosts) |
OrderedInputSplitAssigner<java.lang.String> |
getInputSplitAssigner(FileInputSplit<java.lang.String>[] inputSplits)
Return the input split asigner
|
configure, createInputSplits
public LocalTextInputPartitioner(Path filePath, int numTasks)
protected TextInputSplit createSplit(int num, Path file, long start, long length, java.lang.String[] hosts)
createSplit
in class FileInputPartitioner<java.lang.String>
public OrderedInputSplitAssigner<java.lang.String> getInputSplitAssigner(FileInputSplit<java.lang.String>[] inputSplits)
InputPartitioner
inputSplits
- the input splits to be assigned