sql异步查询流程图
2020-04-14 14:10:27 0 举报登录查看完整内容
hive impala数据查询流程图
作者其他创作
大纲/内容
进度增加10%
是否启动成功
否
成功
在数据库插入历史及执行状态记录，执行状态运行中
判断状态
用请求id分页查询结果数据
启动进度监听线程
状态为启动成功
获取连接
以请求id为key缓存执行对象到map
用请求id查询执行进度
进度100%或连接关闭
判断进度是否小于90%
判断map中是否存在以请求id为key的请求对象
状态为启动失败
返回进度及状态
读取进度及状态
执行线程结束
接收并展示数据
清除hdfs缓存
更新执行对象状态及进度到历史记录，删除执行对象
查询历史记录获取进度及状态
执行中
接收进度及状态
执行状态写入执行对象
设置请求对象进度状态为无实时状态
是
执行线程开始
缓存数据到hdfs
更新执行状态为失败
生成请求id
连接是否关闭
sql及其他参数
判断请求对象进度状态是否为实时状态
是否为hive模式
执行是否有异常
给出错误提示
失败
执行sql
结束进度监听线程
进度监听线程结束
解析appId
获取yarn日志
连接yarn
接收请求id及请求状态
获取执行进度并更新进度到执行对象
进度监听线程开始
分页读取缓存数据
执行是否有返回结果
创建执行对象
是否成功
是否存在appId
主线程携带请求id返回启动状态
启动执行线程
收藏
收藏
0 条评论
回复 删除
下一页
