第七色在线视频,2021少妇久久久久久久久久,亚洲欧洲精品成人久久av18,亚洲国产精品特色大片观看完整版,孙宇晨将参加特朗普的晚宴

為了賬號(hào)安全,請(qǐng)及時(shí)綁定郵箱和手機(jī)立即綁定

CDH+Kylin三部曲之三:Kylin官方demo

標(biāo)簽:
大數(shù)據(jù)

欢迎访问我的GitHub

内容:所有原创文章分类汇总及配套源码,涉及Java、Docker、Kubernetes、DevOPS等;

本文是《CDH+Kylin三部曲》系列的终篇,先简单回顾前面的内容:

  1. 《CDH+Kylin三部曲之一:准备工作》:准备好机器、脚本、安装包;
  2. 《CDH+Kylin三部曲之二:部署和设置》:完成CDH和Kylin部署,并在管理页面做好相关的设置;

现在Hadoop、Kylin都就绪了,接下来实践Kylin的官方demo;

Yarn参数设置

Yarn的内存参数设置之后一定要重启Yarn使之生效,否则Kylin提交的任务是会由于资源限制而无法执行;

关于Kylin官方demo

  1. 下图是官方demo的脚本的一部分(create_sample_tables.sql),基于HDFS数据创建Hive表:
    在这里插入图片描述
  2. 通过脚本可见KYLIN_SALES为事实表,其他是维度表,并且KYLIN_ACCOUNT和KYLIN_COUNTRY存在关联,因此维度模型符合Snowflake Schema;

导入样例数据

  1. SSH登录CDH服务器
  2. 切换到hdfs账号:su - hdfs
  3. 执行导入命令:${KYLIN_HOME}/bin/sample.sh
  4. 导入成功,控制台输出如下:
    在这里插入图片描述

检查数据

  1. 检查数据,执行beeline进入会话模式(hive官方推荐用beeline取代Hive CLI):
    在这里插入图片描述
  2. 在beeline会话模式输入链接URL:!connect jdbc:hive2://localhost:10000,按照提示输入账号hdfs,密码直接回车:
    在这里插入图片描述
  3. 用命令show tables查看当前的hive表,已建好:
    在这里插入图片描述
  4. 查出订单的最早和最晚时间,后面构建Cube的时候会用到,执行SQL:select min(PART_DT), max(PART_DT) from kylin_sales; ,可见最早2012-01-01,最晚2014-01-01,整个查询耗时18.87秒
    在这里插入图片描述

构建Cube:

数据准备完成,可以构建Kylin Cube了:

  1. 登录Kylin网页:http://192.168.50.134:7070/kylin
  2. 加载Meta数据,如下图:
    在这里插入图片描述
  3. 如下图红框所示,数据加载成功:
    在这里插入图片描述
  4. 在Model页面可以看到事实表和维度表,如下图的操作可以创建一个MapReduce任务,计算维度表KYLIN_ACCOUNT每个列的基数(Cardinality):
    在这里插入图片描述
  5. 去Yarn页面(CDH服务器的8088端口),如下图,可见有个MapReduce类型的任务正在执行中:
    在这里插入图片描述
  6. 上述任务很快就能完成(10多秒),此时刷新Kylin页面,可见KYLIN_ACCOUNT表的Cardinality数据已经计算完成了(hive查询得到ACCOUNT_ID数量是10000,但下图的Cardinality值为10420,Kylin对Cardinality的计算采用的是HyperLogLog的近似算法,与精确值有误差,其他四个字段的Cardinality与Hive查询结果一致):
    在这里插入图片描述
  7. 接下来开始构建Cube:
    在这里插入图片描述
  8. 日期范围,刚才Hive查询结果是2012-01-012014-01-01,注意截止日期要超过2014-01-01:
    在这里插入图片描述
  9. 在Monitor页面可见进度:
    在这里插入图片描述
  10. 去Yarn页面(CDH服务器的8088端口),可以看到对应的任务和资源使用情况:
    在这里插入图片描述
  11. build完成后,会出现ready图标:
    在这里插入图片描述

查询

  1. 先尝试查询交易的最早和最晚时间,这个查询在Hive上执行的耗时是18.87秒,如下图,结果一致,耗时0.14秒
    在这里插入图片描述
  2. 下面这个SQL是Kylin官方示例用来对比响应时间的,对订单按日期聚合,再按日期排序,然后接下来分别用Kylin和Hive查询:
select part_dt, sum(price) as total_sold, count(distinct seller_id) as sellers from kylin_sales group by part_dt order by part_dt;
  1. Kylin查询耗时0.13秒
    在这里插入图片描述
  2. Hive查询,结果相同,耗时40.196秒
    在这里插入图片描述
  3. 最后来看下资源使用情况,Cube构建过程中,18G内存被使用:
    在这里插入图片描述
    至此,CDH+Kylin从部署到体验就已完成,《CDH+Kylin三部曲》系列也结束了,如果您正在学习Kylin,希望本文能够给您一些参考。
點(diǎn)擊查看更多內(nèi)容
TA 點(diǎn)贊

若覺(jué)得本文不錯(cuò),就分享一下吧!

評(píng)論

作者其他優(yōu)質(zhì)文章

正在加載中
  • 推薦
  • 評(píng)論
  • 收藏
  • 共同學(xué)習(xí),寫(xiě)下你的評(píng)論
感謝您的支持,我會(huì)繼續(xù)努力的~
掃碼打賞,你說(shuō)多少就多少
贊賞金額會(huì)直接到老師賬戶(hù)
支付方式
打開(kāi)微信掃一掃,即可進(jìn)行掃碼打賞哦
今天注冊(cè)有機(jī)會(huì)得

100積分直接送

付費(fèi)專(zhuān)欄免費(fèi)學(xué)

大額優(yōu)惠券免費(fèi)領(lǐng)

立即參與 放棄機(jī)會(huì)
微信客服

購(gòu)課補(bǔ)貼
聯(lián)系客服咨詢(xún)優(yōu)惠詳情

幫助反饋 APP下載

慕課網(wǎng)APP
您的移動(dòng)學(xué)習(xí)伙伴

公眾號(hào)

掃描二維碼
關(guān)注慕課網(wǎng)微信公眾號(hào)

舉報(bào)

0/150
提交
取消