00:00
呃,好,那接下来呢,我们写一个link状语的一个案例啊,但是这里边呢,要求我们必须有这个。事件时间对吧,必须有这个事件时间,所以呢,我们就加一个这个事件时间啊,比方说就用之前的那个什么嗯,水位线啊这种方式搞一个ID来我们见啊。我在这边写一个测试啊,我就不写在这个底下了,我就写在test里面啊,在这边呢,我也搞一个这个定。对,并包,然后呢,再来一个AB包,诶这个是并class对吧,这不行,还是并包啊,我们刚才创建错了,应该是先创建一个包。并报好再来一个AB包。我们写测试。那接下来呢,我们订包里边,我去创建一个第一个啊,就是。
01:06
并一。第一啊,就随便啊,取个名字这个无所谓了,对吧,第二。简单一点,那B呢,比方说里边有一个那个ID啊private,然后呢,String。一个ID啊,第二个private,然后string类型,假如说我们给一个name,然后第三个是long类型,一个TS。时间戳啊,它必须得要有这个时间戳生产这个沃才可以啊,然后接下来呢。我把这个加一下啊。构造方法啊,Get set to string方法啊行,那在接下来呢,我们把这个拿一下,把这个干掉,然后呢,第二,然后ID,假如说呢,我们这个叫sex可以吧,对吧,一个,那这就ID关联字段,然后呢,主要关联它啊这个时间戳是用来生成我们的wordmark。
02:06
啊,生成wordmark用的好,那ABB呢,我们就写一个link。Data stream。Test。好,那这里边我们先写麦光马,把这个注释写一下,第一步获取。执行环境好,然后呢,这两个我们都用呃NC啊,我们都用NC来做这个测试,就简简单一点啊,用用NC好那读取。两个。端口数据创建流并提取时间戳生成wordmark。好,那接下来呢,我们就是join啊,要做双流转引。说完这呃,装印好之后呢,我们就可以打印对吧,打印结果啊,最后呢,第五步。
03:06
启动。启动诶。任务好,那第一个获取执行环境。Get。因为好,那因为点S边度为一,当然多边度也可以啊,因为我们这里边会做P,拜。对吧,啊会做KB,所以多变异度呢,是没有问题的啊,所以这个跟变异度没关系,那我们就都设置为一啊简单一点对吧?呃,大家来读取端口数据,就因为点。对吧哈杜102,然后呢,我们第一个用8888端口。哎,端口号不要这个双引号了啊。波端口对吧?呃,创建流并提取实验中生成wordmark,首先第一步呢,我们先把这个数据变成一个呃招并啊line.li假如说我们按照逗号分割啊,这个我快速写一下,然后得到一个file,嗯,接下来呢是return,又有一个呃叫病一。
04:16
零一对吧,零一里边呢就是fails0feels1long.pass long,然后呢,Fails。二是吧,然后呢,我们提取我ma和。那我们也不要什么乱序了,因为里边可以写一个范围嘛,所以呢,这个我们就不需要乱序了,对吧。然后这边给一个B1。好,然后继续。这里边我们就element.get ts乘以1000,假如说呢,我们乘以1000,那边呢,我们写这个,呃,写写单个值啊,就是秒数就够了,这样就好观察一点啊行,那接下来呢,这个就得到了一个抗化加V啊,得到了一个。
05:11
好,选B,好,那同理,我把它复制一份啊,改一改,呃,这个呢变成二,然后呢,呃,这个变成二。对吧,B2啊,然后B2呢,我们找一下包啊,接下来B2也要放在这个地方,对吧,这个地方也是B2。嗯,然后我看一下这丙。这个地方比好,那这个就搞定了,我们检查一下啊呃,Falses be2,嗯,它是一个name一个sex嘛,对吧,我们都用类型,最后一个呢,是时间戳啊这个端口号改一下,九九九九两个不能来自于同一个端口号,两个流对吧?呃,然后这边是B2B2B2啊都是get ts好,那这个就搞定了,我们就得到了一个STRING2接下来呢,做双流照引,双流照引的时候呢,注意啊,要替败。
06:00
击败啊,然后这边呢,我们用的是B1。Get ID对吧,去join咱们的啊,Inter join啊点inter join。然后呢,并二。也是get ID对吧,两个人ID,哎,这个地方不能这样写,应该是四二。点KBY啊,然后呢是B2GETID对吧?呃,接下来呢,给一个between。时间范围对吧,那我们就看点second,假如说给一个负五。到五对吧,Time second。到正午好,呃,那将来呢,这个地方我们正常的调用这个process,有一个这个process作为风第一第二,呃,那这个地方呢,我们就偷工减料一点啊,我就直接写一个TOP2 top2的类型呢,里边放一个B一定二,对吧,我就不写那个什么两个人联合的一个。
07:04
招聘了OK吧,就跟官方文档写的是一样的啊,这个快速敲一下,但这里面还有一个点我们需要说明一下啊,嗯,这两个东西。我注意掉这两个干什么用的呀,大家能看出来干什么用的。一个叫lower bound exclusive,一个叫up bound exclusive。那你看啊,这个负五到五它是一个范围呀,对吧,那默认的我这两个不加,它是不是左臂右臂呀,对吧,那加了。它呢是只加它啊,只加第一个是左开右臂,只加第二个是左臂右开,两个都加就是开区间。没问题吧,这个好理解吧,叫exclusive排除嘛啊就商边界包不包含的意思。
08:02
OK吗?这个应该没问题吧。就他是可以做到这些事情的啊,可以做到这些事情的,那其实你想想看啊,你们之前写的那个代码,那就这么一行对吧,然后呢,out.connect啊,你有一个T2,然后呢放left放right。对吧,放进去啊,那就得到了一个点。啊,装之后的一个流对吧,接下来呢,做一个打印啊来到这边来。点print啊做一个打印对吧,然后这边启动任务,因为点。好,那我们就是这样,就。搞定了。对吧,啊就搞定了,这个代码呢,就写完了啊,其实最核心的呢,就这就这款对吧,前面都是一些提取,该提取这个时间该提取时间的对吧,没有什么奇奇怪怪的一个地方啊,只有呃,这个地方我们是没接触过的,就这一行代码。
09:10
对吧,这样代码呢,我们并没有接触过啊好,那接下来呢,我们。
我来说两句