項(xiàng)目4Hive數(shù)據(jù)倉(cāng)庫(kù)

任務(wù)4.1

任務(wù)4.2

任務(wù)4.3餐飲數(shù)據(jù)統(tǒng)計(jì)分析

【任務(wù)描述】

都市生活緊張忙碌，不少上班族已經(jīng)習(xí)慣于在餐飲外賣平臺(tái)上訂餐，外賣平臺(tái)的菜品種

類豐富，提供各式風(fēng)味的美食。但是即便如此，由于個(gè)體的口味偏好及菜品質(zhì)量的差異，上

班族們常常有不知道今天午餐應(yīng)該吃什么的煩惱。

w餐飲外賣平臺(tái)，向廣大用戶提供網(wǎng)上訂餐服務(wù)，其市場(chǎng)占有量在近年不斷增加。當(dāng)用

戶在W平臺(tái)訂餐完成后，平臺(tái)會(huì)引導(dǎo)用戶對(duì)于品嘗過的菜品進(jìn)行評(píng)價(jià)打分，最高為5分，

最低為1分。

為提高用戶的購(gòu)買體驗(yàn)，平臺(tái)需要對(duì)用戶的在平臺(tái)上的打分?jǐn)?shù)據(jù)、以及平臺(tái)的相關(guān)菜品

數(shù)據(jù)進(jìn)行統(tǒng)計(jì)分析，在后續(xù)的菜品推送時(shí)能有所依據(jù)。本小節(jié)通過平臺(tái)收集的用戶評(píng)分?jǐn)?shù)據(jù),

分析外賣平臺(tái)的受歡迎度、客戶的體驗(yàn)度。

【任務(wù)分析】

本小節(jié)將從如下的分析操作，分析外賣平臺(tái)的受歡迎度、客戶的體驗(yàn)度。

（1）根據(jù)用戶評(píng)分?jǐn)?shù)據(jù)統(tǒng)計(jì)日銷用和日用戶量。

（2）統(tǒng)計(jì)同時(shí)有評(píng)分和評(píng)分內(nèi)容的記錄。

（3）分析用戶的評(píng)分分布情況。

（4）統(tǒng)計(jì)10大熱銷菜品。

（5）統(tǒng)計(jì)10大評(píng)分為5的熱銷菜品。

（6）統(tǒng)計(jì)單口評(píng)分超過2次的用戶數(shù)。

(7)找出評(píng)分次數(shù)超過兩次的用戶中，每個(gè)用戶評(píng)分最富的記錄。

【任務(wù)實(shí)施】

4.3.1數(shù)據(jù)說明

因?yàn)闃I(yè)務(wù)數(shù)據(jù)的安全原因,用戶評(píng)分?jǐn)?shù)據(jù)集的數(shù)據(jù)已做了脫敏處理，只保留部分重要屬

性，其各屬性及說明如表4?1所示。

表4-1用戶評(píng)分?jǐn)?shù)據(jù)屬性及其說明

屬性名稱屬性說明

UserID用戶ID

MeallD菜品ID

Rating評(píng)分

ReviewTime評(píng)分的時(shí)間戳

Review評(píng)價(jià)內(nèi)容

另外，在網(wǎng)站的后臺(tái)數(shù)據(jù)庫(kù)(MySQL)中保存著菜品的數(shù)據(jù)集，其數(shù)據(jù)內(nèi)容如圖4-1所

示，導(dǎo)出后形成Parquet文件。

mealnomeallDmeal_name

1BOOOHOOVBQ口權(quán)

2B000H0X79O套保雞丁

3BOOOH29TXU水煮牛肉

4BOOOH2DMMF番前茄餅

5BOOOH4YNMO球械

6BOOOHAB4NK蛋包飯

7B000HKWE3O魚香茄子

8B000HZEHL6塔尖大白菜

9BOOOI5PVD8酸溜土豆絲

10B000I5Q0ZG茄汁萌餅

圖4-1菜品數(shù)據(jù)集

在用戶評(píng)分?jǐn)?shù)據(jù)集中，保存了用戶對(duì)菜品的評(píng)分信息，很大程度上反映了用戶對(duì)菜品的

興趣度，因此這份數(shù)據(jù)將作為統(tǒng)計(jì)分析的主要數(shù)據(jù)源.

4.3.2創(chuàng)建數(shù)據(jù)表并導(dǎo)入數(shù)據(jù)

