00:00
我们开始已经分析过了,咱们现在这个需求当中啊,不需要的了。是不是因为它不涉及到任何的一个具体操作嘛,其实你在map做完这个处理之后就直接扔到哪啊。扔给奥就够了吧,但是这个地方你要注意啊,就是迈阶段,你看啊,如果它小于九的话,这个方法返回的是一个什么,是一个棱,那你这个地方。清洗完了之后,你再往里边set的时候,你是不是前面要做一个判断呀,如果说string u u是吧点。Is bank为空的话,这个ETL你直接干什么,为你看它一个规范写法,也也把我们加了这个大括号是吧,你其实你知道这个大括号其实加跟不加。
01:00
都能运行成功吧,那加就加吧,就这样,也就是说我们那个地方传过来数据,如果是没空的啊,就直接走掉就行了,不要往里面塞了,塞了也没有什么任何意义是吧?好,这是这个你要注意的一个点啊,这是我们后加的啊,这个判断一定要有的。啊,你看啊,不加这个判断的时候。你看这个地方也给你标什么,标黄了,他说什么这个参数啊,可能是那的,可能是那的,所以说你这个东西啊,就idea你不加,他idea都让你加吧,让你加的这个事情啊,所以说有时候idea这地方不好啊,你就看一看它到底是什么错,会不会影响业务逻辑,有时候像类似于这种private没写这个倒无所谓。像这种在发送啊,就是你包房的时候,你都点进去看一看,你看一看你看到底是什么原因。好,接下来我们就封装的那个抓我了,抓我装抓我七步还记得吗?
02:03
啊,不记得了,这样,呃,这个地方介绍另外一种写法,另外一种写法转换另外一种写法,你可以实现一个。To。托。画类。托尔接口。接口呢是哎。是继承是吗?应该是实现啊,我记得应该是实现实现那个。接口第二个,诶刚才为什么没有呢?就很奇怪是吧,那这个地方要实现相应的一个方法,实现的方法,你看一下一个wrong方法,那肯定是最终执行的地方嘛,而且它可以。接收的类似于这种参数的,是不是给卖方法传的参数,也就是说卖方法里面最终调的这个run方法来执行的啊,然后还有一个set,还有一个get这个方法。
03:05
那set康其实就是你在外面进行一个这个是什么private,然后这个里边赛的话,其实就等于康吧,然后这个get康复的话,就直接嘛,返回它的一个这个值就行。然后呢,我们这个run方法里面其实就写我们。封装的那几部吧,封装的那几部,那还记得吗?第一步是干什么获取。叫我对象。然后呢,封装专累吧,这放里边,然后是卖吧,关联卖。
04:09
然后呢,因为这地方我没有没有是吧,没有,所以只写的关联就没有字,那其实是map。输入输出类型啊。只有输啊对输出类型应该是输出的KV类型是吧,想写的是KV2个V类,然后还有一个什么最终输出的类型吧,输出类型。好,然后输入输出路径是吧,输入。输出入境。进,然后最后是提交任务吧,提交任务好,那我们一个人来写一下,那封装叫我。
05:12
是job.get get,它要传一个。com进去,我们要用那个get康复嘛,能用这种方式啊,你下面这个。com只是定义了一下吧,OK,那叫做对象有了,那就是接下来就拿着这个教授对象来封装相应的内容啊。叫我点set,这在这那肯定是by class这种方式是吧,因为你你放上传到集群运行的话,你肯定不能写绝对路径啊,集群当中它可能传到一个路径,它其他节点是找不到的吧,其他节点是找不到的啊,它是一个ETL driver.class然后maply。
06:00
job.set map class吧,它是一个dtl map.class map.class然后map的一个输入输出类型叫个点set map out的key key是text吧,是不是text,注意这个地方。Text不要导到包了啊哈,Lo下来是吧,不要导到包了点class。下面还有一个job.set outp value map value是吧?那这个地方是不是那。点,然后最终输出的一个类型叫么点赛T好好的吧,这个最终输出类型其实就是跟上面是一样的吧,TST下点class,然后是叫我点。
07:09
在这吧,是那点。然后接下来是输入输出路径,这个地方是不一样啊,是怎么来啊,注意是哪个包是下面的这个包点。的pass照得放进去,然后有一个有一个pass,那这个pass里边传的就是从这个地方传进来的吧,从外面传进来的200。还有一个奥的方的吧,也是立方向的吧,利方向的新的一边不是老的在奥的,然后是,然后一个pass一个pass,然后是二一。
08:16
最后提交任务是job.wait for complete吧,然后他要一个不类型给他一个是吧处,它是一个返回值。然后最终他要一个这个值是吧,这个值怎来啊,直接问号零冒号一这样返回就可以了,直接这样。那接下来就是写我们的那个什么慢方法,没写吧,程序的入口还没有是吧,PSVM,那这个是我们要知道它是要调这个run方法的,那你可以干什么,弄一个用一个这个drive类是吧,来来让它,它还有一个优。
09:11
悠久。哎,不是悠吗?是有一个什么优秀工具类,记不太清了,看一眼。在这个地方往这儿。兔儿庄儿呢是吧。他用这个方法来调的,当然你可以自己写一个什么,你用一个这个ETL drive,然后调一个run方法也一样嘛,只要让那个run方法有人调就行了,它是to装来调的,是让让,然后是我们用这个都一样,这两个因为我们这个configuration里边都用到了,自己去获取的吧。这你就获取了,那用这个他要一个拓,那其实在这个地方你还是创建了一个什么ETL。
10:06
Z了嘛,这个东西是不是就是一个托啊,因为它实现的是托尔接口啊,哎,所以它本身也是一个托尔,然后第二个它还要什么参数啊二那就是把这个参数的阿传进去,对吧,它有异常往下。啊,其实你写到这一步啊就OK了,你看它有没有返回,它返回一个int,返回一个int,那你其实把这个int可以打印到控制台是吧,你可以执行一个什么操作,让点so了,让点是不就直接打印到控制台啊。你们之前都写sot,然后把写进去是吧,Sot可以直接是一个方法调出来了,因为你想想这是其实也是一个方法对吧,它也是一个方法,那这样我们的一个整个的一个程序就。写完了吧,啊写完了,因为有入口了,其实你看其实它里边只不过用工具,有一个工具帮我们来实现这个功能了,如果说你自己就像我们刚开始说的,你自己拗一个这个类的对象,然后调这个run方法是不是也一样啊,也一样的啊啊。
我来说两句