赞
踩
具体可以查看
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.创建具体干活的查询任务
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。