6.5 基于Flink平台的实现