通过rowkey查看为lianjia10和lianjia205数据并存储通过Java IO写到text中

以下是一个基于Java API从HBase中读取数据，并将结果写入文本文件的示例代码。在这个例子中，我们使用了Hadoop的FileSystem API来写入文本文件。

import java.io.BufferedWriter;
import java.io.OutputStreamWriter;
import java.util.ArrayList;
import java.util.List;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;
import org.apache.hadoop.hbase.Cell;
import org.apache.hadoop.hbase.CellUtil;
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.Get;
import org.apache.hadoop.hbase.client.Result;
import org.apache.hadoop.hbase.client.Table;

public class ReadHBaseAndWriteToFile {

   public static void main(String[] args) throws Exception {

      // 创建HBase配置对象
      Configuration config = HBaseConfiguration.create();

      // 创建HBase连接对象
      Connection connection = ConnectionFactory.createConnection(config);

      // 定义表名
      TableName tableName = TableName.valueOf("myTable");

      // 定义rowkeys
      List<String> rowkeys = new ArrayList<String>();
      rowkeys.add("lianjia10");
      rowkeys.add("lianjia205");

      // 创建文本文件
      FileSystem fs = FileSystem.get(config);
      Path filePath = new Path("/tmp/output.txt");
      BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(fs.create(filePath)));

      // 逐行读取数据，并写入文本文件
      Table table = connection.getTable(tableName);
      for (String rowkey : rowkeys) {
         Get get = new Get(rowkey.getBytes());
         Result result = table.get(get);
         for (Cell cell : result.rawCells()) {
            String line = rowkey + "\t" + new String(CellUtil.cloneQualifier(cell)) + "\t" + new String(CellUtil.cloneValue(cell));
            writer.write(line);
            writer.newLine();
         }
      }

      // 关闭连接和文件
      table.close();
      writer.close();
      fs.close();
      connection.close();
   }
}

在这个示例中，我们定义了表名和rowkeys，并使用HBase API从表中读取数据。然后，我们将每个单元格的值写入文本文件中。最后，我们关闭所有连接和资源。

请注意，这个示例代码仅用于演示目的，实际应用中需要根据具体需求进行修改。