Allow to pipe the result of an Elasticsearch query into a Flink data set
Data store evolution tool suite. Supports Mysql, Elasticsearch, and Cassandra.