Flink源码分析 | 读取HBase配置

2023-12-18 21:04:34

1、前言

上面文章中总结了Flink 获取 HBase 配置的逻辑和优先级，但是并没有对源码进行分析，本文主要是补充这一部分的源码分析。

2、版本

  • Flink 1.15.4
  • HBase 2.0.2

3、入口

从我之前写的文章：Flink用户自定义连接器（Table API Connectors）学习总结 中可知其实Flink Table API 读写 HBase 其实和通过自定义实现一个Table API Connectors （‘connector’ = ‘hbase-2.2’）差不多，只不过 HBase Connector 是Flink源码自带的，具体的模块为flink-connector-hbase-2.2，相关的类为HBase2DynamicTableFactory、HBaseDynamicTableSource 和 HBaseDynamicTableSink，入口为 HBase2DynamicTableFactory。并且在Hudi Flink SQL源码调试学习（一）我们也总结了从tableEnv.executeSql到Factor

文章来源:https://blog.csdn.net/dkl12/article/details/135070347
本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。