public class EsHiveInputFormat extends EsInputFormat<Text,Writable>
FileInputFormat to ESInputFormat.EsInputFormat.AbstractWritableEsInputRecordReader<V>, EsInputFormat.EsInputRecordReader<K,V>, EsInputFormat.EsInputSplit, EsInputFormat.JsonWritableEsInputRecordReader, EsInputFormat.WritableEsInputRecordReader| Constructor and Description |
|---|
EsHiveInputFormat() |
| Modifier and Type | Method and Description |
|---|---|
EsInputFormat.AbstractWritableEsInputRecordReader |
getRecordReader(InputSplit split,
JobConf job,
Reporter reporter) |
FileSplit[] |
getSplits(JobConf job,
int numSplits) |
createRecordReader, getSplits, isOutputAsJsonpublic FileSplit[] getSplits(JobConf job, int numSplits) throws IOException
getSplits in interface InputFormat<Text,Writable>getSplits in class EsInputFormat<Text,Writable>IOExceptionpublic EsInputFormat.AbstractWritableEsInputRecordReader getRecordReader(InputSplit split, JobConf job, Reporter reporter)
getRecordReader in interface InputFormat<Text,Writable>getRecordReader in class EsInputFormat<Text,Writable>