ArtemKoval

import org.apache.spark.{SparkConf, SparkContext}
import org.elasticsearch.spark._

object EsSpark {
  def main(args: Array[String]): Unit = {
    val conf = new SparkConf().setAppName("es-spark").setMaster("local[*]")
    conf.set("es.index.auto.create", "true")
    conf.set("es.nodes", "amazonaws.com")
    conf.set("es.port", "443")
    conf.set("es.nodes.wan.only", "true")