ODPs next map / reduce preparation

Hello everyone , I meet you again , I'm the king of the whole stack

Ali received a phone call saying that practice and competition are two choices , It's really sad , Exercise the right to active aging before .

To sum up ODPS next Write map / reduce And the purchase forecasting process .

First of all hadoop The input and output are in the form of tables , We need an input table and an output table .

Input table is Provided t_alibaba_bigdata_user_brand_total_1 The output table is defined for yourself wc_out

wc_out It needs to be predefined . The function of the following example is to merge the user's operations on goods and record the number of iterations , Created wc_out The structure of the table is :

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

And then in eclipse In the middle of map /recduce Programming .

take project Export to jar file .( A little )

stay ODPS Create resources in and execute

completion of enforcement

Then we can design more complex models to predict the bank

Copyright notice ： This article is an original blog article . Blog , Without consent , Shall not be reproduced .

Publisher ： Full stack programmer stack length , Reprint please indicate the source ：https://javaforall.cn/117653.html Link to the original text ：https://javaforall.cn