[streaming] Added new DataStream types for operators