MAPREDUCE服务 MRS-Flink HBase样例程序开发思路:开发思路

时间:2024-06-13 09:38:27

开发思路

  1. 写HBase:
    1. 通过参数指定“hbase-site.xml”文件的父目录,Flink Sink可以获取到HBase的Connection。
    2. 通过Connection判断表是否存在,如果不存在则创建表。
    3. 将接收到的数据转化成Put对象,写到HBase。
  2. 读HBase:
    1. 通过参数指定“hbase-site.xml”文件的父目录,Flink Source可以获取到HBase的Connection。
    2. 通过Connection判断表是否存在,如果不存在则作业失败,需要通过HBase Shell创建表或上游作业创建表。
    3. 读取HBase中的数据,将Result数据转化成Row对象发送给下游算子。
support.huaweicloud.com/devg-lts-mrs/mrs_07_050060.html