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.
I don't think shutting down an single datum fail is correct.