Jdbc/ODBC 输出¶
通过Jdbc/Odbc协议查询存储在数仓中的托管表、全局临时视图或者执行ChannelQuery脚本。
Jdbc¶
选择下载 Simba JDBC Driver for Apache Spark™ 并解压出 SparkJDBC41.jar 置于类路径。
连接配置
配置项 |
值 |
|---|---|
Url |
jdbc:spark://<hostname>:10015 |
Driver |
com.simba.spark.jdbc41.Driver |
用户名 |
sa(默认) |
密码 |
sa(默认) |
重要
用户名和密码可在 hive-site.xml 中配置
ODBC¶
Windows 下载安装： Microsoft® Spark ODBC Driver
连接配置
配置项 |
值 |
|---|---|
主机 |
x.x.x.x |
端口 |
10015 |
数据库 |
default |
认证方式 |
使用用户名和密码 |
用户名 |
sa(默认) |
密码 |
sa(默认) |
Trift 传输 |
SASL |
或者下载支持Linux/Windows的ODBC驱动： Simba ODBC Driver for Apache Spark™， 如何使用请阅读安装向导。
重要
用户名和密码可在 hive-site.xml 中配置
ChannelQuery 脚本执行¶
在能正确通过Jdbc/Odbc访问数仓前提下：
-- 返回结果集
select channel('demo.sql', '2012-12-12', 1)
-- 返回指示是否运行成功的信息
-- 用于定时调度，创建托管表/全局临时视图/数据分发的场景
select channel_bg('demo.sql', '2012-12-12')
警告
运行脚本如果发生找不到函数的错误，请在连接初始化脚本里写上：
CREATE OR REPLACE TEMPORARY FUNCTION channel as 'com.torchdb.framework.udf.ChannelQueryUDTF'
CREATE OR REPLACE TEMPORARY FUNCTION channel_bg as 'com.torchdb.framework.udf.ChannelQueryTaskUDTF'