1.11版本 FactoryUtil类中有如下方法。 public static DynamicTableSink createTableSink();
我拿到DynamicTableSink之后调用什么API可以把表注册进Catalog啊。 老版本API有 tEnv.registerTableSink() 注册TableSink。新版我是没办法这么注册DynamicTableSink是吧。 Leonard Xu <[email protected]> 于2020年11月16日周一 下午10:59写道： > > Hi, > 据我了解会弃用的，新的connector都会用DynamicTableSourceFactory，一般稳定一两个版本后社区会弃用， > 另外这个是比较底层的实现，sql用户应该感知不到，如果有自定义connector的开发都建议用DynamicTableSourceFactory。 > > 祝好 > Leonard Xu > > > 在 2020年11月16日，19:54，Luna Wong <[email protected]> 写道： > > > > FLIP-95都实现后有了DynamicTableSourceFactory那么TableSourceFactory会弃用吗？ >
