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.
no it is not.  LOGGER.warn is an appropriate action on a failed write.  or retry