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