First attempt to push logs stored on Hadoop into ElasticSearch

ha2es.pig

/*
Made by Pierre Zemb
Part-time internship at System Team
Credit Mutuel Arkea
2014
*/

REGISTER elasticsearch-hadoop-1.3.0.M2-yarn.jar;

DEFINE EsStorage org.elasticsearch.hadoop.pig.EsStorage();

YUMLOG = load '/hdfs/data/Hadoop2ES/sys.log' using PigStorage(' ') AS (jour:chararray, day:int, time:chararray, host:chararray, app:chararray, msg:chararray);

DUMP YUMLOG;

STORE YUMLOG INTO 'hadooplogs/logsevent' USING EsStorage(
        'es.http.timeout = 5m',
        'es.http.retries = 10',
        'es.http.timeout= 5m',
        'es.nodes = ip:port'
);