当前位置：网站首页>基于Flink CDC实现实时数据采集(三）-Function接口实现

基于Flink CDC实现实时数据采集(三）-Function接口实现

2022-08-05 05:14:00 【IT_xhf】

为了统一sink的输入格式，在Source输出后做了一个统一Function处理，输出的数据格式为RowData,目前针对mysql、oracle、kafka三种数据源分别完成了三种实现类

/** * @author xiaohf7 * @date 2022/4/12 16:58 * @Description mysql binlog 的数据源转换 */
public class MysqlFunction extends BaseFunction{ 
    
    @

版权声明
本文为[IT_xhf]所创，转载请带上原文链接，感谢
https://blog.csdn.net/IT_xhf/article/details/126129191