If I am storing page view statistics using flume, which flushes to a file every x seconds, is there a event/hook available that I can pre-filter the collection?
Example: I want to roll-up the stats for a given minute, this will reduce the # of messages substantially. (I can filter using a dictionary where the sessionId is the key)
