org.elasticsearch.hadoop.mr

Class EsMapReduceUtil

java.lang.Object

org.elasticsearch.hadoop.mr.EsMapReduceUtil

public final class EsMapReduceUtil
extends java.lang.Object

Utility functions for setting up Map Reduce Jobs to read and write from Elasticsearch.

See Also:

For reading from Elasticsearch, For writing to Elasticsearch

Method Summary

Modifier and Type	Method and Description
static void	initCredentials(Job job) Given the settings contained within a job object, retrieve an authentication token from either the currently logged in user or from the Elasticsearch cluster and add it to the job's credential set.
static void	initCredentials(JobConf jobConf) Given the settings contained within the job conf, retrieve an authentication token from either the currently logged in user or from the Elasticsearch cluster and add it to the job's credential set.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

initCredentials

public static void initCredentials(Job job)

Given the settings contained within a job object, retrieve an authentication token from either the currently logged in user or from the Elasticsearch cluster and add it to the job's credential set.

Parameters:

job - for collecting the settings to connect to Elasticsearch, as well as for storing the authentication token

initCredentials

public static void initCredentials(JobConf jobConf)

Given the settings contained within the job conf, retrieve an authentication token from either the currently logged in user or from the Elasticsearch cluster and add it to the job's credential set.

Parameters:

jobConf - containing the settings to connect to Elasticsearch, as well as for storing the authentication token