i want to retrieve Elasticsearch Data with ES-Hadoop.
i use the following code to retrieve Elastic data but get Java.io.IOException:
JobConf conf=new JobConf();
conf.set("es.nodes","10.25.4.12:9200");
conf.set("es.resource","university/docs");
conf.set("es.query","?q=*");
conf.setInputFormat(EsInputFormat.class);
conf.setMapOutputKeyClass(Text.class);
conf.setOutputValueClass(MapWritable.class);
FileOutputFormat.setOutputPath(conf,new Path(hdfs://10.25.4.12/user));
JobClient.runJob(conf);