Hive扩展功能(四)--HiveServer2服务

Posted

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了Hive扩展功能(四)--HiveServer2服务相关的知识，希望对你有一定的参考价值。

参考技术A </br>

</br>

从 Hive 2.0 版本开始，为 HiveServer2 提供了一个简单的 WEBUI 界面，界面中可以直观的看到当前链接的会话、历史日志、配置参数以及度量信息, 所以配置一个 HiveServer2 的UI端口

</br>
</br>
</br>

Hive常用函数

Hive常用函数

  • 功能

    • 用Hive计算的话,主要是通过Hive将SQL转换为MR/Spark/Tez程序,很少用,有很多的替代品来实现(Presto、Impala、SparkSQL)

      思考🤔:替代软件是怎么知道Hive中有哪些表,那些库?
Hive中要启动2个进程,metastore和hiveserver2

      思考🤔:为什么要这两个进程,只启动HiveServer2可以吗?
可以,但其他软件需要通过metastore获取元数据,metastore的功能就是共享元数据,对外提供所有元数据请求
    • 将HDFS文件映射成表(重要),构建数据仓库

  • 场景:利用Hive构建数仓

  • 核心: SQL+函数

    • ​ sql语法 + hive中特殊的语法:sort by/ lateral view/ distribute by/ partition by/ clustered by

      • 查询、分组、排序、过滤

        # SQL的基本语法
