This project contains an abstract implementation of an ElasticSearch River and is used as a basis for custom river implementations.