00:00
好,那接下来呢,我们做一个测试来运行当前我们的程序。这边我们第一次运行它要经过整个的一个编译啊,所以我们可以稍微等一会儿。由于我们用的是初始化的方案啊,那么等会儿呢,我们将会看到1001那条数据啊,稍等一下,好,那我们来看一下当前这条数据,这条数据呢,其实就刚才我们说的。1001张三mail这条数据,因为刚刚我们看到了初始化这种方式呢。它是先做一次当前表格的一个快照,然后切到B的最新位置,同时我们也可以看到,此时这个文件呢,要读的是199这个文件,914这个位置。对不对,同时我们可以看到它之后呢,第二次连接到这个位置。好,此时呢,我们做一些增删改,我们看一下啊,做一个对比,首先我们新增一条数据新增。
01:07
1002叫零四。然后呢,听见没有。保存该数据,接下来我们可以看到,诶,第二条数据已经看到了,在这个当中呢,确实1002:4飞秒数据啊,它也是一个after,同时我们可以看到它的一个操作类型,呃,这个当中呢,一个op啊,包括刚才有一个。啊,这个呢,是read读取过来的一个数据,对吧,那么此时呢,它是一个create新增的数据,啊,这个新增数据,那接下来我们看一下这个修改,比方说我们李四呢,修改了一个姓名叫A4。好,那保存当前这个数据,然后我们看一下它的一个变化,此时又多了一条数据,那么我们看一下有什么不同,此时它是一个。
02:00
更新的数据,所以它的一个操作呢叫U。U也就意味着update CD是不是U好,那在这个当中呢,同时还有不同的点,大家注意一下,它当中呢,有这个before数据,也有这个after数据,也就是说这个这条数据呢,是一个更新数据,所以它保留了更新前和更新后两个点,而对于我们之前的那种数据,无论是查询的还是说新增的数据也好,它只有之后的。只有after数据,那是因为我们在这个过程当中。在插入数据的时候,前面是没有数据的,所以它并没有before对吧?好,那大家其实能够想象到,那如果我要去删除一条数据。会是什么现象呢?对吧,那是不是应该只有before数据,而没有after的数据?对不对,好,那我们继续看一下第四条数据,我把刚才102这条数据给它删掉。
03:01
删数据我们刷新一下,保存好,此时呢,又多了一条数据,我们看一下是不是我们想的这种,在这个当中呢,确实只有我们的before数据,而没有阿的数据啊,而且我们可以看到它的一个操作类型叫D。诶,C rud成齐了,这是第一次基于查询的方式,对吧,这是create,然后这个地方呢,U update c rud啊好,这是我们所看到这样的一个现象。也就是说我们可以通过弗CC直接用流的方式监控到买四个当中数据的一个变化啊。那么接下来有一个问题,刚才我们看到他说初始化模式在第一次启动的时候会。读取我们。每次格当中现有的数据,也就是做一个快照,那是不是说我此时把任务关掉,我重启,大家这个时候觉得。此时,这条数据还会不会出现呢?
04:04
啊,可以思考一下对不对啊,那我们来启动,大家觉得这个会还是不会呢。啊,想一想这个问题,我们来看结果啊。哎,发现我们刚才表当中剩余的1001张三这条数据怎么样又打印了一次,哎,那是不是注释写错了,说第一次才做快照,那这个每一次都做快照啊,其实并不是,大家要知道在生长环境当中,我们是需要给当年这个任务开启checkpoint。啊,那因为当前我每次重启它都是一次新的,都相当于第一次重启,那如果我们保存了checkpoint,或者说做了point,我们从checkpoint或者c point去恢复数据的时候。那么。就不是第一次启动当前的任务了啊,所以接下来呢,我们再给大家测一下,从checkpoint和cpoint当中去恢复数据,这种情况看能不能做到刚才我们所说的第一次启动的时候会读取这个历史数据,而往后不会了,还我,我们同时还希望它具备断点续传的功能,是不是?也就是说我们任务挂掉了,此时我买赛当中又写了五条数据,那重启之后我们应该把这五条数据消费过来,不应该消费老的,也不能只消费最新的,这个才符合我们生长环境当中的要求,对不对?好,接下来呢,我们就对它做一个测试。
我来说两句