Hive Beeline提交查询过程
2021-09-07 17:39:39 0 举报hive sql提交查询过程
作者其他创作
大纲/内容
SQL
getDatabaseConnection().getConnection()
HiveServer2
获取ResultSetHiveStatement.getResultSet
session.executeStatementAsync
Beeline.createStatement
打印ResultSetbeeLine.print
获取format并获取对应的OutputFormat
获取HiveSessionsessionManager.getSession
new HiveStatement()
HiveStatement.execute
HiveStatement.runAsyncOnServer构建TExecuteStatementReq请求参数，调用Thrift服务TCLIService.iface的ExecuteStatement方法，异步请求
Operation.run
HiveConnection.createStatement
CliService.executeStatementAsync
SQLOperation.runQuery
Beeline.executeInternal
driver.run
设置RUNNING状态，初始化DriverSQLOperation.prepare
DriverManager.getConnection
获取ExecuteStatementOperationOperationManager.newExecuteStatementOperation
获取配置，建立链接DatabaseConnection.connect
SQLOperation.runInternal
创建Statement
OutputFormat.print
Thrift服务调用
收藏
收藏
0 条评论
下一页
