如何将HDFS上的文件读入到Hbase，用java

要将HDFS上的文件读入到HBase，可以使用Java编写MapReduce程序实现，以下是实现步骤：

1. 首先需要创建一个HBase表，可使用HBase Shell或Java API创建；
2. 编写MapReduce程序，其中Map阶段读取HDFS上的文件，将数据转换成Put对象，然后将Put对象写入到HBase表中；
3. 在MapReduce程序中设置HBase表名、列族名、列名等参数；
4. 在程序运行前，需要将HBase相关的jar包和配置文件加入到classpath中；
5. 最后提交MapReduce任务运行即可。

以下是示例代码：

Configuration conf = HBaseConfiguration.create();
Job job = Job.getInstance(conf, "HDFS to HBase");

job.setJarByClass(HdfsToHBase.class);
job.setMapperClass(HdfsToHBaseMapper.class);

FileInputFormat.addInputPath(job, new Path("hdfs://localhost:9000/input"));
TableMapReduceUtil.initTableReducerJob("table_name", HdfsToHBaseReducer.class, job);

job.setMapOutputKeyClass(ImmutableBytesWritable.class);
job.setMapOutputValueClass(Put.class);

System.exit(job.waitForCompletion(true) ? 0 : 1);

其中，HdfsToHBaseMapper类的代码如下：

public class HdfsToHBaseMapper extends Mapper<LongWritable, Text, ImmutableBytesWritable, Put> {

    private final static byte[] CF = "cf".getBytes();
    private final static byte[] COLUMN = "column".getBytes();

    @Override
    protected void map(LongWritable key, Text value, Context context) throws IOException, InterruptedException {
        String[] fields = value.toString().split(",");
        String rowKey = fields[0];
        Put put = new Put(Bytes.toBytes(rowKey));
        put.addColumn(CF, COLUMN, Bytes.toBytes(fields[1]));
        context.write(new ImmutableBytesWritable(Bytes.toBytes(rowKey)), put);
    }
}

其中，HdfsToHBaseReducer类的代码如下：

public class HdfsToHBaseReducer extends TableReducer<ImmutableBytesWritable, Put, ImmutableBytesWritable> {

    @Override
    protected void reduce(ImmutableBytesWritable key, Iterable<Put> values, Context context) throws IOException, InterruptedException {
        for (Put put : values) {
            context.write(key, put);
        }
    }
}

在以上代码中，CF和COLUMN分别表示HBase表的列族名和列名，可以根据实际情况修改。同时，也要根据实际情况修改HDFS文件路径、HBase表名等参数。