Flink未来会弃用TableSourceFactory吗

classic Classic list List threaded Threaded
3 messages Options
Reply | Threaded
Open this post in threaded view
|

Flink未来会弃用TableSourceFactory吗

Luna Wong
FLIP-95都实现后有了DynamicTableSourceFactory那么TableSourceFactory会弃用吗?
Reply | Threaded
Open this post in threaded view
|

Re: Flink未来会弃用TableSourceFactory吗

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

祝好
Leonard Xu

> 在 2020年11月16日,19:54,Luna Wong <[hidden email]> 写道:
>
> FLIP-95都实现后有了DynamicTableSourceFactory那么TableSourceFactory会弃用吗?

Reply | Threaded
Open this post in threaded view
|

Re: Flink未来会弃用TableSourceFactory吗

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

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

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

Leonard Xu <[hidden email]> 于2020年11月16日周一 下午10:59写道:

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