Streams 191

Relies on pull requests https://github.com/apache/incubator-streams/pull/98
and https://github.com/apache/incubator-streams/pull/98.

Once those are merged in this one will not have so many files to review.  Please wait till those requests are merged in before reviewing this request.

This handles implemented the throughput queues form the previous request into the local streambuilder, added new tests, and improving old tests.
So this logic tries and retries one time.  It seems like this could be better organized for readability and reduced code.