005.hive列轉行 （collect_all()/collect_list() 不去重）

collect_list()   hive 0.13

collect_all()    hive 0.12

https://cwiki.apache.org/confluence/display/Hive/LanguageManual+UDF#LanguageManualUDF-CollectionFunctions

1、問題

hive如何將

a       b1
a       b2
a       b2
c       d1
c       d1
d       d2

變爲：

a       ["b1","b2","b2"]
c       ["d1","d1"]
d       ["d2"]

2、數據

test.txt   （空格分隔）

a       b1
a       b2
a       b2
c       d1
c       d1
d       d2

3、答案

1.建表

drop table tmp_jzl_20151027_test;
create table tmp_jzl_20151027_test
(
  col1 string,
  col2 string
)
row format delimited 
  fields terminated by ' '
stored as textfile;

load data local inpath '/home/jiangzl/shell/test.txt' into table tmp_jzl_20151027_test;

2.處理

hive> 
    > select col1, collect_all(col2))
    > from tmp_jzl_20151027_test  
    > group by col1; 

a       ["b1","b2","b2"]
c       ["d1","d1"]
d       ["d2"]

4、關於咱們

本文author：數據的開拓者成員之一 江中煉

QQ羣：248087140 

座右銘： 

你在你擅長的領域牛逼， 

並帶着一羣小白變牛逼，

別人會發自心裏的去尊重你的。 

--可點擊加入咱們