00:01
好,那刚刚呢,我们就已经完成了这个,呃,阿斯卡班呃,使用阶段的这个技术内容,那接下来我们进入到这个进阶的这一部分啊,那进阶的这一部分里边呢,我们要讲的东西有以下几个,咱们可以简单看一下啊,那第一个呢,是关于我们这个,呃,这个阿斯卡班所支持的这个任务类型的一个补充,那这个呢,一会儿会详细的说明啊,那再往下呢,有一个概念叫做工条件工作流。条件工作流啊,这个呢是呃,阿兹卡班这个work flow2.0里边的一个新特性啊,那再往下呢,是咱们这个阿兹卡温的一个定时啊,一个定时配置啊,这个呢,需要简单说一下啊,然后再往下呢,是关于我们这个阿兹卡班的哎,报警一个是邮件报警,一个呢是电话报警啊好,那这是我们接下来要讲的,哎,五部分内容,那我们先从第一个开始,第一个呢,我们刚刚提到了,是关于阿兹卡班所支持的任务类型的一个补充。
01:02
啊,任务类型一个补充,那所谓的任务类型之前我们其实已经讲过了,就是这个位置,那这个type字段是不是用来标明咱们这个工作节点或者这个任务节点的任务类型的,对吧?那前面我们接触的所有案例,咱们的类型是不是都是用的可冒的类型啊,对吧?那其实阿兹卡班呢,它内置的任务类型内置的啊,其实是有两个的,一个呢,就是我们大家现在所熟悉的这个command on类型,就是执行一条商务命令,那还有一种类型呢,是Java process。啊,就是去启动一个Java进程啊,也是它支持这样的两种,哎,两种类型的这个任务啊,那其实我们大数据当中啊,大部分的任务类型呢,都可以使用这个可的去做。啊,不管是我们的have的circle。对吧,还是这个,呃,海杜的map producece啊,对吧,或者是Spark的任务,或者是弗Li的任务,我们其实都可以用哎,一个shell命令去提交,对吧?所以说我们大部分大数据的任务呢,可以都可以使用这个,可类型啊,是这样的啊,那这边呢,我们在补充一种类型,就是哎,这个所谓的Java process类型啊,那我们来看一看这个案例,我们需要做哪些工作,来我们往下看啊,那大家现在看到的这个位置的东西都是什么呢?都是我们这个,哎,Java process类型也就是这个啊,哎,它所需要配置的一些参数。
02:26
啊就就在相当于是在哪配的呢?我们可以看一下啊,你看如果我们的类型是可盲的,那我们需要给它配的参数呢?仅仅是什么?就是说哎,你这个可盲的是什么?咱是不是告诉他这些就行了呀,对吧?那你假如说我们这个类型不是command的,是Java process对吧?那我们给的的参数还能是这个吗?那就不是了啊,而是哪些呢?哎,就是我们文档当中列出来的这一些,那包括什么呢?比如说呃,XMX啊,最小的对内存啊,SMX最大的对内存啊,Class pass这个类路径啊,类路径,这个类路径呢,需要特殊说明一下啊,路径呢,其实咱们可以省略,也是省略的话,它的默认值是什么呢?指的是哎,咱们那个flow文件的当前路径,Flow文件的当前路径。
03:11
啊,那这个呢,一会儿我给会会给大家解释的啊,这个诶会有一个默认值啊,那就来继续,那加process这个呃,加入点class,这个很简单了啊,应该是什么呀,就是我们要运行的啊什么呀,那个main方法所在的全列名对吧?Main方法所在全列名好,那接下来继续,那下边的是men点二这是不是我们要传给main方法的参数啊对吧?这时候我们传参的时候呢,要注意一下啊,因为我们可以给main方法传多个参数对吧?那多个参数之间呢,是用空格去分隔的啊,用空格去分隔,那这个要注意一下。好了,那这些呢,就是我们这种,呃,Java process类型啊,需要传的参数。好,那接下来呢,我们哎做一个小案例啊,然后呢去看一看哎这个Java类型的这个任务到底如何去,哎调度啊其实相对比较简单啊啊那现在我们首先哎创建一个这个呃加va工程啊,咱们你有一个呃product啊但这边呢,我们创建一个呃没用工程或者一个加va工程其实都可以啊,咱们为了呃打包方便,我们就创建一个没用工程吧,那咱们点击new完了之后呢,我们点击诶没问,然后呢点击下一步,然后呢,这边我们诶叫做呃这个az KA dn啊咱们叫做呃阿斯卡湾啊然后呢杠Java p c ss这个呢,当然我们就随便起一个名字就可以啊,咱们主要是做一个测试啊下边呢,我们把这个JV改一下,改成com.at,诶硅谷啊完了之后呢,我们点击finish。
04:43
好,那这里边我们就不需要再引入额外的依赖了啊,我们在这边呢,就直接诶写代码来右右键,然后呢,我们新建一个class,我们就叫做com.at,诶硅谷啊,然后点我们后边的来一个这个啊,就叫做test,这个Java CSS啊,Test Java process写一个这样的一个类就可以了,来class。
05:08
呃,我们看一下啊,呃多了一个字符,咱们回撤啊,这个有了,这个有了之后呢,我们在这个类里边呢,咱们写一个闷法就行啊,写个闷发就行,然后这里边我们不需要做呃过多的逻辑了啊,我就直接打印一句话就行了啊,那打印一句话呢,就是说什么呀,就是说呃这个。This is啊这个。呃,这个Java啊,这个pro。嗯。啊,咱们分开写吧,Pro c is,呃,加va process啊,这个呢,就是我们做的一个呃,比较简单的一个小测试啊,小测试好了,这个代码写完之后呢,我们呃,给它打个包啊,咱们使用这个mannu插件打包就行了啊,我们找到这个袋,找到left circle,然后呢,我们点击拍K。
06:01
好,等待他这个打包完成。好了,那现在这个打案的包已经出现在了我们这个target的目录里边,这个呢,就是我们现在所需要用到的这个一个Java的包,那现在呢,我们给它放到桌面上啊,放在桌面上好了,那它放在这之后呢,我们接下来呢,需要去,呃,去编写一下什么东西呢,去编写一下我们的这个,诶工作流程的配置文件对吧,也就是这个flow文件对不对啊,那这个附漏文件呢,我们就不能再用之前那个了,咱们给它删掉啊,我们用这个文档当中给我们提供的这个最新的啊,咱们往下拉啊,把它拿下来。那当然了,这个工作流程呢,也相对来说比较简单,也是只有一个工作单元啊,CTRLV,然后来拿了之后呢,我们看它有什么,跟之前有什么区别啊,跟name的这边随便起,然后type,你注意观察是Java process啊,注意都是小写啊,这个不能乱写啊,这边呢,我们指明了这个最小堆和最大堆完之后呢,我们理论上还得指明什么呀,理论上我们上面是不是还得再指明一个呃类路径啊对吧,一个class pass,但是你发现文档当中这块呢,并没有去指明那个class pass,这是为什么呢?这是因为class pass它是不是有默认值啊对吧?默认值是什么呢?啊,注意注意真听啊,默认值呢指的是诶flow文件所在的节点。
07:14
呃,所在的这个路径啊,默认默认啊,默认这个class pass呢,就等于啊,Flow文件所在路径。啊,也就是附漏文件的当前路径,哎,这是什么意思呢?咱们怎么去理解这句话呢?啊,给大家简单说一下啊,就是我们一会儿呢,这个附漏文件写完之后,那我们需要将这个附漏文件和这个炸包啊,它俩打到同一个包下边。啊,达到同一个包下之后呢,我们一同将这两个文件是不是就上传到了我们的阿斯卡班里边了,对吧?啊,那当然最终那这俩文件也就那个zip包会怎么样呢?最终这个是不是需要去执行这个任务啊,对吧,这个任务执行是交给谁执行,是不是交给exut执行啊,对吧?最终这两个文件呢,诶会被诶哪啊会被诶分分,呃分配到哪呢?分配到我们其中的一个ex上边啊,那注意大家认真听,那这俩文件到达ex之后呢,那他俩的相对路径还是一样的,就是他俩在那个zipip包里边,哎,他俩的相对路径是什么?是在同一级路径下,对吧?那到了ex里边呢,仍然是同一级路径下。
08:21
啊,仍然是同一级路径下啊是这样的啊,那所以说那一会儿我把这个文件呃跟他俩进行打包,打包完之后呢,那我们这个炸包是不是就在flow文件的通前路径,那到了ex之后是不是仍然是这样的呀,对吧,仍然是这样的,那所以说这样的情况下呢,我们这个class bus呢,就可以省略不写啊就可以省略不写啊是这样的啊好,那这边呢,咱们就省略掉了,好那接下来继续往下走,下面呢,是这个闷方法啊所在的全列名,这个呢,咱们需要改一下啊,改成我们自己的这个诶main方法所在的全列名来我们右键,然后呢copy一下copy reference,然后呢把这改一下control v给它放在这,呃,那我们这呢,是不需要给它传这个参数的,因为我们这个用不到参数,那就不用传了啊,不完之后呢,那这个文件就写完了,CTRLS保存一下,那这时候呢,我们把这个文件呢,再给它拖到我们的这个,呃,这个包里啊,拖到这IP包里拖进来。
09:17
诶,替换一下,然后同同同时呢,我们需要把这个炸包是不是也给它放到诶这个路径下呀,同一个路径下啊,那这时候我们这个zip包就准备好了啊好,那完了之后呢,我们再重新创建一个product去做一个测试啊那这边呢,我们叫做呃,Five five,这是咱们五一个对吧?那那这个也是啊这个啊应该是fifth对吧?啊fifth fight啊,Fith啊OK,之后呢,我们点击create create之后呢,我们点击upload,选择文件,呃,找到我们那个first.z然后点击upload,然后这时候我们点击ex,你看这是不是只有一个工作单元呀,对吧,这时候我们点击执行啊,点击continue,好,大家看到了这个是不是直接就变绿了呀,对吧,那变绿了就说明我们这个任务呢,应该是执行成功了,那现在我们点击这个job list完之后呢,点击这个log,咱们来看一看这里边有没有什么期望的输出,你看是不是输出了this ISA Java process,对吧。
10:14
那看到这个结果就说明我们这个任务执行成功了,好,那这个呢,就是我们,呃,这个Java process这个任务类型啊的全部内容,好。
我来说两句