增加一个处理数据流的类 DataStream