I am using following command to persist data in elastic search using spark streaming.
EsSparkSQL.saveToEs(DataFrame, indexname, ES_CONFIG)
With this, I am overwriting entire document, which I don't want.
I want to update only the fields for which data exists in this dataframe.
Please suggest, How to achieve this...