Skip to content

Instantly share code, notes, and snippets.

@IvanFernandez
IvanFernandez / SparkToElasticSearch
Last active Oct 10, 2016
Gist to persist from Spark to ElasticSearch
View SparkToElasticSearch
String mode = args[0];
final String collection = args[1];
SparkConf sparkConf = new SparkConf();
sparkConf.set("es.nodes", args[2]);
sparkConf.setAppName("Spark to ElasticSearch PoC");
sparkConf.setMaster(mode);
// Twitter configuration
You can’t perform that action at this time.