Instream aggreation using storm as a poc - first cut