public static class Fetcher.InputFormat extends SequenceFileInputFormat<Text,CrawlDatum>
FileInputFormat.CounterINPUT_DIR_RECURSIVE, LOG, NUM_INPUT_FILES| Constructor and Description |
|---|
InputFormat() |
| Modifier and Type | Method and Description |
|---|---|
InputSplit[] |
getSplits(JobConf job,
int nSplits)
Don't split inputs, to keep things polite.
|
getRecordReader, listStatusaddInputPath, addInputPathRecursively, addInputPaths, computeSplitSize, getBlockIndex, getInputPathFilter, getInputPaths, getSplitHosts, isSplitable, makeSplit, makeSplit, setInputPathFilter, setInputPaths, setInputPaths, setMinSplitSizepublic InputSplit[] getSplits(JobConf job, int nSplits) throws java.io.IOException
getSplits in interface InputFormat<Text,CrawlDatum>getSplits in class FileInputFormat<Text,CrawlDatum>java.io.IOExceptionCopyright © 2017 The Apache Software Foundation