Spark Streaming编程模型
文件大小: 107k
源码售价: 10 个金币 积分规则     积分充值
资源说明:本节将介绍 Spark Streaming 的编程模型,包括 DStream 的操作流程和使用方法。 DStream 的操作流程 DStream 作为 Spark Streaming 的基础抽象,它代表持续性的数据流。这些数据流既可以通过外部输入源来获取,也可以通过现有的 DStream 的 Transformation 操作来获得。 在内部实现上,DStream 由一组时间序列上连续的 RDD 来表示。如图 1 所示,每个 RDD 都包含了自己特定时间间隔内的数据流。 图 1  DStream中在时间轴下生成离散的RDD序列 如图 2 所示,对 DStream 中数据的各种操作也是映射
本源码包内暂不包含可直接显示的源代码文件,请下载源码包。