將用戶評(píng)分?jǐn)?shù)據(jù)realrating.parquet和菜品數(shù)據(jù)meal」ist.txt上傳至Linux系統(tǒng)的/opt目錄

下，啟動(dòng)Hadoop集群、MySQL服務(wù)、MelaSlore服務(wù)，打開HiveCLL在命令行窗口進(jìn)行

菜品數(shù)據(jù)表mealjist和用戶評(píng)分?jǐn)?shù)據(jù)表meal.rating的創(chuàng)建并導(dǎo)入相應(yīng)數(shù)據(jù)，如代碼4-1所

zjso

代碼4”創(chuàng)建數(shù)據(jù)表并導(dǎo)入數(shù)據(jù)

createdatabasemeal;

usemeal;

-創(chuàng)建菜單表

createtabicmcal」i$l(

idint,

Mealldstring,

mealnamestring)

rowformatdelimitedfieldstenninatedby

一導(dǎo)入數(shù)據(jù)

loaddatalocalinpath'/opt/meaLlist.txt'overuriteintotablemeal_list;

--創(chuàng)建評(píng)分表

createtablemeal_rating(

useridstring,

mealidstring,

ratingdouble,

reviewstring,

revicwtimestring)

storedasparquet;

一導(dǎo)入數(shù)據(jù)

loaddatalocalinpath'/opt/mealrating.parquet'overwriteintotablemealrating;

導(dǎo)入數(shù)據(jù)后，可使用select語句查詢前5行數(shù)據(jù)，險(xiǎn)驗(yàn)一下，查詢結(jié)果如圖4-2所示。

hive>select*frommeal_listlimit5;

OK

1B000H0OVBQ口水碼

2B00OHOX79O宮保海丁

3B000H29TXU水煮牛肉

4B00OH2DMME香煎茄餅

5B000H4YNM0五彩相取

Timetaken:0.737seconds.Fetched:5row(s)

hive>select*frommealratinglimit5;

OK

A2W0H395IHGS0TB0940HNZTVI5.0風(fēng)味獨(dú)特，真的不錯(cuò)！1496177056

A^?KHSf)VNONOHRRfia674RT7S?A有特色,也比較T生14Qfi1771fiR

A1YQ4Z5U9NIGPB09CDBTQCW5.0家常美味，推薦！1496177276

A3E5V5TSTAY3R9B09751IYQ44.0好吃1496179256

A1V50CTTDJ73ZMB09C0OLT6S5.0不得不贅1496180009

Timetaken:0.486seconds.Fetched:5row(s)

圖4-2查詢數(shù)據(jù)表前5行數(shù)據(jù)

4.3.3統(tǒng)計(jì)分析任務(wù)實(shí)現(xiàn)

根據(jù)用戶評(píng)分?jǐn)?shù)據(jù)，使用日期函數(shù)fisLunix山nc與CHSI實(shí)現(xiàn)日期格式的轉(zhuǎn)換，在通過

聚合函數(shù)count,結(jié)合分組關(guān)鍵字groupby實(shí)現(xiàn)日銷量和日用戶量的統(tǒng)計(jì)，最后使用排序關(guān)

鍵字orderby對(duì)日期進(jìn)行升序輸出，如代碼4-2所示。

代碼4-2統(tǒng)計(jì)日銷量和日用戶量

selectymd,count(1)asdaycount,count(distinctuserid)asusercount

from(select*,from_unixtimc(cas((rcview(imeasbiginl),'yyyy-MM-dd')asymdfrommeal_rating)imp

groupbyymd

orderbyymd;

部分運(yùn)行結(jié)果如圖4-3所示，其中菜品日銷量比日用戶量普遍都高，意味著存在有部分

用戶在一天內(nèi)購(gòu)買同一種菜品的現(xiàn)象。

2017-96-15491371

2017-96-16630466

2017-96-17577427

2017-96-18514393

2017-06-19560431

2017-96-20515378

2017-96-21733497

2017-96-22648446

2617-96-23669460

2017-96-24459326

2017-96-25664480

2017-96-26598427

2017-96-27575418

2017-96-281023733

2017-96-29716502

2017-96-303633

Timetaken:79.159seconds.Fetched:62row(s)

圖4-3日銷量和日用戶量部分統(tǒng)計(jì)結(jié)果

通過使用聚合函數(shù)count,結(jié)合條件篩選關(guān)鍵字where,統(tǒng)計(jì)同時(shí)有評(píng)分和評(píng)分內(nèi)容的

記錄，如代碼4-3所示。

代碼4-3查詢同時(shí)有評(píng)分和評(píng)分內(nèi)容的記錄

selectcount(*)frommealratingwherereviewisnotnullandratingisnotnull;

統(tǒng)計(jì)結(jié)果如圖4-4所示，使用聚合函數(shù)count統(tǒng)計(jì)用戶評(píng)分?jǐn)?shù)據(jù)表meaLrating的總數(shù)據(jù)

