尚硅谷基于腾讯云EMR搭建离线数据仓库（2023版）/视频/031-腾讯云EMR-离线数仓-FlinkCDC简单代码本地测试.mp4原创

好，那接下来呢，我们就去做一个测试，因为我们是监控的所有的数据表，对吧，而且呢是只读最新的数据，所以我们在启动完这个之后呢，要注意一定要去造一些数据，对吧？比如说这边呢，我再加一点东西，加一些前缀，这样我们看更清楚一点，好来我们启动。先把它提起来，提起来之后呢，我们再去造一些数据啊。这个我们稍微多等待一会儿。好，那他打印了一条日志，呃，我不知道有多少同学还记得之前我们是不是分别做了增。改善三个操作，那个日志文件大小就是1018，诶，那我们现在呢，是。Latest，所以呢，它直接读最新的数据啊，以前的那些数据呢，就不要了，对吧？好，那我们这个时候呢，来到这边还是一样的，我们来一个18。

哎，来硅谷保存对吧，保存好之后我们到这边来看一下，诶那么这边呢，就有这个数据了，Before now after是我们的数据，因为我们是一个新增，诶看operator是c create CD嘛，对吧，增筛改查啊好那。Before，因为新增数据之前肯定是，那呃，然后source等等，这里边信息呢，就是连接是my circle对吧？然后呢，表明呃库名等等的信息，时间戳，然后文件名位置信息等等这些都有对吧？操作时间戳啊是否有事误诶那我们最关键的不就是这个东西吗？是不是还有它的什么，表明我们对于我们来说比较关键的是不是这个，以及它的操作类型，时间戳，如果你需要你就拿一下不需要，呃，发现也没事，对吧？啊就这样的一个情况，好，那这是新增，那接下来呢，我们做一个修改啊，比如说还是把它改成大写的A。

保存，保存好以后我们再来看，又多了一条数据，对吧，那这个时候b before就有了啊，因为它这个修改操作，它有b before是小写的A，新的是大写的A，这是一个更新操作，看U。Update对吧，那接下来呢，我们做一个删除，把这条数据呢，我们给它干掉。干掉以后呢，这边又来了一条数据，诶，它只有before，没有after，因为它是一个删除数据，所以删除数据呢，只有以前的新的东西没了，对吧？这里面并没有18这条数据了，OK，那就是这个样子的啊呃，那这个里边呢，其实有很多没用的东西，所以刚才大家看到，呃，在这个代码里边呢，比较复杂，因为我们对这个格式呢做了一个改造，同时呢，我们在里面加了一些内容，想让它能够实现，呃，可以读取最新的，也可以读取选量，通过参数来控制，这样是不是更方便一些啊。没毛病吧，对吧，好，那这是我们把简单的测一下复稍微复杂一点的呢，也就简单了啊，一步一步来，如果我直接跟你聊这个代码，可能大家觉得啊，这个好像挺难的，对吧。