presto提交查询

提交查询的步骤

1、获取SQL

2、发送restful请求给coordinator,并返回结果

3、cli循环分批读取查询结果并显示

源码解析

CLI客户端启动类就Presto  main 方法  彩蛋  如果启动presto CLI 的时候有 --version or --help 将提示帮助信息

否则调用Console.run()  会生成一个查询执行包装类QueryRunner,后续的启动和执行都是通过该类

启动presto CLI时,如果指定了 --execute or --file 读取SQL 否则在CLI端输入SQL

SQL语句的提交和执行通过QueryRunner的 executeCommand方法, 其中 QueryRunner.startQuery初始执行,通过Query.renderOutput循环发送restful请求分批获取查询结果。

startQuery 中new statementClient对象,构建Request(通过session中的server值 即为coordinator的URI,进而将SQL以restful请求发送给coordinator 通过statementResource类) 并接收response

renderOutput  会根据interactive标识决定是否实时更新数据,如果距离上次更新超过0.5s 则更新。不管是否实时更新都会调用client.advance(),改方法通过coordinator返回的nextResultUri向coordinator继续发请求,来分批获得查询结果

提交查询的流程

client发请求给coordinator ,coordinator返回结果和nextResultUri,如果没有结果了结束,如果nextResultUri不为空继续发请求给coordinator。

©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容