You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by Luna Wong <gf...@gmail.com> on 2020/11/16 11:54:36 UTC

Flink未来会弃用TableSourceFactory吗

FLIP-95都实现后有了DynamicTableSourceFactory那么TableSourceFactory会弃用吗？

Re: Flink未来会弃用TableSourceFactory吗

Posted by Luna Wong <gf...@gmail.com>.

1.11版本 FactoryUtil类中有如下方法。
public static DynamicTableSink createTableSink();

我拿到DynamicTableSink之后调用什么API可以把表注册进Catalog啊。

老版本API有 tEnv.registerTableSink() 注册TableSink。新版我是没办法这么注册DynamicTableSink是吧。

Leonard Xu <xb...@gmail.com> 于2020年11月16日周一 下午10:59写道：
>
> Hi,
> 据我了解会弃用的，新的connector都会用DynamicTableSourceFactory，一般稳定一两个版本后社区会弃用，
> 另外这个是比较底层的实现，sql用户应该感知不到，如果有自定义connector的开发都建议用DynamicTableSourceFactory。
>
> 祝好
> Leonard Xu
>
> > 在 2020年11月16日，19:54，Luna Wong <gf...@gmail.com> 写道：
> >
> > FLIP-95都实现后有了DynamicTableSourceFactory那么TableSourceFactory会弃用吗？
>

Re: Flink未来会弃用TableSourceFactory吗

Posted by Leonard Xu <xb...@gmail.com>.

Hi, 
据我了解会弃用的，新的connector都会用DynamicTableSourceFactory，一般稳定一两个版本后社区会弃用，
另外这个是比较底层的实现，sql用户应该感知不到，如果有自定义connector的开发都建议用DynamicTableSourceFactory。

祝好
Leonard Xu

> 在 2020年11月16日，19:54，Luna Wong <gf...@gmail.com> 写道：
> 
> FLIP-95都实现后有了DynamicTableSourceFactory那么TableSourceFactory会弃用吗？