Hi,
可以参考现有的connector,如hbase,jdbc,结合[1]实现自定义connector。


祝好,
Leonard Xu
[1] 
https://ci.apache.org/projects/flink/flink-docs-master/dev/table/sourceSinks.html
 
<https://ci.apache.org/projects/flink/flink-docs-master/dev/table/sourceSinks.html>


> 在 2020年5月28日,09:16,Peihui He <[email protected]> 写道:
> 
> hello
> 
>        请教大家,flink 1.10中如何自定义coonnecter,然后注册到flink sql
> gateway,使得可以执行sql的操作呢?
> 
> 
> best wish

回复