Removed license comments from scala files. license.txt is enough.
Added DStream functions, minor changes in tests