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>

public class EsInputFormat<K,V> extends InputFormat<K,V> implements 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.