[streaming] Iteration update to use proper partitioning and forward connection + DataStream refactor and Javadoc update