00:00
好,接下来呢,我们再写第三个类啊,Driver类哈,应该是第四个了哈,Driver,呃,Flow driver。哎,Driver是最好写的,它类似于这种八股文这种方式啊,固定的这个写法套路啊,没有方法,那么先再写一遍啊,后面呢,我就不带大家去写了哈,那第一步呢,叫获取job对象获取job。OK,那第二步呢叫设置架包,好第三步关联map和reduceion对吧,好第四步设置map mapt样啊map输出的K。和Y6K和Y流对吧,类型,再来第五项呢,是设置最终输出的T和value流类型,设置最终数据输出的T。
01:16
和外流类型,OK,那接下来看一下第六项。第六项呢,是设置数据的输入路径和输入路径和输出数据,OK,那第七项呢,是提交job,哎这么几项啊,比较好记哈,那行,那下面我们来写一下这个获取job吧,那获取job首先我们是new一个conviction,好玩。好,嗯,照吧,别导书包了啊,第二。Get,将这个。com传进来,点YOK,那这个呢,是stop。
02:00
抛下异常行,那第一步搞定,那第二步呢是设置架包,那就用这个z.set。这带class,那将它穿进来。点class搞定,那再往下呢,是关联map和reduce,那就是job.set map class。那传谁呢?哎,传我们刚才写的。map.class OK,再来一个job.set reducer class,那将这个flow reducer.class关联进来,哎,好,第三步搞定,那下一步呢,看一下第四步设置map输出的key value类型,那我map输出是什么类型?还记得吗?Map输出是手机号test。然后呢,Y6呢,是对应的这个floor b对吧,Floor b,那我job.set map output key啊这也说了啊key,呃,Key的是test,哎,这个包非常。
03:09
容易出错,哎,选他啊选他。哎呀,选错了,嗯,你看选错了吧,呃,Test选这个它第二了,我看上面有没有倒啊,好包没问题啊啊,一定要注意啊这块,然后job there set map output。Value加class,那value呢,我们是flow。D点吧,搞定,那再往下job.set哎,这回直接set out put。Key key class,那这里面是test.class再来job.set。嗯,Output key output value plus啊,然后这里面呢,是这个b.plus。是吧,哎,那下面是设置最终啊,这个数据的输入路径和输入路径那file。
04:06
Input format给导出包了,导这个MAP6的包了,那它第2SET pass,那首先第一个参数呢,就是这个job,第二参数呢,你有一个pass。好,Pass,一会再给它输入路径啊,那再来fair outp post form,第2SET out pass,哎,把job传起来,然后另一个pass。好给过来,那我把输入路径和输入路径啊给上我的输入路径在。拿来哈。在这个input目录下有一个input flow,看看啊,这呢input flow对吧?哎,这呢是这个手机号对应的这个数据啊。那把它拿过来。
05:00
输入路径对吧,哎,给过来,那么输出路径呢,我们仍然也输出到这个D盘,我输出到hi do。下面有一个output。你了是。我给放一个OUT3。好,把三给过来。那这个输入路径,输入路径搞定,那下面再来一个job.wait for complication打一个注啊,那你啊这个处有的同学这个不理解这个含义,那你就把这个先传一个处,然后再传一个false,哎,传一个处呢,你打印到控制台的日志信息和打印一个啊用一个false再打印到控制台,你看这两个结果啊,差哪啊,其实呢,这个处里面打印的这个日志信息更多一些,更方便你去了解这个系统的运行情况啊,点包。2system.s啊,然后result问号零括号一。
06:01
Ctrl alt加L。我这个应该是。退出CL加LOK,然后呢这呢抛一层al加回车跑一程行,那整个这个驱动代码啊,我们也已经写完了,嗯。
我来说两句