Spark Streaming的工作机制

 1. Spark Streaming的工作机制

     Spark Streaming 是Spark核心API的一个扩展，可以实现高吞吐量的、具备容错机制的实时流数据的处理。

     支持从多种数据源获取数据，包括Kafk、Flume、Twitter、ZeroMQ、Kinesis 以及TCP sockets，

     从数据源获取数据之后，可以使用诸如map、reduce、join和window等高级函数进行复杂算法的处理。

     最后还可以将处理结果存储到文件系统，数据库和现场仪表盘。

 

2.编写Spark Streaming程序的基本步骤：

 

     

      

 

转载于:https://www.cnblogs.com/sevenyang/p/9785438.html

总结

以上是生活随笔为你收集整理的Spark Streaming的工作机制的全部内容，希望文章能够帮你解决所遇到的问题。

如果觉得生活随笔网站内容还不错，欢迎将生活随笔推荐给好友。