开发者社区> 问答> 正文

Flink catalog的几个疑问

Hi Flink社区:

有几个疑问希望社区小伙伴们帮忙解答一下:

1.个人感觉Flink很有必要提供一个官方的catalog,用来支持各种connector,比如:kafka,jdbc,hbase等等connector。不知道社区有没有这个打算,目前没有看到对应的flip

2.社区对hive catalog的定位是什么,后续有可能转正为flink 默认的catalog实现吗?

3.hive catalog是不支持大小写敏感的(字段名都是小写),这个后续会带来哪些问题?想征集下大家的意见避免我们以后踩大坑。

*来自志愿者整理的flink邮件归档

展开
收起
小阿矿 2021-12-06 16:49:56 679 0
1 条回答
写回答
取消 提交回答
    1. Flink 提供了一套catalog的接口,提提供了几个内置的实现:in-memory catalog, hive catalog,

    postgres catalog,

    可以根据自己的需求选择。也可以实现自定义的catalog。参考 [1]

    1. hive catalog 主要是对接 hive,方便读取现有的hive catalog的meta信息。当然也可以往hive

    catalog写新的meta。

    是否会转为默认catalog,据我所知,目前没有。

    1. 一般没什么问题。在和其他区分大小写的db对接的时候,可能有问题。

    *来自志愿者整理的flink邮件归档

    2021-12-06 17:13:47
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Flink CDC Meetup PPT - 龚中强 立即下载
Flink CDC Meetup PPT - 王赫 立即下载
Flink CDC Meetup PPT - 覃立辉 立即下载