[TOC] Hive的 TRANSFORM 關鍵字提供了在SQL中調用自寫腳本的功能 適合實現Hive中沒有的功能又不想寫UDF的情況 使用示例1：下面這句sql就是借用了weekday_mapper.py對數據進行了處理. ~~~ CREATE TABLE u_data_new ( movieid INT, rating INT, weekday INT, userid INT) ROW FORMAT DELIMITED FIELDS TERMINATED BY '\t'; ~~~ ~~~ add FILE weekday_mapper.py; ~~~ ~~~ INSERT OVERWRITE TABLE u_data_new SELECT TRANSFORM (movieid , rate, timestring,uid) USING 'python weekday_mapper.py' AS (movieid, rating, weekday,userid) FROM t_rating; ~~~ 其中weekday_mapper.py內容如下 ~~~ #!/bin/python import sys import datetime for line in sys.stdin: line = line.strip() movieid, rating, unixtime,userid = line.split('\t') weekday = datetime.datetime.fromtimestamp(float(unixtime)).isoweekday() print '\t'.join([movieid, rating, str(weekday),userid]) ~~~