Flink源码分析 | 读取HBase配置

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,相关的类为HBase2DynamicTableFactoryHBaseDynamicTableSourceHBaseDynamicTableSink,入口为 HBase2DynamicTableFactory。并且在Hudi Flink SQL源码调试学习(一)我们也总结了从tableEnv.executeSqlFactor

相关推荐

  1. Flink分析 | 读取HBase配置

    2023-12-19 11:00:04       48 阅读
  2. flink分析 - flink命令启动分析

    2023-12-19 11:00:04       25 阅读
  3. flink分析 - yaml解析

    2023-12-19 11:00:04       26 阅读
  4. flink分析之功能组件(六)-心跳组件

    2023-12-19 11:00:04       41 阅读
  5. flink分析 - 简单解析命令行参数

    2023-12-19 11:00:04       30 阅读

最近更新

  1. TCP协议是安全的吗?

    2023-12-19 11:00:04       16 阅读
  2. 阿里云服务器执行yum,一直下载docker-ce-stable失败

    2023-12-19 11:00:04       16 阅读
  3. 【Python教程】压缩PDF文件大小

    2023-12-19 11:00:04       15 阅读
  4. 通过文章id递归查询所有评论(xml)

    2023-12-19 11:00:04       18 阅读

热门阅读

  1. HTML及FTL文件转换为PDF的实现方式

    2023-12-19 11:00:04       44 阅读
  2. Arrays.asList()方法的大坑

    2023-12-19 11:00:04       28 阅读
  3. mybatis框架的orm机制(类和数据库表的映射)

    2023-12-19 11:00:04       38 阅读
  4. Unity3D UDP传输大文件怎么提高速度详解

    2023-12-19 11:00:04       47 阅读
  5. linux中数据库的概念、mysql的两种安装方法

    2023-12-19 11:00:04       34 阅读
  6. 笔记:LVM的简单使用

    2023-12-19 11:00:04       36 阅读
  7. npm的介绍和使用

    2023-12-19 11:00:04       20 阅读
  8. openssl数据压缩

    2023-12-19 11:00:04       37 阅读