本文共 1202 字,大约阅读时间需要 4 分钟。
// rowkey设置为整形1~31 转换为了16进制表示32~126转换为ASCII码的字符表示(包括32和126)127以后按照16进制表示(包括127)
代码:
public static void main(String[] args) throws IOException { System.setProperty("hadoop.home.dir", "E:\\software\\bigdate\\hadoop-2.6.0-cdh5.15.0\\hadoop-2.6.0-cdh5.15.0"); Configuration conf = new Configuration(); conf.set("zookeeper.znode.parent", "/hbase"); conf.set("hbase.zookeeper.quorum", "wang"); conf.set("hbase.zookeeper.property.clientPort", "2181"); //和hbase连接 Connection connection = ConnectionFactory.createConnection(conf); Admin admin = connection.getAdmin(); TableName tableName = TableName.valueOf("hadoop:t1"); Table table =connection.getTable(tableName); //插入数据,封装到Put,必须指定rowkey /* //设置为整形 1~31 转换为了16进制表示 32~126转换为ASCII码的字符表示(包括32和126) 127以后按照16进制表示(包括127)*/ Put put = new Put(Bytes.toBytes(6666)); // Put addColumn(byte [] family, byte [] qualifier, byte [] value) put.addColumn(Bytes.toBytes("f1"),Bytes.toBytes("id"),Bytes.toBytes(1)); put.addColumn(Bytes.toBytes("f1"),Bytes.toBytes("name"),Bytes.toBytes("haha")); //触发操作 table.put(put); }
转载地址:http://lrjxi.baihongyu.com/