Hive：map字段存儲和取用 ( str_to_map函數 )

str_to_map(字符串參數, 分隔符1, 分隔符2)

使用兩個分隔符將文本拆分為鍵值對。

分隔符1將文本分成K-V對，分隔符2分割每個K-V對。對於分隔符1默認分隔符是 ','，對於分隔符2默認分隔符是 '='。

 

例子：

1. 創建map字段

DROP TABLE IF EXISTS tmp.tmp_str_to_map;
CREATE TABLE IF NOT EXISTS tmp.tmp_str_to_map
(
ocolumn string comment '原始字段', 
rcolumn map<string,string> comment 'map字段'
);

　　

2. concat + str_to_map函數

用concat + & 取表字段拼接成map類型

insert overwrite table tmp.tmp_str_to_map
SELECT 
concat('&crowd:', m0.id,'&clicker:',m0.dui_leader,'&sen:',m0.application_type) ocolumn,
str_to_map(concat('column1:', m0.id,'&column2:',m0.dui_leader,'&column3:',m0.application_type), '&', ':') rcolumn
FROM tmp.tmp_adhoc_detail_20180927 m0
limit 1
;

　　

3. 取用map里的字段，用[""]即可

select 
rcolumn,
rcolumn["column1"] column1
from tmp.tmp_str_to_map;

 

4. 也可以直接轉換取用，而不需要存儲字段

SELECT 
  m0.id column1,
  str_to_map(concat('column1:', m0.id,'&column2:',m0.dui_leader,'&column3:',m0.application_type), '&', ':')["column1"] column1_1
from tmp.tmp_adhoc_detail_20180927 m0 
limit 1

　　

5. 結果:

rcolumn	column1
{"column1":"1","column2":"李某某","column3":"創新班"}	1