Zeppelin运行paragraph的整个流程分析
前文分别讲述了,JdbcInterpreter、Interpreter、Zengine的流程,本文来主要串联起来paragraph的整个流程
前端
首先前端部分点运行的时候是通过websocket向后端发送请求的zeppelin-web/src/components/websocket/websocket-message.service.js 里面的runParagraph向后端发送请求
后端
zeppelin-server/src/main/java/org/apache/zeppelin/socket/NotebookServer.java 里面的 onMessage 根据前端传进来的参数进入到不同的方法里面
流程为:
NotebookServer.runParagraph–>NotebookService.runParagraph–>Note.run–>Paragraph.execute–>Paragraph.jobRun
至此再进入到RemoteInterpreter.interpret 即和上文串起来了
前端分为旧前端和新的前端界面
旧前端为AngularJs zeppelin-web
新前端为Angular zeppelin-web-angular 目录
参考:
(1)websocket 介绍
https://www.ruanyifeng.com/blog/2017/05/websocket.html
https://blog.csdn.net/KeepStruggling/article/details/105543449