野性河马

文章
3
资源
0
加入时间
3年0月21天

用json实现深拷贝

一、代码 private SaleDetailReportRespDTO deepCopy(SaleDetailReportRespDTO obj) { String json = JSON.toJSONString(obj); return JSON.parseObject(json, SaleDetailReportRespDTO.class); ...

Spark源码解析03-Submit提交流程及Driver启动流程

1、前言由前面的文章Spark基础06-Spark client和cluster提交流程我们已经知道了Spark client和cluster提交模式流程启动Driver进程,并向集群管理器注册应用程序集群资源管理器根据任务配置文件分配并启动ExecutorExecutor启动之后反向到Driver注册,Driver已经获取足够资源可以运行Driver开始执行main函数,Spark查询为懒执行,当执行到action算子时开始反向推算,根据宽依赖进行stage的划分,随后每一个stage对应一个