SparkStreaming支持的业务场景

目前而言SparkStreaming 主要支持以下三种业务场景&＃xff1a;

　　➢ 无状态操作&＃xff1a;只关注当前的DStream中的实时数据。例如&＃xff1a;只对当前DStream中的数据做正确性校验。&＃xff08;下一条与上一条数据无关&＃xff09;　　　　　　适合做预警系统

　　➢ 有状态操作&＃xff1a;对有状态的DStream进行操作时,需要依赖之前的数据。例如&＃xff1a;统计网站各个模块总的访问量。　　　　　　　　　　　　　　　　　累加累乘汇总　

　　➢ 窗口操作:对指定时间段范围内的DStream数据进行操作。例如&＃xff1a;需要统计一天之内网站各个模块的访问数量。　　　　　　　　　　　　　　　　热点

初识流计算　　　　　　

查看此例子&＃xff0c;对流计算直观认识
　　◆ 启动服务
　　◆ nc -lk 9999
　　◆ run-example streaming.NetworkWordCount localhost 9999

nc　　netcat　　网络工具命令