A library to support streaming data applications