Streaming analytics in Apache Flume