天天看點

ODPS 下一個map / reduce 準備

大家好,又見面了,我是全棧君

阿裡接到一個電話說練習和比賽智能二選一, 真的很傷心, 練習之前積極老齡化的權利.

要總結ODPS下一個 寫map / reduce 并進行購買預測過程.

首先這裡的hadoop輸入輸出都是表的形式, 我們須要一張輸入表和一張輸出表.

輸入表為 提供的 t_alibaba_bigdata_user_brand_total_1 輸出表為自己定義的wc_out

wc_out 須要預先定義. 以下的執行個體的功能是合并使用者對商品的操作并記錄反複次數, 建立的wc_out表結構為:

create table wc_out(user_id string,brand_id string,type string,visit_datetime string,count bigint);

然後在eclipse 中進行map /recduce 程式的編寫.

ODPS 下一個map / reduce 準備
ODPS 下一個map / reduce 準備
ODPS 下一個map / reduce 準備
ODPS 下一個map / reduce 準備

将project導出為jar檔案.(略)

在ODPS中建立資源并執行

ODPS 下一個map / reduce 準備

執行完畢

ODPS 下一個map / reduce 準備

接下來就能夠設計更複雜的模型來進銀行預測

版權聲明:本文部落格原創文章。部落格,未經同意,不得轉載。

釋出者:全棧程式員棧長,轉載請注明出處:https://javaforall.cn/117653.html原文連結:https://javaforall.cn