这个屌丝很懒，什么也没留下！

flink connector实现原理和自定义connector_flink 自定义connector

作者：小惠珠哦 | 2024-07-07 23:38:32

flink 自定义connector

动态源工厂：解析flink sql中with的属性，利用spi技术实现对应的动态源工厂的创建

动态源表：创建动态原表，并在实现类中new动态源

动态源：实现RichSourceFunction，

实现open、run和cancle方法，在run方法中实现具体的逻辑

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/小惠珠哦/article/detail/797069