量為38383,意味著用戶評(píng)分?jǐn)?shù)據(jù)表中的所有記錄均有評(píng)分與評(píng)分內(nèi)容。

38383

Timetaken36.655seconds.Fetched^1row(s)

圖4-4查詢同時(shí)有評(píng)分和評(píng)分內(nèi)容的記錄

使用聚合函數(shù)對(duì)用戶評(píng)分?jǐn)?shù)據(jù)表分析用戶的評(píng)分分布情況，如代碼4-4所示。

代碼4-4創(chuàng)建手游被關(guān)注信息表

selectrating,coun((1),round(count(1)/38383*100,2)asusercountfrommeal_ratinggroupbyrating;

selectmax(rating)asmaxrating.min(rating)asminrating.round(avg(niting).3)asavgrating,

round(stcldev(rating),3)asstdratingfromineal_rating;

由圖4-5可知，54.77%的用戶在評(píng)分時(shí)都會(huì)打5分，其中打3分的用戶超過90%；由圖

4-6可知，用戶評(píng)分的最大值為5分，最小值為1分，平均值為4.19分，標(biāo)準(zhǔn)差為L(zhǎng)I18分，

說明了用戶評(píng)分的數(shù)值數(shù)據(jù)較為集中，結(jié)合平均值為4.19分，可以推斷，評(píng)分?jǐn)?shù)值數(shù)據(jù)較

多為4、5分，即由圖4-5所展示的情況。

1.017824.64

2.019605.11

3.0447511.66

4.0914223.82

5.02102454.77

Timetaken:30.697seconds,Fetched:5row(s)

圖4-5用戶評(píng)分分布情況1

0K

5.01.04.191.118

JTimetaken:35.019seconds.Fetched:1row(s)

圖4-6用戶評(píng)分分布情況2

使用分組關(guān)鍵字groupby對(duì)菜品ID進(jìn)行分組，結(jié)合聚合函數(shù)count統(tǒng)計(jì)記錄數(shù)，然后

使用排序關(guān)鍵字orderby降序輸出10條數(shù)據(jù)，實(shí)現(xiàn)統(tǒng)計(jì)10大熱銷菜品，如代碼4-5所示。

代碼4-5統(tǒng)計(jì)10大熱銷菜品1

selectnicalid,counl(l)asmealcounlfrommealratinggroupbymealidorderbymcalcounldesclimit10;

運(yùn)行結(jié)果如圖4-7所示，第1列數(shù)據(jù)為菜品ID,第2列數(shù)據(jù)即為銷售數(shù)據(jù)。

B00I3MPDP4467

BO0DAHSVYC460

B00I3MMN4I432

B00APEO0H4398

BOOCDBTQCW371

BO0I3MNGCG353

B0OI3MNVBW335

B00B8P3O9K325

B00I3MMTS8320

BO0CDBR1P6301

Timetaken:66.485seconds,Fetched:10row(s)

圖4-710大熱銷菜品統(tǒng)計(jì)情況1

基十代碼4-5的分析思路，使用聯(lián)合關(guān)鍵字join,連接菜品數(shù)據(jù)表meal」ist,輸出10大

熱銷菜品與其對(duì)應(yīng)菜品名稱，如代碼4-6所示。

代碼4-6統(tǒng)計(jì)10大熱銷菜品2

