1. 原始数据实时ETL任务HBase调优
1.1 数据写入hbase优化
上一节写入数据，一条条数据put到表中，对于大量数据的写入，效率极低，因此针对此项进行优化
-
使用hbase客户端写缓存进行批量写入数据到hbase中
-
hbase客户端写缓存对象:BufferedMutator
hbase的每一次put操作写入数据，实际上是一个RPC操作，将客户端的数据传输到hbase服务器再返回结果，适合小数据量写入，当需要写入大量数据时，每一次put连接一次RPC连接，会增加连接次数，因此会增加传输时间和IO消耗
BufferedMutator通过mutate方法提交数据，flush方法可以强制刷新缓冲区提交数据，最后执行close方法也会刷新缓冲区
使用BufferedMutator数据写与直接写数据到hbase的区别：
- 写入步骤与第一节类似，这里针对hbase客户端写入数据方式进行优化
1.2 优化后的代码实现
-
自定义sink，继承RichSinkFunction类
