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'