Cleaned up both map and reduce scripts.  Now following streams effectively; but need to find a better way of dealing with broken streams (ones without a clear start point).  Also, need to test on more varied data sets.