请用java读入文本文件到Hbase中

首先，您需要使用HBase Java API来连接HBase，然后使用Java的文件读取器来读取文本文件。接下来，您需要将读取的文本文件逐行插入HBase表中。

下面是一个简单的例子，演示如何将文本文件逐行插入HBase表中：

import java.io.BufferedReader;
import java.io.FileReader;
import java.io.IOException;

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.client.Connection;
import org.apache.hadoop.hbase.client.ConnectionFactory;
import org.apache.hadoop.hbase.client.Put;
import org.apache.hadoop.hbase.client.Table;

public class TextFileToHBase {
    public static void main(String[] args) throws IOException {
        
        // 设置HBase配置
        Configuration conf = HBaseConfiguration.create();
        conf.set("hbase.zookeeper.quorum", "localhost");
        conf.set("hbase.zookeeper.property.clientPort", "2181");
        
        // 连接HBase
        Connection conn = ConnectionFactory.createConnection(conf);
        
        // 获取表
        Table table = conn.getTable(TableName.valueOf("mytable"));
        
        // 读取文本文件
        BufferedReader br = new BufferedReader(new FileReader("myfile.txt"));
        String line;
        while ((line = br.readLine()) != null) {
            // 创建Put对象并设置行键
            Put put = new Put(line.getBytes());
            // 设置列族、列和值
            put.addColumn("cf".getBytes(), "col".getBytes(), "value".getBytes());
            // 插入数据
            table.put(put);
        }
        br.close();
        
        // 关闭连接
        table.close();
        conn.close();
    }
}

这个例子假设您已经创建了名为“mytable”的HBase表，并且在表中有一个名为“cf:col”的列族和列。在插入数据时，请将行键设置为读取的每行文本。此代码仅适用于小型文件，如果文件很大，则需要进行更多优化。