本文我们来看一下Kylin如何对接JDBC,以及如何集成到Zepplin中。自定义编码可以实现更多的业务逻辑,而Zepplin是一个非常好用的编辑器工具。本文也是整个Kylin部分的最后一篇文章,关注专栏《破茧成蝶——大数据篇》,查看更多相关的内容~
一、Kylin对接JDBC
1、创建项目并导入依赖
<dependencies>
<dependency>
<groupId>org.apache.kylin</groupId>
<artifactId>kylin-jdbc</artifactId>
<version>2.5.1</version>
</dependency>
</dependencies>
2、编码实现
package com.xzw.kylin;
import java.sql.*;
/**
* @author: xzw
* @create_date: 2021/5/11 10:21
* @desc:
* @modifier:
* @modified_date:
* @desc:
*/
public class TestJDBC {
public static void main(String[] args) throws ClassNotFoundException, SQLException {
//1、定义连接串
String driverClass = "org.apache.kylin.jdbc.Driver";
String url = "jdbc:kylin://master:7070/emp_dept";
String user = "ADMIN";
String password = "KYLIN";
//2、加载驱动
Class.forName(driverClass);
//3、获取连接
Connection conn = DriverManager.getConnection(url, user, password);
//4、SQL语句
String sql = "select dept.dept_name,sum(emp.sal) from emp join dept on emp.dept_no = dept.dept_no group by " +
"dept.dept_name";
//5、预编译SQL
PreparedStatement ps = conn.prepareStatement(sql);
//6、执行SQL
ResultSet rs = ps.executeQuery();
//7、遍历,打印结果
while (rs.next()) {
System.out.println(rs.getString(1) + "\t" + rs.getString(2));
}
//8、关闭连接
conn.close();
}
}
3、结果展示
(1)在Kylin监控界面看到的结果如下所示:

(2)编码实现的结果如下所示:

二、Kylin集成Zepplin
2.1 安装Zepplin
1、将下载的安装包上传到服务器并解压
[root@master software]# tar -zxvf zeppelin-0.8.0-bin-all.tgz -C ../modules/
2、切换到Zepplin目录并使用如下命令启动
[root@master zeppelin-0.8.0-bin-all]# bin/zeppelin-daemon.sh start
3、登录到监控界面
master:8080

2.2 配置Zepplin支持Kylin
1、点击Interpreter

2、搜索kylin,并点击Edit

3、修改连接和项目名称,点击保存。

4、创建新的Notebook

5、测试

还可以进行各种各样的图表展示:

以上就是Kylin对接JDBC集成Zepplin的实现方法的详细内容,更多关于Kylin对接JDBC和Zepplin的资料请关注其它相关文章!
声明:本站所有文章,如无特殊说明或标注,均为本站原创发布。任何个人或组织,在未征得本站同意时,禁止复制、盗用、采集、发布本站内容到任何网站、书籍等各类媒体平台。如若本站内容侵犯了原著者的合法权益,可联系我们进行处理。

评论(0)