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