Pre-filtering based Summarization for Data Partitioning in Distributed Stream Processing - View it on GitHub