2.2 DataStream API