public class EsHiveInputFormat extends EsInputFormat<Text,Writable>
FileInputFormat to ESInputFormat.EsInputFormat.AbstractWritableShardRecordReader<V>, EsInputFormat.JsonWritableShardRecordReader, EsInputFormat.ShardInputSplit, EsInputFormat.ShardRecordReader<K,V>, EsInputFormat.WritableShardRecordReader| Constructor and Description |
|---|
EsHiveInputFormat() |
| Modifier and Type | Method and Description |
|---|---|
EsInputFormat.AbstractWritableShardRecordReader |
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.AbstractWritableShardRecordReader getRecordReader(InputSplit split, JobConf job, Reporter reporter)
getRecordReader in interface InputFormat<Text,Writable>getRecordReader in class EsInputFormat<Text,Writable>