hello

 现在已经定义了一个tablesource,可以通过  batchEnv.registerTableSource 这个注册
并查询数据,但是如何在sqlgateway 中配置呢?

Leonard Xu <[email protected]> 于2020年5月28日周四 上午9:32写道:

> 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
>
>

回复