如何将数据加载到hbase

我想将数据加载到Hbase，因此我尝试了一本书HBASE：权威性指南中的简单示例。 HbaseHelper.java已加载。如何将数据加载到hbase

import org.apache.hadoop.conf.Configuration; 
import org.apache.hadoop.hbase.HBaseConfiguration; 
import org.apache.hadoop.hbase.client.HTable; 
import org.apache.hadoop.hbase.client.Put; 
import org.apache.hadoop.hbase.util.Bytes; 
// ^^ PutExample 
import util.HBaseHelper; 
// vv PutExample 

import java.io.IOException; 

public class PutExample { 

    public static void main(String[] args) throws IOException { 
    Configuration conf = HBaseConfiguration.create(); // co PutExample-1-CreateConf Create the required configuration. 

    // ^^ PutExample 
    HBaseHelper helper = HBaseHelper.getHelper(conf); 
    helper.dropTable("testtable1"); 
    helper.createTable("testtable1", "colfam1"); 
    // vv PutExample 
    HTable table = new HTable(conf, "testtable1"); // co PutExample-2-NewTable Instantiate a new client. 

    Put put = new Put(Bytes.toBytes("row1")); // co PutExample-3-NewPut Create put with specific row. 

    put.add(Bytes.toBytes("colfam1"), Bytes.toBytes("qual1"), 
     Bytes.toBytes("val1")); // co PutExample-4-AddCol1 Add a column, whose name is "colfam1:qual1", to the put. 
    put.add(Bytes.toBytes("colfam1"), Bytes.toBytes("qual2"), 
     Bytes.toBytes("val2")); // co PutExample-4-AddCol2 Add another column, whose name is "colfam1:qual2", to the put. 

    table.put(put); // co PutExample-5-DoPut Store row with column into the HBase table. 
    } 
}

我做的javac -classpath HBase的-version.jar：hadoop.jar：zookeeper.jar：log4j.jar：公地-logging.jar：公地lang.jar PutData.java（他们是在同一目录），但不能成功编译。据说：

Note: Some input files use or override a deprecated API. 
Note: Recompile with -Xlint:deprecation for details. 
Note: Some input files use unchecked or unsafe operations. 
Note: Recompile with -Xlint:unchecked for details.

我尝试了一些其他类似的方法将数据。错误是一样的。我怎样才能以任何可能的方式做到这一点？

来源

2014-11-06 chenchenmomo

你安装了zookeeper吗？它的运行与否？ – 2014-11-06 16:46:49

是的，zookeeper安装并且版本是3.4.5-cdh5.0.2--1 – chenchenmomo 2014-11-06 17:00:59

检查这是否与你的问题相同 - http://stackoverflow.com/questions/7470677/some-input-files-use-或重写的-A-弃用-API – mbaxi 2014-11-07 06:45:22

试试这个代码，首先添加HBase的/ conf目录偏食 - 在java中内置路径 - >源 - >添加链接 - >您的HBase的conf目录

进口产生java.io.IOException;

import org.apache.hadoop.hbase.HBaseConfiguration; 
import org.apache.hadoop.hbase.HTableDescriptor; 
import org.apache.hadoop.hbase.client.Get; 
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; 
public class insertDataManually 
{ 
public static void main(String[] args) throws IOException 
{ 
    org.apache.hadoop.conf.Configuration config = HBaseConfiguration.create(); 

    HTable table = new HTable(config, "car"); 
    Put p = new Put(Bytes.toBytes("row1")); 
    p.add(Bytes.toBytes("vi"), Bytes.toBytes("make"),Bytes.toBytes("bmw")); 
    p.add(Bytes.toBytes("vi"),Bytes.toBytes("model"),Bytes.toBytes("2012")); 
    table.put(p); 
    Get g = new Get(Bytes.toBytes("row1")); 
    Result r = table.get(g); 
    byte [] value = r.getValue(Bytes.toBytes("vi"),Bytes.toBytes("make")); 
    byte [] value1 = r.getValue(Bytes.toBytes("vi"),Bytes.toBytes("model")); 
    String valueStr = Bytes.toString(value); 
    String valueStr1 = Bytes.toString(value1); 
    System.out.println("GET: " +"make: "+ valueStr+" model: "+valueStr1); 
    Scan s = new Scan(); 
    s.addColumn(Bytes.toBytes("vi"), Bytes.toBytes("make")); 
    s.addColumn(Bytes.toBytes("vi"), Bytes.toBytes("model")); 
    ResultScanner scanner = table.getScanner(s); 
    try 
    { 
    for (Result rr = scanner.next(); rr != null; rr = scanner.next()) 
    { 
    System.out.println("Found row : " + rr); 
    } 
    } finally 
    { 
    // Make sure you close your scanners when you are done! 
    scanner.close(); 
    } 
} 
}

来源

2014-11-08 05:34:38

如何将数据加载到hbase

回答

相关问题