sclecla.mealid,a.mcalcoun(,b.mcalnumefrom(selectmcalid,coun((l)asmealcounlfrommcal_raiinggroupby

mealidorderbymealcountdes:limit10)ajoinmealjistbona.mealid=b.mealid;

運(yùn)行結(jié)果如圖4-8所示，第1列數(shù)據(jù)為菜品ID,第2列數(shù)據(jù)為銷售數(shù)據(jù)，第3列數(shù)據(jù)

為對(duì)應(yīng)的菜品名稱。

0K

B00I3MPDP4467蟹柳蔬菜沙拉

B00DAHSVYC460香菜陳皮鶴

B0OI3MMN4I432紅酒燉牛猜

B00APEG0H4398紅苴南瓜米糊

B00CDBTQCW371素魚煽苦瓜

B0OI3MNGCG353洋蔥炒雞蛋

B00I3MNVBW335懶人版紅燒肉

B0OB8P8O9K325冬瓜茶

B0OI3MNTS8320烤豬頸肉

B00CDBR1P6301金銀瓜條

Tim?taken:115.285seconds,Fetched:10row(s)

圖4-810大熱銷菜品統(tǒng)計(jì)情況2

參考代碼4-6的分析思路，實(shí)現(xiàn)統(tǒng)計(jì)10大評(píng)分為5的熱銷菜品，如代碼4-7所示，運(yùn)

行結(jié)果如圖4-9所示。

代碼4-7統(tǒng)計(jì)10大評(píng)分為5的熱銷菜品

selecta.mealid,a.mealcount,b.niealnainefrom(selectmealid,count(l)asmealcountfrommeal_ratingwhere

rating=5groupbymealidorderbymealcountdesclimit10)ajoinmealjistbona.mealid=b.mealid;

OK

BO0APE00H4289紅豆南瓜米糊

B00I3MPDP4253鬟柳蔬菜沙拉

B009FZF0N0217高湯

B006Z48TZS215手撕茄子

BO04MWZLYC193藐菜烤魚

B00B8P8O9K190冬瓜茶

BO0DAHSVYC177香菜陳皮日鳥

B00DT0YIIE174肉燕

B005544TRQ167X0音拌荷蘭豆

B00F87ZUYG167大杏仁桃麻

Timetaken:128.263seconds,Fetched:10row(s)

圖4-910大評(píng)分為5的熱銷菜品統(tǒng)計(jì)情況

為提高查詢效率，創(chuàng)建一張視圖mcal-rating-ymd,內(nèi)容為用戶評(píng)分?jǐn)?shù)據(jù)表的所有數(shù)據(jù)

與進(jìn)行了格式轉(zhuǎn)換的日期;對(duì)創(chuàng)建好的視圖使用聚合函數(shù)count,結(jié)合條件篩選關(guān)鍵字having,

實(shí)現(xiàn)統(tǒng)計(jì)單日評(píng)分超過2次的用戶數(shù)，如代碼4-8所示。

代碼4-8統(tǒng)計(jì)單日評(píng)分超過2次的用戶數(shù)

createviewmeal_raiing_ymdasselect*,from_unixiime(casi(reviewiimeasbigini),'yyyy-MM-dd)asymdfrom

meal_raling;

selectcount(distinctuserid)from(selectymd.userid,count(I)asratngcountfromnieal_rating_ymdgroupby

ymd,useridhavingratingcount>2)tnip;

運(yùn)行結(jié)果如圖4-10所示，總計(jì)2231名用戶單日評(píng)分超過兩次，結(jié)合用戶評(píng)分?jǐn)?shù)據(jù)表的

中數(shù)據(jù)量38383,單日評(píng)分超過兩次的用戶所占比例約為5.81%,數(shù)據(jù)較小，說明很少有用

戶在一天內(nèi)評(píng)分兩次。

OK

2231

Tim。taken:72.408seconds.Fetched:1row(s)

圖4-10統(tǒng)計(jì)單日評(píng)分超過2次的用戶數(shù)情況

使用聚合函數(shù)count統(tǒng)計(jì)記錄數(shù)，分析函數(shù)rank對(duì)通過over。子句劃分的分區(qū)進(jìn)行數(shù)據(jù)

排名，實(shí)現(xiàn)統(tǒng)計(jì)查詢每個(gè)用戶評(píng)分最高的記錄，如代碼4-9所示，運(yùn)行結(jié)果如圖4-10所示。

代碼4?9統(tǒng)計(jì)每個(gè)用戶評(píng)分最高的記錄

