前言

傳統關系型數據庫中，無論是Oracle(11g之后)還是SQLserver(2005之后)，都自帶了Pivot函數實現行轉列功能，本文主要講述在Hive中實現行轉列的兩種方式。

傳統數據庫方式

這種方式是借鑒在Oracle或者SQLserver在支持Pivot函數之前實現行轉列的方式，實際上語法沒有什么變化，只是換成了Hive。

with testtable(select 1 id,'k1' key,123 value union allselect 1,'k2' key,124 value union allselect 2,'k1',234 value )select id, max(case when key='k1' then value else null end) k1, max(case when key='k2' then value else null end) k2 from testtable group by id

Map方式

這種方式的思路是把需要轉列的字段及其值字段拼接成一個Hive上的key-value的map數據，具體Sql如下：

with testtable(select 1 id,'k1' key,123 value union allselect 1,'k2' key,124 value union allselect 2,'k1',234 value )select id,kv['k1'],kv['k2'] from (select id,str_to_map(concat_ws(',', collect_set(concat(key, '-', value))),',','-') kv from testtable group by id)t

總結

兩種方式都可以實現行轉列的功能，傳統的方式易于理解，但在key的取值比較多的時候，寫起來會相當繁瑣，map的方式相對要簡便一些。但map的方式所有的數據都collect到一起了，對內存的要求會高一些，而傳統的方式通過聚合函數直接reduce，可以邊運行邊求值。

點贊和轉發是最大的支持～

總結

以上是生活随笔為你收集整理的mysql行转列函数_一个小知识点-Hive行转列实现Pivot的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。