class Fluent::Plugin::ElasticsearchOutputDataStream