select*,coun((l)over(partitionbyuserid)asratingcount,rank()over(partitionbyuseridorderbyratingdesc)as

ratingrankfrommeal_ratinglimit20;

OK

A0705654XT5UCAYOY7THB00IC9XG9O5.0簡(jiǎn)直太費(fèi)了149549280081

A0705654XT5UCAYOY7THB00F406S2U3.0有特色，衛(wèi)生149549280082

A0705654XT5UCAYOY7THB00H7NDSPC2.0基本0K149￡08480083

A0705654XT5UCAYOY7THB06B2G2RG62.0基本0K149549280083

A0705654XT5UCAYOY7THB00IKT36S61.0還算不錯(cuò)149549280085

A0705654XT5UCAYOY7THB00F4PKH5E1.0還算不錯(cuò)149817120085

A0705654XT5UCAYOY7THB00BLCHYKU1.0一般般吧149471520085

A0705654XT5UCAYOY7THB60APE06UA1.0還算不錯(cuò)149362720085

A099898949AFP0GMFDCBB001Y5913C5.0簡(jiǎn)直太贊了149609760071

A0998989>19AFP0GMFDCBB00CeOLT6S5.0太美味了，衽烈推薦11^19817120071

A099898949AFP0GMFDCBB003YUGS6S5.0簡(jiǎn)直太費(fèi)了149506680071

A099898949AFPOGMFDCBB005749LXQ5.0太美味了，資烈推薦!149748600071

A099898949AFP0GMFDCBB00B2LCW8O5.0太美味了，強(qiáng)烈推薦！149817120071

A099898949AFPOGMFDCBB006NU7C485.0此味只應(yīng)天上有！149708320071

A099898949AFP0GMFDCBB002QS5OQ41.0還算不錯(cuò)149627040077

A1004HZ4AR10UIBO05OHSOL65.0太美味了，強(qiáng)烈推薦！149523360061

A1004HZ4AR10UIB00BG2TX9A5.6太美味了，強(qiáng)烈推薦！149734240061

A1004HZ4AR10UIB00DBT2QZY5.0太美味了，強(qiáng)烈推薦！149523360061

A1004HZ4AR10UIB00EY8MCOO5.6太美味了，強(qiáng)烈推薦！149514720061

A1004HZ4AR10UIB00ESNDHQY5.0太美味了，強(qiáng)烈推薦！149514720061

Timetaken:79.212seconds.Fetched:2。row(s)

圖4-11每個(gè)用戶評(píng)分最高的記錄統(tǒng)計(jì)情況

基于代碼4-9的分析思路，使用條件篩選關(guān)鍵字where找出評(píng)分次數(shù)超過兩次的用戶

中，每個(gè)用戶評(píng)分最高的記錄，如代碼4-10所示，部分運(yùn)行結(jié)果如圖4-12所示。

代碼4-10在評(píng)分次數(shù)超過兩次的用戶中每個(gè)用戶評(píng)分最高的記錄

select*from(select*.count；1)over(partitionbyuserid)asratingcount,rank()overfpartitionbyuserid

orderbyratingdesc)asratingrankfrommeal_rating)tmpwhereratingcount>2andratingrank=l;

AZU6MIE3PA7MB005C4FD0Q5.0此味只應(yīng)天上有！149863840051

AZV9BLVTYCRC1B00FDZ8S2O5.0太美味了，強(qiáng)烈推薦！149678880051

AZV9BLVTYCRC1B004U8LF7K5.0太美味了，強(qiáng)烈推薦！149678880051

AZV9BLVTYCRC1B0O574P75M5.0太美味了，強(qiáng)烈推薦！149471520051

AZV9BLVTYCRC1B00337ZGIS5.0筒亙太贅了149678880051

AZV9BLVTYCRC1B007427XS45.0太美味了，強(qiáng)烈推薦！149756640051

AZVLTNV02CNP7B00ATLJYL65.0簡(jiǎn)直太贊了149682400051

AZVLTNV02CNP7B00H7NDSPC5.0太美味了，強(qiáng)烈推薦！149817120051

AZVLTNV02CNP7B00I3MPDP45.0太美味了，強(qiáng)烈推薦！149523360051

AZVLTNV02CNP7B00APE1NZW5.0簡(jiǎn)直太贅了149682400051

AZWFKYXA6ZAV9B0091P6X2E5.0太美味了，強(qiáng)烈推薦！149812000061

AZWFKYXA6ZAV9B002NWNTLO5.0簡(jiǎn)直太提了149423200061

AZX26WCIS8CNEB00ICGZIKG5.0此味只應(yīng)天上有！149436960071

AZX26WCI58CNEB0OJMJOWXG5.0太美味了，弓雖烈推薦！149851680071

AZX26WCIS8CNEB00IJNKQHM5.0太美味了，強(qiáng)烈推薦！149817120071

AZX26WCIS8CNEB003RRW3BC5.0太美味了，強(qiáng)烈推薦！149817120071

AZX8DJ3X10LD4BO08ZXSUO25.0太美味了，強(qiáng)烈推薦！149466400051

