Extensions to spark streaming to work with Algebird for aggregation and Storehaus for storage