Spark Streaming简单入门(示例+原理)

概述 SparkStreaming是流式处理框架,是Spark API的扩展,支持可扩展、高吞吐量、容错的实时数据流处理,实时数据的来源能够是:Kafka, Flume, Twitter, ZeroMQ或者TCP sockets,而且可使用高级功能的复杂算子来处理流数据。例如:map,reduce,join,window 。最终,处理后的数据能够存放在文件系统,数据库等,方便实时展示。java 一
相关文章
相关标签/搜索