[streaming] DataStream type refactor
[streaming] Added new DataStream types for operators
[streaming] Updated Streaming function interfaces to match main project
[streaming] API update with more differentiated DataStream types and javadoc + several fixes