I have some test RDD with case class Product (tokens : String, count : Long, timestamp : Long,id :Int) in Spark-Scala.
timestamp - System.currentTimeMillis()
I wrote it to elasticsearch, but later i'll need to update this data and write new rdd.
My problem is that I don't know, how to delete old data by field timestamp (using Spark ElasticSearch).This is part of online application, so I can't just delete old data and then write new.
I could't find any information in documentation.
Could someone help me?