当前位置:   article > 正文

flink自定义connector

flink自定义connector
具体可以查看
https://github.com/zck573693104/flinkLearn/tree/flink-1.13
实现细节
1.实现DynamicTableSourceFactory , DynamicTableSinkFactory 注册 自定义connector
 resources目录下创建文件 org.apache.flink.table.factories
2.自定义DynamicTableSource和DynamicTableSink 生成逻辑计划
3.根据维表或者select功能实现LookupTableSource,ScanTableSource
4.创建具体干活的查询任务
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8

在这里插入图片描述

声明:本文内容由网友自发贡献,不代表【wpsshop博客】立场,版权归原作者所有,本站不承担相应法律责任。如您发现有侵权的内容,请联系我们。转载请注明出处:https://www.wpsshop.cn/w/煮酒与君饮/article/detail/886378
推荐阅读
相关标签
  

闽ICP备14008679号