把原始数据进行stream处理