Package org.elasticsearch.hadoop.mr
Class EsInputFormat<K,V>
java.lang.Object
org.apache.hadoop.mapreduce.InputFormat<K,V>
org.elasticsearch.hadoop.mr.EsInputFormat<K,V>
- All Implemented Interfaces:
InputFormat<K,V>
ElasticSearch
InputFormat for streaming data (typically based on a query) from ElasticSearch.
Returns the document ID as key and its content as value.
This class implements both the "old" (org.apache.hadoop.mapred) and the "new" (org.apache.hadoop.mapreduce) API.-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionprotected static classprotected static classprotected static classprotected static classprotected static class -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptioncreateRecordReader(InputSplit split, TaskAttemptContext context) getRecordReader(InputSplit split, JobConf job, Reporter reporter) Deprecated.Deprecated.getSplits(JobContext context) protected boolean
-
Constructor Details
-
EsInputFormat
public EsInputFormat()
-
-
Method Details
-
getSplits
- Specified by:
getSplitsin classInputFormat<K,V> - Throws:
IOException
-
createRecordReader
public EsInputFormat.EsInputRecordReader<K,V> createRecordReader(InputSplit split, TaskAttemptContext context) - Specified by:
createRecordReaderin classInputFormat<K,V>
-
getSplits
Deprecated.- Specified by:
getSplitsin interfaceInputFormat<K,V> - Throws:
IOException
-
getRecordReader
@Deprecated public EsInputFormat.EsInputRecordReader<K,V> getRecordReader(InputSplit split, JobConf job, Reporter reporter) Deprecated.- Specified by:
getRecordReaderin interfaceInputFormat<K,V>
-
isOutputAsJson
-