Major changes to the streamer threads. Created more Esper aggregating
operators to balance load. Seems to work fine..