5.2 MapReduce数据流