HBase的数据库与Elasticsearch的集成

import org.apache.hadoop.hbase.client.Put;
import org.apache.hadoop.hbase.util.Bytes;
import org.elasticsearch.action.index.IndexRequest;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestHighLevelClient;
 
// 假设hbasePut是从HBase表中获取的Put对象
Put hbasePut = ...
 
// 假设restHighLevelClient是已经配置好的Elasticsearch的RestHighLevelClient实例
RestHighLevelClient restHighLevelClient = ...
 
// 从HBase的Put对象中提取rowkey和列族:列限定符:值
String rowKey = Bytes.toString(hbasePut.getRow());
Map<String, Object> source = new HashMap<>();
for (Cell cell : hbasePut.getFamilyCellMap().get(Bytes.toBytes("your_column_family"))) {
    String qualifier = Bytes.toString(CellUtil.cloneQualifier(cell));
    String value = Bytes.toString(CellUtil.cloneValue(cell));
    source.put(qualifier, value);
}
 
// 使用Elasticsearch的RestHighLevelClient将数据索引到Elasticsearch
IndexRequest indexRequest = new IndexRequest("your_index_name")
        .id(rowKey)
        .source(source);
 
restHighLevelClient.index(indexRequest, RequestOptions.DEFAULT);

这段代码展示了如何从HBase的Put对象中提取数据，并将其索引到Elasticsearch中。需要注意的是，这里的your_column_family应该替换为实际的列族名，your_index_name应该替换为Elasticsearch中的索引名。同时，RestHighLevelClient实例需要根据Elasticsearch服务器的配置进行初始化。