using logstash i have ingested file into elastic search with index/type .. car/soldcars
now for practising i want to read that csv file from spark using scala code.
;val spark= SparkSession.builder.master("local").appName("ReadFromES")
.config("es.nodes", "localhost").config("es.port",9200).config("es.resoruces","car/soldcars")
.config("es.index.auto.create","true").getOrCreate()
val es_df=spark.read.format("org.elasticsearch.spark.sql")
}
what to do next ?