A library to support streaming data applications - View it on GitHub