hbase-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Amandeep Khurana <ama...@gmail.com>
Subject Reading from hbase
Date Fri, 20 Feb 2009 21:19:31 GMT
I am a new Hbase user and am trying to figure my way around with the
framework.

I was able to get the cluster going and used map reduce to enter data into
it. Now, I need to access the table from a java program from a client
machine. How can I do that? I tried setting the hbase.master value in the
configuration to the server:port of the hbase master, but that didnt work. I
added the default.xml and site.xml files as resources in the
HBaseConfiguration object, that didnt work either.

This is the error I am getting:

Exception in thread "main" java.lang.IllegalStateException
   at java.nio.charset.CharsetEncoder.encode(libgcj.so.90)
   at org.apache.hadoop.io.Text.encode(Text.java:388)
   at org.apache.hadoop.io.Text.encode(Text.java:369)
   at org.apache.hadoop.io.Text.writeString(Text.java:409)
   at
org.apache.hadoop.hbase.io.HbaseObjectWritable.writeObject(HbaseObjectWritable.java:265)
   at
org.apache.hadoop.hbase.ipc.HBaseRPC$Invocation.write(HBaseRPC.java:156)
   at
org.apache.hadoop.hbase.ipc.HBaseClient$Connection.sendParam(HBaseClient.java:472)
   at org.apache.hadoop.hbase.ipc.HBaseClient.call(HBaseClient.java:691)
   at org.apache.hadoop.hbase.ipc.HBaseRPC$Invoker.invoke(HBaseRPC.java:321)
   at $Proxy1.getProtocolVersion(Unknown Source:0)
   at org.apache.hadoop.hbase.ipc.HBaseRPC.getProxy(HBaseRPC.java:467)
   at org.apache.hadoop.hbase.ipc.HBaseRPC.getProxy(HBaseRPC.java:443)
   at org.apache.hadoop.hbase.ipc.HBaseRPC.getProxy(HBaseRPC.java:491)
   at org.apache.hadoop.hbase.ipc.HBaseRPC.waitForProxy(HBaseRPC.java:407)
   at
org.apache.hadoop.hbase.client.HConnectionManager$TableServers.getHRegionConnection(HConnectionManager.java:724)
   at
org.apache.hadoop.hbase.client.HConnectionManager$TableServers.locateRootRegion(HConnectionManager.java:773)
   at
org.apache.hadoop.hbase.client.HConnectionManager$TableServers.locateRegion(HConnectionManager.java:448)
   at
org.apache.hadoop.hbase.client.HConnectionManager$TableServers.locateRegion(HConnectionManager.java:423)
   at
org.apache.hadoop.hbase.client.HConnectionManager$TableServers.locateRegionInMeta(HConnectionManager.java:498)
   at
org.apache.hadoop.hbase.client.HConnectionManager$TableServers.locateRegion(HConnectionManager.java:457)
   at
org.apache.hadoop.hbase.client.HConnectionManager$TableServers.locateRegion(HConnectionManager.java:423)
   at
org.apache.hadoop.hbase.client.HConnectionManager$TableServers.locateRegionInMeta(HConnectionManager.java:498)
   at
org.apache.hadoop.hbase.client.HConnectionManager$TableServers.locateRegion(HConnectionManager.java:461)
   at
org.apache.hadoop.hbase.client.HConnectionManager$TableServers.locateRegion(HConnectionManager.java:423)
   at org.apache.hadoop.hbase.client.HTable.<init>(HTable.java:114)
   at org.apache.hadoop.hbase.client.HTable.<init>(HTable.java:97)
   at Client.main(Client.java:21)

What am I doing wrong?

Here's my code for accessing the table:
HBaseConfiguration config = new HBaseConfiguration();
        config.set("hbase.master", "rndpc0:60000");
//        config.addResource(new
Path("/hadoop/install/hbase/conf/hbase-default.xml"));
//        config.addResource(new
Path("/hadoop/install/hbase/conf/hbase-site.xml"));
        HTable table = new HTable(config, "sunm");
        Cell cell = table.get("842", "disruption:");
        String valueStr = Bytes.toString(cell.getValue());
        System.out.println(valueStr);


Amandeep



Amandeep Khurana
Computer Science Graduate Student
University of California, Santa Cruz

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message