Flink中的Hive Connector

[code-dm]

[code-dm]

1. Hive Connector的使用：

• 基本概述
• Catalog
• 读写案例
• Hive中函数的使用

2. 源码了解

[code-dm]

一些企业中常见的使用例子：

1. 从MySQL中同步数据到Hive
2. MySQL实时同步一张表到Hive
3. 从Kafka同步数据到Hive
4. Hive的一个表同步到另外一个表
5. Kafka数据关联Hive维度数据进行同步

[code-dm]

参考相关连接：
Flink官方文档：https://nightlies.apache.org/flink/flink-docs-release-1.15/zh/docs/connectors/table/hive/overview/

[code-dm]

Hive Connector创建Catalog的原理：

• HiveCatalogFactory、HiveCatalog以及CatalogManager。
• HiveShim
• 执行流程

[code-dm]

Hive Connector 读写源码解析：
参考文章：
https://cloud.tencent.com/developer/article/1697918
https://nightlies.apache.org/flink/flink-docs-master/zh/docs/connectors/table/hive/hive_read_write/