Flink-1.15 HiveDynamicTableFactory 取Catalog使用

[yanggang_it_job <ya...@163.com>]

当前使用HiveDynamicTableFactory需要先声明HiveCatalog才可以使用。
请问能否把HiveDynamicTableFactory直接作为一个connector使用，或者说需要怎么调整才可以直接使用？

Re:Flink-1.15 HiveDynamicTableFactory 取Catalog使用

[Xuyang <xy...@163.com>]

Hi，你可以看下HiveDynamicTableFactory的实现，作为connector需要实现factoryIdentifier来表明在with参数中使用的‘connector’=‘xxx’，但这个类由于仅支持在hive catalog中使用，所以没有实现（还有一些其他的方法，如options可以透传with中的其他参数）。
如果你需要HiveDynamicTableFactory的功能，我感觉可以通过copy出一个新的connector类，参照其他正常connector的方式裁剪和实现一些必要的方法，然后mvn打包一下




--

    Best！
    Xuyang





在 2022-09-19 17:04:00，"yanggang_it_job" <ya...@163.com> 写道：
>当前使用HiveDynamicTableFactory需要先声明HiveCatalog才可以使用。
>请问能否把HiveDynamicTableFactory直接作为一个connector使用，或者说需要怎么调整才可以直接使用？

Re: Flink-1.15 HiveDynamicTableFactory 取Catalog使用

[yuxia <lu...@alumni.sjtu.edu.cn>]

目前还不能直接 把HiveDynamicTableFactory直接作为一个connector使用。
把 HiveDynamicTableFactory 改造一下，
factoryIdentifier 不能再抛出  UnsupportedOperationException("Hive factory is only work for catalog.") 异常了，
改造工作量不大。

Best regards,
Yuxia

----- 原始邮件 -----
发件人: "yanggang_it_job" <ya...@163.com>
收件人: "user-zh" <us...@flink.apache.org>
发送时间: 星期一, 2022年 9 月 19日 下午 5:04:00
主题: Flink-1.15 HiveDynamicTableFactory 取Catalog使用

当前使用HiveDynamicTableFactory需要先声明HiveCatalog才可以使用。
请问能否把HiveDynamicTableFactory直接作为一个connector使用，或者说需要怎么调整才可以直接使用？