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