import java.util.List;

import org.apache.hadoop.hive.service.HiveClient;

import org.apache.hadoop.hive.service.HiveServerException;

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;

public class thrift_hive_java {

private static String HOST = "127.0.0.1";

private static int PORT = 10000;

public static void main(String[] args)

{

TTransport transport = new TSocket(HOST, PORT);

TProtocol protocol = new TBinaryProtocol(transport);

HiveClient client = new HiveClient(protocol);

try {

long time1 = System.currentTimeMillis();

transport.open();

client.execute("select a, b, c from tb where a='' and b='' limit 10");

List<String> list = client.fetchAll();

long time2 = System.currentTimeMillis();

String str = "";

for(int i = 0; i < list.size(); i++)

{

str = list.get(i);

System.out.println(str);

}

System.out.println("use time : " + (time2 - time1) + " ms." );

} catch (TTransportException e) {

e.printStackTrace();

} catch (HiveServerException e) {

e.printStackTrace();

} catch (TException e) {

e.printStackTrace();

}

try {

client.shutdown();

} catch (TException e) {

e.printStackTrace();

}

transport.close();

}

}