3.1 DataStream API