import
java.io.IOException;
import
java.util.Iterator;
import
java.util.List;
import
org.apache.hadoop.conf.Configuration;
import
org.apache.hadoop.hbase.Cell;
import
org.apache.hadoop.hbase.CellUtil;
import
org.apache.hadoop.hbase.HBaseConfiguration;
import
org.apache.hadoop.hbase.HColumnDescriptor;
import
org.apache.hadoop.hbase.HTableDescriptor;
import
org.apache.hadoop.hbase.TableName;
import
org.apache.hadoop.hbase.client.Delete;
import
org.apache.hadoop.hbase.client.Get;
import
org.apache.hadoop.hbase.client.HBaseAdmin;
import
org.apache.hadoop.hbase.client.HTable;
import
org.apache.hadoop.hbase.client.Put;
import
org.apache.hadoop.hbase.client.Result;
import
org.apache.hadoop.hbase.client.ResultScanner;
import
org.apache.hadoop.hbase.client.Scan;
import
org.apache.hadoop.hbase.util.Bytes;
import
org.junit.Test;
public
class Run {
static
Configuration conf = null;
public
static Configuration configuration;
static {
conf = HBaseConfiguration.create();
configuration = HBaseConfiguration.create();
configuration.set("hbase.zookeeper.property.clientPort", "2181");
configuration.set("hbase.zookeeper.quorum", "hd1,hd2,hd3,hd4");
configuration.set("hbase.master", "hd1:60000");
}
public
static void main(String[] args) throws IOException{
//
TODO Auto-generated method stub
try
{
System.out.println("start");
go();
System.out.println("over");
}
catch
(Exception e)
{
System.out.println(e.toString());
}
}
public
Run() throws IOException {
super();
}
public
static void go() throws IOException
{
for
(int i1 = 0; i1 <= 3; i1++) {
for
(int i2 = 0; i2 <= 3; i2++) {
for
(int i3 = 0; i3 <= 3; i3++) {
for
(int i4 = 0; i4 <= 3; i4++) {
System.out.println(Integer.toString(i1*1000+i2*100+i3*10+i4));
addData(i1,
i2, i3, i4);
}
}
}
}
}
public
static void addData(int i1, int i2, int i3, int i4) throws IOException
{
String
strTBName = "ttable0";
String
strColFamily = "tuser";
String
strColumn = "b";//列名
String
strRowKey = "";//行号
String
strValue = "1";//值
HTable
table1 = new HTable(conf, strTBName);
strRowKey
=
Integer.toString(i1)+Integer.toString(i2)+Integer.toString(i3)+Integer.toString(i4);
Put
put = new Put(Bytes.toBytes(strRowKey));// 设置行号，RowKey
put.add(Bytes.toBytes(strColFamily),
Bytes.toBytes(strColumn),
Bytes.toBytes(strValue));
table1.put(put);
table1.close();
}
}
为瑞昌等地区用户提供了全套网页设计制作服务，及瑞昌网站建设行业解决方案。主营业务为成都网站设计、成都网站制作、瑞昌网站设计，以传统方式定制建设网站，并提供域名空间备案等一条龙服务，秉承以专业、用心的态度为用户提供真诚的服务。我们深信只要达到每一位用户的要求，就会得到认可，从而选择与我们长期合作。这样，我们也可以走得更远！
单纯这样写，别的问题没有，就是速度超级慢。损失的环节主要是建立连接和分配HTable的时候。