检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
Flink HBase样例程序开发思路 本章节适用于MRS 3.2.0及以后版本。 典型场景说明 本样例介绍通过Flink API作业读写HBase数据。 数据规划 准备HBase配置文件,通过Manager下载集群配置,获取“hbase-site.xml”文件。 开发思路 写HBase:
Flink HBase样例程序开发思路 本章节适用于MRS 3.2.0及以后版本。 典型场景说明 本样例介绍通过Flink API作业读写HBase数据。 数据规划 准备HBase配置文件,通过Manager下载集群配置,获取“hbase-site.xml”文件。 开发思路 写HBase:
testDelete."); } 如果被删除的cell所在的列族上设置了二级索引,也会同步删除索引数据。 父主题: HBase数据读写样例程序
testDelete."); } 如果被删除的cell所在的列族上设置了二级索引,也会同步删除索引数据。 父主题: HBase数据读写样例程序
} } } LOG.info("Exiting testSelect."); } 父主题: HBase数据读写样例程序
testModifyTable."); } 注意事项 注[1] modifyTable只有表被disable时,才能生效。 父主题: HBase数据读写样例程序
ConnectionFactory.createConnection(conf); } 登录代码要避免重复调用。 父主题: HBase数据读写样例程序
ConnectionFactory.createConnection(conf); } 登录代码要避免重复调用。 父主题: HBase数据读写示例程序
Table,tableExists,isTableEnabled,isTableDisabled结合在一起使用。 父主题: HBase数据读写样例程序
Table,tableExists,isTableEnabled,isTableDisabled结合在一起使用。 父主题: HBase数据读写示例程序
SubstringComparator(substring))); scan.setFilter(filterList); 父主题: HBase数据读写样例程序
ALM-38009 Broker磁盘IO繁忙(适用于MRS 3.1.0之后版本) 告警解释 系统每60秒周期性检测Kafka各个磁盘的IO情况,当检测到某个Broker上的Kafka数据目录磁盘IO超出阈值(默认80%)时,产生该告警。 平滑次数为3,当该磁盘IO低于阈值(默认80%)时,告警恢复。
hbase.security.log.file=hbase-client-audit.log //审计日志文件命令 父主题: HBase数据读写样例程序
配置ClickHouse对接HDFS源文件(MRS 3.2.0-LTS) 本章节仅适用于MRS 3.2.0-LTS版本。 操作场景 本章节主要介绍使用ClickHouse对接HDFS组件进行文件读写。 前提条件 已安装ClickHouse客户端,例如客户端安装目录为“/opt/client”。
info("Exiting testMultiSplit."); } 注意:分割操作只对空Region起作用。 父主题: HBase数据读写样例程序
} } } LOG.info("Exiting testSelect."); } 父主题: HBase数据读写样例程序
SubstringComparator(substring))); scan.setFilter(filterList); 父主题: HBase数据读写样例程序
} } } LOG.info("Exiting dropIndex."); } 父主题: HBase数据读写样例程序
testDelete."); } 如果被删除的cell所在的列族上设置了二级索引,也会同步删除索引数据。 父主题: HBase数据读写示例程序
testModifyTable."); } 注意事项 注[1] modifyTable只有表被disable时,才能生效。 父主题: HBase数据读写示例程序