Flink1.8如何批量Sink到HBase

Flink 1.8可以通过使用HBaseSink来实现将数据批量Sink到HBase。HBaseSink是Flink 1.8中提供的一种将数据写入HBase的方式，它可以将Flink的DataStream或DataSet转换为HBase表中的Put或Increment操作，并将其写入HBase。

要使用HBaseSink，首先需要构建一个HBaseSink的实例，它需要一些参数，如HBase的配置，表名称，操作类型（Put或Increment），以及将Flink数据转换为HBase操作的函数：

//创建HBaseSink实例
HBaseSink hbaseSink = new HBaseSink(hbaseConfig, tableName, opType, func);

其中，hbaseConfig是HBase的配置，可以使用HBaseConfiguration.create()来创建；tableName是HBase表的名称；opType是操作类型，可以是Put或Increment；func是一个将Flink数据转换为HBase操作的函数，可以使用HBaseSinkFunction来实现，它需要实现HBaseSinkFunction接口，该接口有两个方法：invoke()方法用于将Flink的DataStream或DataSet转换为HBase的Put或Increment操作，close()方法用于关闭HBase的连接。

有了HBaseSink实例后，就可以将它添加到Flink的DataStream或DataSet上，如下所示：

//将HBaseSink添加到DataStream
DataStream<String> dataStream = ...
dataStream.addSink(hbaseSink);

//将HBaseSink添加到DataSet
DataSet<String> dataSet = ...
dataSet.output(hbaseSink);

添加完HBaseSink后，Flink就会将DataStream或DataSet中的数据转换为HBase的Put或Increment操作，并将其写入HBase表中，从而实现将数据批量Sink到HBase。