Structured Streaming Programming Guide

概述 结构化流是一种基于Spark SQL引擎的可扩展且容错的流处理引擎。他可以像表达静态数据的批处理计算一样表达流式计算。 快速示例 监听本地netcat服务器的输入内容 实时计算每个单词出现的次数在屏幕上打印 可以通过运行下载的Spark目录下的程序直接启动 再另外启动一个netcat服务器 再服务器终端输入内容即可在控制台看见相应的输出 编程模型 结构化流中的关键思想是将实时数据流视为连续追
相关文章
相关标签/搜索