[streaming] API update with more differentiated DataStream types and javadoc + several fixes