1 select 2 from 3 where 4 group by 5 having 6 order by 7 limit

    • ​ 函数: 条件、开窗函数、特殊函数

    • 字符串

    函数解释语法举例
    substring字符串截取substring(字符串,开始位置,[长度])select substr(‘abcde’,3)
    cde
    select substr(‘abcde’,-1)
    e
    select substr(‘abcde’,3,2)
    cd
    split分割字符串split(string str, string 分隔符)select split(‘abtcdtef’,‘t’)
    [“ab”,“cd”,“ef”]
    length长度length(string A)select length(‘abcedfg’)
    7
    regex_replace正则替换regex_replace(将strA中,符合strB的,替换成strC)select regexp_replace(‘foobar’, ‘oo|ar’, ‘’)
    fb
    regex_extract正则解析regexp_extract(将string 字符串, s按string 正则拆分, 返回int 指定下标字符0开始)select regexp_extract(‘foothebar’, ‘foo(.?)(bar)’, 1)
    the
    select regexp_extract(‘foothebar’, 'foo(.    ?)(bar)’, 2)
    bar
    select regexp_extract(‘foothebar’, ‘foo(.*?)(bar)’, 0)
    foo
    Trim去空格trim(string A)select trim(’ abc ')
    abc
    Concat连接concat(拼接string A, 和string B…)select concat(‘abc’,'def’,'gh’)
    abcdefgh
    Concat_ws带分隔符连接concat_ws(string 分隔符, string A, string B…)select concat_ws(’,!,‘abc’,‘def’,‘gh’)
    abc!def!gh
    Instr查找instr(在string str中, string substr首次出现的位置)select instr(‘abcdf’,‘df’)
    4

    • 日期:

    函数解释语法举例
    date_add日期增加date_add(string startdate, int days)
    返回开始日期startdate增加days天后的日期    		select date_add(‘2012-12-08’,10)
    2012-12-18
    select date_add(‘2012-12-08’,-5)
    2012-12-03
    date_sub日期减少date_sub (string startdate, int days)
    返回开始日期startdate减少days天后的日期    		select date_sub(‘2012-12-08’,5)
    2012-12-03
    datediff日期比较datediff(string enddate, string startdate)
    前面结束日期减去后面的开始日期的天数    		select datediff(‘2012-12-08’,‘2012-05-09’)
    213
    unix_timestmap指定格式日期转UNIX时间戳unix_timestamp(string date, [string pattern])
    返回值: bigint
    转换pattern格式的日期到UNIX时间戳,默认为"yyyy-MM-dd HH:mm:ss",如果转化失败，则返回0    		select unix_timestamp(‘20111207 13:01:03’,‘yyyyMMdd HH:mm:ss’)
    1323234063
    from_unixtimeUNIX时间戳转日期from_unixtime(bigint unixtime[, string format])
    返回值: string
    		select from_unixtime(1323308943,‘yyyyMMdd’)
    20111208
    year日期转年year(string date)select year(‘2011-12-08 10:03:01’)
    2011
    month日期转月month (string date)select month(‘2011-12-08 10:03:01’)
    12
    weekofyear日期转周weekofyear (string date)select weekofyear(‘2011-12-08 10:03:01’)
    49
    day日期转天day (string date)select day(‘2011-12-08 10:03:01’)
    8
    hour日期转小时hour (string date)select hour(‘2011-12-08 10:03:01’)
    10
    Minute日期转分钟minute (string date)select minute(‘2011-12-08 10:03:01’)
    3

    • 聚合:

    函数解释语法举例
    sum总和统计sum(col), sum(DISTINCT col)select sum(t) from lxw_dual
    100
    select sum(distinct t) from lxw_dual
    70
    max最大值统计max(col)
    返回最大值    		select max(t) from lxw_dual
    120
    min最小值统计min(col)
    返回最小值    		select min(t) from lxw_dual
    20
    count数量统计count(*)
    统计检索出的行的个数，包括NULL值的行
    count(expr)
    返回指定字段的非空值的个数；
    count(DISTINCT expr[, expr.])
    返回指定字段的不同的非空值的个数    		select count(*)
    20
    select count(distinct t)
    10
    avg平均值统计avg(col), avg(DISTINCT col)select avg(t) from lxw_dual
    50
    select avg (distinct t) from lxw_dual
    30
    ceil/ceiling向上取整ceil(double a)
    返回值:bigint    		select ceiling(3.1415926)
    4
    select ceiling(46)
    46
    floor向下取整floor(double a)
    返回值:bigint    		select floor(3.1415926)
    3
    select floor(25)
    25
    round取整round(double a,[int])
    返回:double
    类型的整数值部分,加上int可保留小数
    select round(3.1415926)
    3
    select round(3.1415926,4)
    3.1415

    • 条件:

    函数解释语法举例
    ifif(如果)if(A,B,C)
    如果A为true,返回B,否则返回C    		select if(1=2,100,200)
    200
    select if(1<2,100,200)
    100
    coalesce非空查找COALESCE(T v1, T v2, …)
    返回参数中第一个非空值    		select COALESCE(null,‘100’,'50′)
    100
    case条件判断CASE a WHEN b THEN c [WHEN d THEN e]* [ELSE f] END
    如果a等于b，那么返回c；如果a等于d，那么返回e；否则返回f    		Select case 100 when 50 then ‘tom’ when 100 then ‘mary’ else ‘tim’ end
    mary
    case条件判断CASE WHEN a THEN b [WHEN c THEN d]* [ELSE e] END
    如果a为TRUE,则返回b；如果c为TRUE，则返回d；否则返回e    		select case when 1=1 then ‘tom’ when 2=2 then ‘mary’ else ‘tim’ end
    tom

    开窗函数语法: 函数() OVER(PARTITION BY xxx ORDER BY xxx)

    • 聚合开窗:

    函数解释语法举例
    sum总和统计sum(col), sum(DISTINCT col)select sum(t) from lxw_dual
    100
    select sum(distinct t) from lxw_dual
    70
    max最大值统计max(col)
    返回最大值    		select max(t) from lxw_dual
    120
    min最小值统计min(col)
    返回最小值    		select min(t) from lxw_dual
    20
    count数量统计count(*)
    统计检索出的行的个数，包括NULL值的行
    count(expr)
    返回指定字段的非空值的个数；
    count(DISTINCT expr[, expr.])
    返回指定字段的不同的非空值的个数    		select count(*)
    20
    select count(distinct t)
    10
    avg平均值统计avg(col), avg(DISTINCT col)select avg(t) from lxw_dual
    50
    select avg (distinct t) from lxw_dual
    30

    • 分析开窗:

    函数解释语法举例
    first_value取分组内排序后，截止到当前行，第一个值FIRST_VALUE(url) over (partition by cookieid order by createtime desc)
    last_value取分组内排序后，截止到当前行，最后一个值LAST_VALUE(url) over (partition by cookieid order by createtime) as last1
    lag统计窗口内往上第n行值LAG(col,n,[x])
    col向上取第n行,如果为null返回x,不指定则返回null
    lead统计窗口内往下第n行值LEAD(col,n,[x])
    col向下取第n行,如果为null返回x,不指定则返回null

    • 排序开窗:

    函数解释语法举例
    rank排名序号可重复但不连续rank(col) over(partition by)
    dense_rank排名序号可重复且连续dense_rank(col) over(partition by)
    row_number排名序号不重复且连续，直接返回行号row_number(col) over(partition by)
    ntile将排序后的分区内数据分组，产生组序号ntile(x) over(partition by)

    • 特殊函数:

    函数解释语法举例
    explode行拆列explode(可迭代数据)
    		select explode(array(1,2,3))
    1
    2
    3
    collect_list列转行(有序,不去重)collect_list(col)[int下标]selectusername, collect_list(video_name) from t_visit_video group by username
    collect_set列转行(无序,去重)collect_set(col)[int下标]
    json_tuplejson解析json_tuple(jsonStr, k1, k2, …)
    参数为一组键k1，k2，。。。。。和json字符串，返回值的元组
    get_json_objectjson解析get_json_object(string json_string, string path)
    解析json的字符串json_string,返回path指定的内容。如果输入的json字符串无效，那么返回NULL    		select get_json_object(’“store”:“fruit”:[“weight”:8,“type”:“apple”,“weight”:9,“type”:“pear”],“bicycle”:“price”:19.95,“color”:“red”,“email”:“amy@only_for_json_udf_test.net”,“owner”:“amy”’,’$.owner’)
    Amy
    parse_urlURL解析parse_url(string ‘URL’, string partToExtract [, string keyToExtract])
    返回URL中指定的部分。partToExtract的有效值为：HOST, PATH, QUERY, REF, PROTOCOL, AUTHORITY, FILE, and USERINFO    		select parse_url(‘http://facebook.com/path1/p.php?k1=v1&k2=v2#Ref1’, ‘HOST’)
    facebook.com
    select parse_url(‘http://facebook.com/path1/p.php?k1=v1&k2=v2#Ref1’, ‘QUERY’, ‘k1’)
    v1
    cast类型转换cast(A as )
    将A转换成指定type类型    		select cast(1 as bigint)
    1

以上是关于Hive扩展功能(四)--HiveServer2服务的主要内容，如果未能解决你的问题，请参考以下文章

连接hiveserver2-Hive用户配置

HiveServer2 在 hdfs /tmp/hive/hive 中生成很多目录

Hive 通过 Jdbc 连接 HiveServer2

Hive 通过 Jdbc 连接 HiveServer2

Hive JDBC 连接hiveserver2

Hive常用函数