Streaming data processing library.