-
ExceptionDalia Sobhy 2012-02-26, 22:22
Dear all,
I run this program but I found the following exception..
/** * Copyright 2008 The Apache Software Foundation * * Licensed to the Apache Software Foundation (ASF) under one * or more contributor license agreements. See the NOTICE file * distributed with this work for additional information * regarding copyright ownership. The ASF licenses this file * to you under the Apache License, Version 2.0 (the * "License"); you may not use this file except in compliance * with the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */package hbasetest;
import java.io.UnsupportedEncodingException;import java.nio.ByteBuffer;import java.nio.charset.CharacterCodingException;import java.nio.charset.Charset;import java.nio.charset.CharsetDecoder;import java.text.NumberFormat;import java.util.ArrayList;import java.util.List;import java.util.Map;import java.util.TreeMap;import java.util.SortedMap;
import org.apache.hadoop.hbase.thrift.generated.AlreadyExists;import org.apache.hadoop.hbase.thrift.generated.ColumnDescriptor;import org.apache.hadoop.hbase.thrift.generated.Hbase;import org.apache.hadoop.hbase.thrift.generated.IOError;import org.apache.hadoop.hbase.thrift.generated.IllegalArgument;import org.apache.hadoop.hbase.thrift.generated.Mutation;import org.apache.hadoop.hbase.thrift.generated.NotFound;import org.apache.hadoop.hbase.thrift.generated.TCell;import org.apache.hadoop.hbase.thrift.generated.TRowResult;
//import com.facebook.thrift.TException;//import com.facebook.thrift.protocol.TBinaryProtocol;//import com.facebook.thrift.protocol.TProtocol;//import com.facebook.thrift.transport.TSocket;//import com.facebook.thrift.transport.TTransport;
//import org.apache.hadoop.hive.service.ThriftHive;import org.apache.thrift.TException;
import org.apache.thrift.protocol.TBinaryProtocol;
import org.apache.thrift.protocol.TProtocol;
import org.apache.thrift.transport.TSocket;
import org.apache.thrift.transport.TTransport;
import org.apache.thrift.transport.TTransportException;/* * Instructions: * 1. Run Thrift to generate the java module HBase * thrift --gen java ../../../src/main/resources/org/apache/hadoop/hbase/thrift/Hbase.thrift * 2. Acquire a jar of compiled Thrift java classes. As of this writing, HBase ships * with this jar (libthrift-[VERSION].jar). If this jar is not present, or it is * out-of-date with your current version of thrift, you can compile the jar * yourself by executing {ant} in {$THRIFT_HOME}/lib/java. * 3. Compile and execute this file with both the libthrift jar and the gen-java/ * directory in the classpath. This can be done on the command-line with the * following lines: (from the directory containing this file and gen-java/) * * javac -cp /path/to/libthrift/jar.jar:gen-java/ DemoClient.java * mv DemoClient.class gen-java/org/apache/hadoop/hbase/thrift/ * java -cp /path/to/libthrift/jar.jar:gen-java/ org.apache.hadoop.hbase.thri
ft.DemoClient * */public class HbaseTestClient { protected int port = 9090; CharsetDecoder decoder = null;
public static void main(String[] args) throws IOError, TException, UnsupportedEncodingException, IllegalArgument, AlreadyExists { HbaseTestClient client = new HbaseTestClient(); client.run(); }
HbaseTestClient() { decoder = Charset.forName("UTF-8").newDecoder(); } // Helper to translate byte[]'s to UTF8 strings private String utf8(byte[] buf) { try { return decoder.decode(ByteBuffer.wrap(buf)).toString(); } catch (CharacterCodingException e) { return "[INVALID UTF-8]"; } } // Helper to translate strings to UTF8 bytes private byte[] bytes(String s) { try { return s.getBytes("UTF-8"); } catch (UnsupportedEncodingException e) { e.printStackTrace(); return null; } } private void run() throws IOError, TException, IllegalArgument, AlreadyExists { TTransport transport = new TSocket("192.168.0.2", port); TProtocol protocol = new TBinaryProtocol(transport, true, true); Hbase.Client client = new Hbase.Client(protocol);
transport.open();
byte[] t = bytes("demo_table"); byte[] t1 = bytes("test"); // // Scan all tables, look for the demo table and delete it. // System.out.println("scanning tables..."); for (byte[] name : client.getTableNames()) { System.out.println(" found: " + utf8(name)); if (utf8(name).equals(utf8(t))) { if (client.isTableEnabled(name)) { System.out.println(" disabling table: " + utf8(name)); client.disableTable(name); } System.out.println(" deleting table: " + utf8(name)); client.deleteTable(name); } } // // Create the demo table with two column families, entry: and unused: // ArrayList<ColumnDescriptor> columns = new ArrayList<ColumnDescriptor>(); ColumnDescriptor col = null; col = new ColumnDescriptor(); col.name = bytes("entry:"); col.maxVersions = 10; columns.add(col); col = new ColumnDescriptor(); col.name = bytes("unused:"); columns.add(col);
System.out.println("creating table: " + utf8(t)); try { // client.deleteTable("test".getBytes()); client.createTable(t, columns); } catch (AlreadyExists ae) { System.out.println("WARN: " + ae.message); } catch(Exception ex){ System.out.println(ex); } System.exit(0); System.out.println("column families in " + utf8(t) + ": "); Map<byte[], ColumnDescriptor> columnMap = client.getColumnDescriptors(t); for (ColumnDescriptor col2 : columnMap.values()) { System.out.println(" column: " + utf8(col2.na
