來自官方文檔

一、寫 python 腳本：

import sys import datetimefor line in sys.stdin:line = line.strip()userid, movieid, rating, unixtime = line.split('\t')weekday = datetime.datetime.fromtimestamp(float(unixtime)).isoweekday()print '\t'.join([userid, movieid, rating, str(weekday)])

二、添加腳本

add file /opt/datas/xxx.py

三、使用腳本

CREATE TABLE u_data_new (userid INT,movieid INT,rating INT,weekday INT) ROW FORMAT DELIMITED FIELDS TERMINATED BY '\t';add FILE weekday_mapper.py;INSERT OVERWRITE TABLE u_data_new SELECTTRANSFORM (userid, movieid, rating, unixtime) # 傳入參數USING 'python weekday_mapper.py' # 使用的腳本文件AS (userid, movieid, rating, weekday) # 輸出的字段 FROM u_data;SELECT weekday, COUNT(*) FROM u_data_new GROUP BY weekday;

轉載于:https://www.cnblogs.com/cenzhongman/p/7206340.html

總結

以上是生活随笔為你收集整理的如何使用Python脚本的全部內容，希望文章能夠幫你解決所遇到的問題。

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