AZXS6P5QWNMLCB0O1EUKHRG5.0太美味了，強(qiáng)烈推薦！149509600051

AZXS6P5QWNMLCB000W4Z5ZO5.0太美味了，強(qiáng)烈推薦！149509600051

AZXS6P5QWNMLCB002QNBRYM5.0太美味了，強(qiáng)烈推薦！149509600051

AZXS6P5QWNMLCB002UXAEV05.0太美味了，強(qiáng)烈推薦！149466400051

AZXS6P5QWNMLCB0012H0DBG5.0太美味了，強(qiáng)烈推薦！149509600051

Timetaken:74.46seconds.Fetched:21989row(s)

圖4-12在評(píng)分次數(shù)超過兩次的用戶中每個(gè)用戶評(píng)分最高的記錄

某于代碼4-10的分析思路，找出評(píng)分次數(shù)超過兩次的用戶中，每個(gè)用戶評(píng)分最高、時(shí)

間最近的一條記錄，如代碼4-11所示，部分運(yùn)行結(jié)果如圖4-13所示。

代碼4-11在評(píng)分次數(shù)超過兩次的用戶中每個(gè)用戶評(píng)分最高、時(shí)間最近的一條記錄

select?from(select*,count(1)over(partitionbyuserid)asratingcount.row_number()over(partitionby

useridorderbyratingdesc,cast(reviewtimeasbigint)desc)asratingrankfrommeal_rating)impwhere

ralingcount>2andratingrank=l;

5

AZJ6N3ZYS2CWQB00HD6RLBK太美味了，強(qiáng)烈推薦/p>

AZJDD7W9UUVG0B003NS007050此味只應(yīng)天上有/p>

AZJOKE3Y0UCBCBO0H7NDSPC50太美味了，強(qiáng)烈推薦/p>

AZJRWV5IDX6BHB0O3N1DFUU50太美味了，強(qiáng)烈推薦！149812000051

AZLIQDH1JWCXNB00252MNV?Y50太美味了，強(qiáng)烈推薦！149544160051

AZP04WRQFEYN8B00JRSBG9U56太美味了，強(qiáng)烈推薦！149678880Q61

AZQJGDWARL3RRB0O337ZGIS50太美味了，強(qiáng)烈推薦！149670240061

AZQP4EIUUNEWDBO0ETRANIO50太美味了，強(qiáng)烈推薦/p>

AZR0M5TIZZW3WB0O4X2M3N850簡(jiǎn)直太贊了149742880061

AZRRMG7IIE3H1B0OD5P4GUC50簡(jiǎn)直太贊了149872480059

AZSZQXY81ZSM3BO0D6MQ6ZM50太美味了，強(qiáng)烈推薦/p>

AZT3AX3A4O809B000UU4IX050簡(jiǎn)直太贅了1498689600155

AZU0LWSMZTIISBO05PK5KPO50太美味了，強(qiáng)烈推薦/p>

AZU6MIE3PA7MB008BQG3RE50此味只應(yīng)天上有/p>

AZV9BLVTYCRC1B0O7427XS450太美味了，強(qiáng)烈推薦/p>

AZVLTNV02CNP7B0GH7NDSPC50太美味了，強(qiáng)烈推薦/p>

AZWFKYXA6ZAV9B0O91P6X2E50太美味了，強(qiáng)烈推薦/p>

AZX26WCIS8CNEBO0JMJOWXG50太美味了，強(qiáng)烈推薦/p>

AZX8DJ3X10LD4BO08ZXSUO2太美味了，強(qiáng)烈推薦/p>

AZXS6P5QWNMLCB0012H0DBG太美味了，強(qiáng)烈推薦！1495096000

Timetaken:86.007seconds.5130row(s)

圖4-13在評(píng)分次數(shù)超過兩次的用戶中每個(gè)用戶評(píng)分最高、時(shí)間最近的一條記錄

若是想保存代碼4-11執(zhí)行后的數(shù)據(jù)，可以基于代他4-11,先創(chuàng)建一張視圖tmp,存儲(chǔ)

數(shù)據(jù)，這樣可以有效地提高查詢數(shù)據(jù)的效率；然后使用insertoverwrite命令將視圖tmp的所

有數(shù)據(jù)導(dǎo)出至Linux本地目錄/opt/userrating下，如代碼4-12所示。

代碼4-12UseCountReducer.java

createviewtmpasselect*from(select*.count(1)over(partitionbyuserid)asratingcount.

row_number()