Real-time analytics in Apache Flume