sample of Hystrix Stream Aggregator in FileStream.java.  Takes a single stream from a file (should be a queue in the future) groups the streams by instanceId, then calls into turbine 2 to aggregate the streams properly.