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会弃用吗?
>