11.2.2 流处理