要在HBase中寫入數據,可以通過HBase的Java API使用Put類。以下是一個簡單的示例:
import org.apache.hadoop.hbase.HBaseConfiguration;
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;
import org.apache.hadoop.hbase.util.Bytes;
public class Example {
public static void main(String[] args) {
try {
org.apache.hadoop.conf.Configuration config = HBaseConfiguration.create();
config.set("hbase.zookeeper.quorum", "localhost");
Connection connection = ConnectionFactory.createConnection(config);
Table table = connection.getTable(TableName.valueOf("example_table"));
Put put = new Put(Bytes.toBytes("row1"));
put.addColumn(Bytes.toBytes("cf"), Bytes.toBytes("col1"), Bytes.toBytes("value1"));
put.addColumn(Bytes.toBytes("cf"), Bytes.toBytes("col2"), Bytes.toBytes("value2"));
table.put(put);
table.close();
connection.close();
} catch (Exception e) {
e.printStackTrace();
}
}
}
在上面的示例中,我們創建了一個Put對象,指定了行鍵為"row1",列族為"cf",列名為"col1"和"col2",值為"value1"和"value2"。然后將該Put對象插入到名為"example_table"的表中。最后,記得關閉Table和Connection對象。