public class NoSQLFileInputFormat extends FileInputFormatAdapter<org.apache.hadoop.io.Text,RecordInfo>
FileInputFormatAdapter.FileRecordReaderAdapter<K,V>, FileInputFormatAdapter.FileSplitAdapterCONF_INPUT_FORMAT| Constructor and Description |
|---|
NoSQLFileInputFormat() |
| Modifier and Type | Method and Description |
|---|---|
protected org.apache.hadoop.mapreduce.InputFormat<org.apache.hadoop.io.Text,RecordInfo> |
getInputFormat(org.apache.hadoop.conf.Configuration conf) |
protected java.util.List<org.apache.hadoop.mapreduce.InputSplit> |
toFileSplits(java.util.List<org.apache.hadoop.mapreduce.InputSplit> inSplits, org.apache.hadoop.mapreduce.JobContext context) |
createRecordReader, getSplits, setInputFormatClass, toFileSplitAdapteraddInputPath, addInputPaths, computeSplitSize, getBlockIndex, getFormatMinSplitSize, getInputPathFilter, getInputPaths, getMaxSplitSize, getMinSplitSize, isSplitable, listStatus, setInputPathFilter, setInputPaths, setInputPaths, setMaxInputSplitSize, setMinInputSplitSizeprotected org.apache.hadoop.mapreduce.InputFormat<org.apache.hadoop.io.Text,RecordInfo> getInputFormat(org.apache.hadoop.conf.Configuration conf)
getInputFormat in class FileInputFormatAdapter<org.apache.hadoop.io.Text,RecordInfo>
protected java.util.List<org.apache.hadoop.mapreduce.InputSplit> toFileSplits(java.util.List<org.apache.hadoop.mapreduce.InputSplit> inSplits,
org.apache.hadoop.mapreduce.JobContext context)
throws java.io.IOException
toFileSplits in class FileInputFormatAdapter<org.apache.hadoop.io.Text,RecordInfo>java.io.IOExceptionCopyright © 2016 Oracle and/or its affiliates. All Rights Reserved.