Kylin系列8- Kylin与BI工具集成

2022-01-24 本文已影响0人只是甲

概述：

可以与 Kylin 结合使用的可视化工具很多，例如：
ODBC：与 Tableau、Excel、PowerBI 等工具集成
JDBC：与 Saiku、BIRT 等 Java 工具集成
RestAPI：与 JavaScript、Web 网页集成

Kylin 开发团队还贡献了 Zepplin 的插件，也可以使用 Zepplin 来访问 Kylin 服务。

一. JDBC

1.1 新建项目并导入依赖

<dependency>
      <groupId>org.apache.kylin</groupId>
      <artifactId>kylin-jdbc</artifactId>
      <version>3.1.2</version>
    </dependency>

1.2 Java代码

package com.bigdata.study.kylin;

import java.sql.*;

public class kylin_jdbc {
    public static void main(String[] args) throws Exception {
        //Kylin_JDBC 驱动
        String KYLIN_DRIVER = "org.apache.kylin.jdbc.Driver";

        //Kylin_URL
        String KYLIN_URL = "jdbc:kylin://hp3:7070/First_Project";

        //Kylin 的用户名
        String KYLIN_USER = "ADMIN";

        //Kylin 的密码
        String KYLIN_PASSWD = "KYLIN";

        //添加驱动信息
        Class.forName(KYLIN_DRIVER);

        //获取连接
        Connection connection = DriverManager.getConnection(KYLIN_URL, KYLIN_USER, KYLIN_PASSWD);

        //预编译 SQL
        PreparedStatement ps = connection.prepareStatement("select dname,sum(sal) from emp e join dept d on e.deptno = d.deptno group by dname");

        //执行查询
        ResultSet resultSet = ps.executeQuery();

        //遍历打印
        while (resultSet.next()) {
            System.out.println(resultSet.getString(1)+":"+resultSet.getDouble (2));
        }
    }


}

1.3 测试记录

image.png

二. Zepplin

2.1 Zepplin 下载

cd /home/kylin
wget https://downloads.apache.org/zeppelin/zeppelin-0.10.0/zeppelin-0.10.0-bin-all.tgz

这个下载是真的慢

image.png

2.2 Zepplin安装和启动

2.2.1 解压文件

解压到安装目录

tar -xvf zeppelin-0.10.0-bin-all.tgz
mv zeppelin-0.10.0-bin-all/ zeppelin
cd /home/kylin/zeppelin

2.2.2 修改配置文件

修改配置文件，指定IP和端口。

cd /home/kylin/zeppelin/conf
cp zeppelin-env.sh.template zeppelin-env.sh
cp zeppelin-site.xml.template zeppelin-site.xml

vi zeppelin-env.sh

export JAVA_HOME=/usr/java/jdk1.8.0_181

vi zeppelin-site.xml

<property>
  <name>zeppelin.server.addr</name>
  <value>10.31.1.125</value>
  <description>Server binding address</description>
</property>

<property>
  <name>zeppelin.server.port</name>
  <value>6060</value>
  <description>Server port.</description>
</property>

最开始我给了一个9090端口，通过netstat -lntp 看到端口已被占用，导致web地址访问不到，后修改为6060