FlumeBase is a database-inspired stream processing system built on top of Cloudera Flume. This system allows users to dynamically insert queries into a data collection environment and inspect the stream of events being collected by Flume. These queries may spot-check incoming data, or specify persistent monitoring, data transformation, or quality filtering tasks. Queries are written in [...]