Logstash Elasticsearch filter plugin Equivalent in Fluentd?

Hi Team,
Please Acknowledge us is any filter plugin available in Fluentd similar to Logstash Elasticsearch filter plugin.

Filter {
if [type] == “end” {
elasticsearch {
hosts => [“es-server”]
query => “type:start AND operation:%{[opid]}”
index => “test”
fields => { “@timestamp” => “started” }
}
}

plugin detail in Logstash:-Elasticsearch filter plugin | Logstash Reference [7.15] | Elastic