一、Spark 运行架构 Spark 运行架构如下图：各个RDD之间存在着依赖关系，这些依赖关系形成有向无环图DAG，DAGScheduler对这些依赖关系形成的DAG，进行...
发简信
IP属地：四川
-
Spark 源码解析 : DAGScheduler中的DAG划分与提交 -
-
do something for myself
-
Structured Streaming 源码剖析（一）- Source一、trait Source Source 必须不断地到达数据以进行流式查询。 Source 必须具有单调递增的进度概念，用 offset 表示。 Spark 将定期查询每个...
-
永不止步 Keep Moving
