...
Takes the Structured Record from the input source and converts it to a JSON string, then indexes it in Elasticsearch using the index, type, and ID Field specified by the user. The Elasticsearch server should be running prior to creating the application.
This Use this sink is used whenever you need to write to an Elasticsearch server. For example, you may might want to parse a file and read its contents into Elasticsearch, which you can achieve with a stream batch source and Elasticsearch as a sink.
...