hive-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From nzh...@apache.org
Subject svn commit: r1044070 [9/29] - in /hive/trunk: ./ eclipse-templates/ ivy/ lib/ metastore/ metastore/if/ metastore/src/gen-cpp/ metastore/src/gen-javabean/org/apache/hadoop/hive/metastore/api/ metastore/src/gen-php/ metastore/src/gen-py/hive_metastore/ m...
Date Thu, 09 Dec 2010 18:31:09 GMT
Added: hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java
URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java?rev=1044070&view=auto
==============================================================================
--- hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java (added)
+++ hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java Thu Dec  9 18:30:58 2010
@@ -0,0 +1,38001 @@
+/**
+ * Autogenerated by Thrift
+ *
+ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ */
+package org.apache.hadoop.hive.metastore.api;
+
+import java.util.List;
+import java.util.ArrayList;
+import java.util.Map;
+import java.util.HashMap;
+import java.util.EnumMap;
+import java.util.Set;
+import java.util.HashSet;
+import java.util.EnumSet;
+import java.util.Collections;
+import java.util.BitSet;
+import java.nio.ByteBuffer;
+import java.util.Arrays;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import org.apache.thrift.*;
+import org.apache.thrift.async.*;
+import org.apache.thrift.meta_data.*;
+import org.apache.thrift.transport.*;
+import org.apache.thrift.protocol.*;
+
+public class ThriftHiveMetastore {
+
+  /**
+   * This interface is live.
+   */
+  public interface Iface extends com.facebook.fb303.FacebookService.Iface {
+
+    public void create_database(Database database) throws AlreadyExistsException, InvalidObjectException, MetaException, TException;
+
+    public Database get_database(String name) throws NoSuchObjectException, MetaException, TException;
+
+    public void drop_database(String name, boolean deleteData) throws NoSuchObjectException, InvalidOperationException, MetaException, TException;
+
+    public List<String> get_databases(String pattern) throws MetaException, TException;
+
+    public List<String> get_all_databases() throws MetaException, TException;
+
+    public Type get_type(String name) throws MetaException, NoSuchObjectException, TException;
+
+    public boolean create_type(Type type) throws AlreadyExistsException, InvalidObjectException, MetaException, TException;
+
+    public boolean drop_type(String type) throws MetaException, NoSuchObjectException, TException;
+
+    public Map<String,Type> get_type_all(String name) throws MetaException, TException;
+
+    public List<FieldSchema> get_fields(String db_name, String table_name) throws MetaException, UnknownTableException, UnknownDBException, TException;
+
+    public List<FieldSchema> get_schema(String db_name, String table_name) throws MetaException, UnknownTableException, UnknownDBException, TException;
+
+    public void create_table(Table tbl) throws AlreadyExistsException, InvalidObjectException, MetaException, NoSuchObjectException, TException;
+
+    public void drop_table(String dbname, String name, boolean deleteData) throws NoSuchObjectException, MetaException, TException;
+
+    public List<String> get_tables(String db_name, String pattern) throws MetaException, TException;
+
+    public List<String> get_all_tables(String db_name) throws MetaException, TException;
+
+    public Table get_table(String dbname, String tbl_name) throws MetaException, NoSuchObjectException, TException;
+
+    public void alter_table(String dbname, String tbl_name, Table new_tbl) throws InvalidOperationException, MetaException, TException;
+
+    public Partition add_partition(Partition new_part) throws InvalidObjectException, AlreadyExistsException, MetaException, TException;
+
+    public Partition append_partition(String db_name, String tbl_name, List<String> part_vals) throws InvalidObjectException, AlreadyExistsException, MetaException, TException;
+
+    public Partition append_partition_by_name(String db_name, String tbl_name, String part_name) throws InvalidObjectException, AlreadyExistsException, MetaException, TException;
+
+    public boolean drop_partition(String db_name, String tbl_name, List<String> part_vals, boolean deleteData) throws NoSuchObjectException, MetaException, TException;
+
+    public boolean drop_partition_by_name(String db_name, String tbl_name, String part_name, boolean deleteData) throws NoSuchObjectException, MetaException, TException;
+
+    public Partition get_partition(String db_name, String tbl_name, List<String> part_vals) throws MetaException, NoSuchObjectException, TException;
+
+    public Partition get_partition_by_name(String db_name, String tbl_name, String part_name) throws MetaException, NoSuchObjectException, TException;
+
+    public List<Partition> get_partitions(String db_name, String tbl_name, short max_parts) throws NoSuchObjectException, MetaException, TException;
+
+    public List<String> get_partition_names(String db_name, String tbl_name, short max_parts) throws MetaException, TException;
+
+    public List<Partition> get_partitions_ps(String db_name, String tbl_name, List<String> part_vals, short max_parts) throws MetaException, TException;
+
+    public List<String> get_partition_names_ps(String db_name, String tbl_name, List<String> part_vals, short max_parts) throws MetaException, TException;
+
+    public List<Partition> get_partitions_by_filter(String db_name, String tbl_name, String filter, short max_parts) throws MetaException, NoSuchObjectException, TException;
+
+    public void alter_partition(String db_name, String tbl_name, Partition new_part) throws InvalidOperationException, MetaException, TException;
+
+    public String get_config_value(String name, String defaultValue) throws ConfigValSecurityException, TException;
+
+    public List<String> partition_name_to_vals(String part_name) throws MetaException, TException;
+
+    public Map<String,String> partition_name_to_spec(String part_name) throws MetaException, TException;
+
+    public Index add_index(Index new_index, Table index_table) throws InvalidObjectException, AlreadyExistsException, MetaException, TException;
+
+    public void alter_index(String dbname, String base_tbl_name, String idx_name, Index new_idx) throws InvalidOperationException, MetaException, TException;
+
+    public boolean drop_index_by_name(String db_name, String tbl_name, String index_name, boolean deleteData) throws NoSuchObjectException, MetaException, TException;
+
+    public Index get_index_by_name(String db_name, String tbl_name, String index_name) throws MetaException, NoSuchObjectException, TException;
+
+    public List<Index> get_indexes(String db_name, String tbl_name, short max_indexes) throws NoSuchObjectException, MetaException, TException;
+
+    public List<String> get_index_names(String db_name, String tbl_name, short max_indexes) throws MetaException, TException;
+
+  }
+
+  public interface AsyncIface extends com.facebook.fb303.FacebookService .AsyncIface {
+
+    public void create_database(Database database, AsyncMethodCallback<AsyncClient.create_database_call> resultHandler) throws TException;
+
+    public void get_database(String name, AsyncMethodCallback<AsyncClient.get_database_call> resultHandler) throws TException;
+
+    public void drop_database(String name, boolean deleteData, AsyncMethodCallback<AsyncClient.drop_database_call> resultHandler) throws TException;
+
+    public void get_databases(String pattern, AsyncMethodCallback<AsyncClient.get_databases_call> resultHandler) throws TException;
+
+    public void get_all_databases(AsyncMethodCallback<AsyncClient.get_all_databases_call> resultHandler) throws TException;
+
+    public void get_type(String name, AsyncMethodCallback<AsyncClient.get_type_call> resultHandler) throws TException;
+
+    public void create_type(Type type, AsyncMethodCallback<AsyncClient.create_type_call> resultHandler) throws TException;
+
+    public void drop_type(String type, AsyncMethodCallback<AsyncClient.drop_type_call> resultHandler) throws TException;
+
+    public void get_type_all(String name, AsyncMethodCallback<AsyncClient.get_type_all_call> resultHandler) throws TException;
+
+    public void get_fields(String db_name, String table_name, AsyncMethodCallback<AsyncClient.get_fields_call> resultHandler) throws TException;
+
+    public void get_schema(String db_name, String table_name, AsyncMethodCallback<AsyncClient.get_schema_call> resultHandler) throws TException;
+
+    public void create_table(Table tbl, AsyncMethodCallback<AsyncClient.create_table_call> resultHandler) throws TException;
+
+    public void drop_table(String dbname, String name, boolean deleteData, AsyncMethodCallback<AsyncClient.drop_table_call> resultHandler) throws TException;
+
+    public void get_tables(String db_name, String pattern, AsyncMethodCallback<AsyncClient.get_tables_call> resultHandler) throws TException;
+
+    public void get_all_tables(String db_name, AsyncMethodCallback<AsyncClient.get_all_tables_call> resultHandler) throws TException;
+
+    public void get_table(String dbname, String tbl_name, AsyncMethodCallback<AsyncClient.get_table_call> resultHandler) throws TException;
+
+    public void alter_table(String dbname, String tbl_name, Table new_tbl, AsyncMethodCallback<AsyncClient.alter_table_call> resultHandler) throws TException;
+
+    public void add_partition(Partition new_part, AsyncMethodCallback<AsyncClient.add_partition_call> resultHandler) throws TException;
+
+    public void append_partition(String db_name, String tbl_name, List<String> part_vals, AsyncMethodCallback<AsyncClient.append_partition_call> resultHandler) throws TException;
+
+    public void append_partition_by_name(String db_name, String tbl_name, String part_name, AsyncMethodCallback<AsyncClient.append_partition_by_name_call> resultHandler) throws TException;
+
+    public void drop_partition(String db_name, String tbl_name, List<String> part_vals, boolean deleteData, AsyncMethodCallback<AsyncClient.drop_partition_call> resultHandler) throws TException;
+
+    public void drop_partition_by_name(String db_name, String tbl_name, String part_name, boolean deleteData, AsyncMethodCallback<AsyncClient.drop_partition_by_name_call> resultHandler) throws TException;
+
+    public void get_partition(String db_name, String tbl_name, List<String> part_vals, AsyncMethodCallback<AsyncClient.get_partition_call> resultHandler) throws TException;
+
+    public void get_partition_by_name(String db_name, String tbl_name, String part_name, AsyncMethodCallback<AsyncClient.get_partition_by_name_call> resultHandler) throws TException;
+
+    public void get_partitions(String db_name, String tbl_name, short max_parts, AsyncMethodCallback<AsyncClient.get_partitions_call> resultHandler) throws TException;
+
+    public void get_partition_names(String db_name, String tbl_name, short max_parts, AsyncMethodCallback<AsyncClient.get_partition_names_call> resultHandler) throws TException;
+
+    public void get_partitions_ps(String db_name, String tbl_name, List<String> part_vals, short max_parts, AsyncMethodCallback<AsyncClient.get_partitions_ps_call> resultHandler) throws TException;
+
+    public void get_partition_names_ps(String db_name, String tbl_name, List<String> part_vals, short max_parts, AsyncMethodCallback<AsyncClient.get_partition_names_ps_call> resultHandler) throws TException;
+
+    public void get_partitions_by_filter(String db_name, String tbl_name, String filter, short max_parts, AsyncMethodCallback<AsyncClient.get_partitions_by_filter_call> resultHandler) throws TException;
+
+    public void alter_partition(String db_name, String tbl_name, Partition new_part, AsyncMethodCallback<AsyncClient.alter_partition_call> resultHandler) throws TException;
+
+    public void get_config_value(String name, String defaultValue, AsyncMethodCallback<AsyncClient.get_config_value_call> resultHandler) throws TException;
+
+    public void partition_name_to_vals(String part_name, AsyncMethodCallback<AsyncClient.partition_name_to_vals_call> resultHandler) throws TException;
+
+    public void partition_name_to_spec(String part_name, AsyncMethodCallback<AsyncClient.partition_name_to_spec_call> resultHandler) throws TException;
+
+    public void add_index(Index new_index, Table index_table, AsyncMethodCallback<AsyncClient.add_index_call> resultHandler) throws TException;
+
+    public void alter_index(String dbname, String base_tbl_name, String idx_name, Index new_idx, AsyncMethodCallback<AsyncClient.alter_index_call> resultHandler) throws TException;
+
+    public void drop_index_by_name(String db_name, String tbl_name, String index_name, boolean deleteData, AsyncMethodCallback<AsyncClient.drop_index_by_name_call> resultHandler) throws TException;
+
+    public void get_index_by_name(String db_name, String tbl_name, String index_name, AsyncMethodCallback<AsyncClient.get_index_by_name_call> resultHandler) throws TException;
+
+    public void get_indexes(String db_name, String tbl_name, short max_indexes, AsyncMethodCallback<AsyncClient.get_indexes_call> resultHandler) throws TException;
+
+    public void get_index_names(String db_name, String tbl_name, short max_indexes, AsyncMethodCallback<AsyncClient.get_index_names_call> resultHandler) throws TException;
+
+  }
+
+  public static class Client extends com.facebook.fb303.FacebookService.Client implements TServiceClient, Iface {
+    public static class Factory implements TServiceClientFactory<Client> {
+      public Factory() {}
+      public Client getClient(TProtocol prot) {
+        return new Client(prot);
+      }
+      public Client getClient(TProtocol iprot, TProtocol oprot) {
+        return new Client(iprot, oprot);
+      }
+    }
+
+    public Client(TProtocol prot)
+    {
+      this(prot, prot);
+    }
+
+    public Client(TProtocol iprot, TProtocol oprot)
+    {
+      super(iprot, oprot);
+    }
+
+    public void create_database(Database database) throws AlreadyExistsException, InvalidObjectException, MetaException, TException
+    {
+      send_create_database(database);
+      recv_create_database();
+    }
+
+    public void send_create_database(Database database) throws TException
+    {
+      oprot_.writeMessageBegin(new TMessage("create_database", TMessageType.CALL, ++seqid_));
+      create_database_args args = new create_database_args();
+      args.setDatabase(database);
+      args.write(oprot_);
+      oprot_.writeMessageEnd();
+      oprot_.getTransport().flush();
+    }
+
+    public void recv_create_database() throws AlreadyExistsException, InvalidObjectException, MetaException, TException
+    {
+      TMessage msg = iprot_.readMessageBegin();
+      if (msg.type == TMessageType.EXCEPTION) {
+        TApplicationException x = TApplicationException.read(iprot_);
+        iprot_.readMessageEnd();
+        throw x;
+      }
+      if (msg.seqid != seqid_) {
+        throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "create_database failed: out of sequence response");
+      }
+      create_database_result result = new create_database_result();
+      result.read(iprot_);
+      iprot_.readMessageEnd();
+      if (result.o1 != null) {
+        throw result.o1;
+      }
+      if (result.o2 != null) {
+        throw result.o2;
+      }
+      if (result.o3 != null) {
+        throw result.o3;
+      }
+      return;
+    }
+
+    public Database get_database(String name) throws NoSuchObjectException, MetaException, TException
+    {
+      send_get_database(name);
+      return recv_get_database();
+    }
+
+    public void send_get_database(String name) throws TException
+    {
+      oprot_.writeMessageBegin(new TMessage("get_database", TMessageType.CALL, ++seqid_));
+      get_database_args args = new get_database_args();
+      args.setName(name);
+      args.write(oprot_);
+      oprot_.writeMessageEnd();
+      oprot_.getTransport().flush();
+    }
+
+    public Database recv_get_database() throws NoSuchObjectException, MetaException, TException
+    {
+      TMessage msg = iprot_.readMessageBegin();
+      if (msg.type == TMessageType.EXCEPTION) {
+        TApplicationException x = TApplicationException.read(iprot_);
+        iprot_.readMessageEnd();
+        throw x;
+      }
+      if (msg.seqid != seqid_) {
+        throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "get_database failed: out of sequence response");
+      }
+      get_database_result result = new get_database_result();
+      result.read(iprot_);
+      iprot_.readMessageEnd();
+      if (result.isSetSuccess()) {
+        return result.success;
+      }
+      if (result.o1 != null) {
+        throw result.o1;
+      }
+      if (result.o2 != null) {
+        throw result.o2;
+      }
+      throw new TApplicationException(TApplicationException.MISSING_RESULT, "get_database failed: unknown result");
+    }
+
+    public void drop_database(String name, boolean deleteData) throws NoSuchObjectException, InvalidOperationException, MetaException, TException
+    {
+      send_drop_database(name, deleteData);
+      recv_drop_database();
+    }
+
+    public void send_drop_database(String name, boolean deleteData) throws TException
+    {
+      oprot_.writeMessageBegin(new TMessage("drop_database", TMessageType.CALL, ++seqid_));
+      drop_database_args args = new drop_database_args();
+      args.setName(name);
+      args.setDeleteData(deleteData);
+      args.write(oprot_);
+      oprot_.writeMessageEnd();
+      oprot_.getTransport().flush();
+    }
+
+    public void recv_drop_database() throws NoSuchObjectException, InvalidOperationException, MetaException, TException
+    {
+      TMessage msg = iprot_.readMessageBegin();
+      if (msg.type == TMessageType.EXCEPTION) {
+        TApplicationException x = TApplicationException.read(iprot_);
+        iprot_.readMessageEnd();
+        throw x;
+      }
+      if (msg.seqid != seqid_) {
+        throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "drop_database failed: out of sequence response");
+      }
+      drop_database_result result = new drop_database_result();
+      result.read(iprot_);
+      iprot_.readMessageEnd();
+      if (result.o1 != null) {
+        throw result.o1;
+      }
+      if (result.o2 != null) {
+        throw result.o2;
+      }
+      if (result.o3 != null) {
+        throw result.o3;
+      }
+      return;
+    }
+
+    public List<String> get_databases(String pattern) throws MetaException, TException
+    {
+      send_get_databases(pattern);
+      return recv_get_databases();
+    }
+
+    public void send_get_databases(String pattern) throws TException
+    {
+      oprot_.writeMessageBegin(new TMessage("get_databases", TMessageType.CALL, ++seqid_));
+      get_databases_args args = new get_databases_args();
+      args.setPattern(pattern);
+      args.write(oprot_);
+      oprot_.writeMessageEnd();
+      oprot_.getTransport().flush();
+    }
+
+    public List<String> recv_get_databases() throws MetaException, TException
+    {
+      TMessage msg = iprot_.readMessageBegin();
+      if (msg.type == TMessageType.EXCEPTION) {
+        TApplicationException x = TApplicationException.read(iprot_);
+        iprot_.readMessageEnd();
+        throw x;
+      }
+      if (msg.seqid != seqid_) {
+        throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "get_databases failed: out of sequence response");
+      }
+      get_databases_result result = new get_databases_result();
+      result.read(iprot_);
+      iprot_.readMessageEnd();
+      if (result.isSetSuccess()) {
+        return result.success;
+      }
+      if (result.o1 != null) {
+        throw result.o1;
+      }
+      throw new TApplicationException(TApplicationException.MISSING_RESULT, "get_databases failed: unknown result");
+    }
+
+    public List<String> get_all_databases() throws MetaException, TException
+    {
+      send_get_all_databases();
+      return recv_get_all_databases();
+    }
+
+    public void send_get_all_databases() throws TException
+    {
+      oprot_.writeMessageBegin(new TMessage("get_all_databases", TMessageType.CALL, ++seqid_));
+      get_all_databases_args args = new get_all_databases_args();
+      args.write(oprot_);
+      oprot_.writeMessageEnd();
+      oprot_.getTransport().flush();
+    }
+
+    public List<String> recv_get_all_databases() throws MetaException, TException
+    {
+      TMessage msg = iprot_.readMessageBegin();
+      if (msg.type == TMessageType.EXCEPTION) {
+        TApplicationException x = TApplicationException.read(iprot_);
+        iprot_.readMessageEnd();
+        throw x;
+      }
+      if (msg.seqid != seqid_) {
+        throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "get_all_databases failed: out of sequence response");
+      }
+      get_all_databases_result result = new get_all_databases_result();
+      result.read(iprot_);
+      iprot_.readMessageEnd();
+      if (result.isSetSuccess()) {
+        return result.success;
+      }
+      if (result.o1 != null) {
+        throw result.o1;
+      }
+      throw new TApplicationException(TApplicationException.MISSING_RESULT, "get_all_databases failed: unknown result");
+    }
+
+    public Type get_type(String name) throws MetaException, NoSuchObjectException, TException
+    {
+      send_get_type(name);
+      return recv_get_type();
+    }
+
+    public void send_get_type(String name) throws TException
+    {
+      oprot_.writeMessageBegin(new TMessage("get_type", TMessageType.CALL, ++seqid_));
+      get_type_args args = new get_type_args();
+      args.setName(name);
+      args.write(oprot_);
+      oprot_.writeMessageEnd();
+      oprot_.getTransport().flush();
+    }
+
+    public Type recv_get_type() throws MetaException, NoSuchObjectException, TException
+    {
+      TMessage msg = iprot_.readMessageBegin();
+      if (msg.type == TMessageType.EXCEPTION) {
+        TApplicationException x = TApplicationException.read(iprot_);
+        iprot_.readMessageEnd();
+        throw x;
+      }
+      if (msg.seqid != seqid_) {
+        throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "get_type failed: out of sequence response");
+      }
+      get_type_result result = new get_type_result();
+      result.read(iprot_);
+      iprot_.readMessageEnd();
+      if (result.isSetSuccess()) {
+        return result.success;
+      }
+      if (result.o1 != null) {
+        throw result.o1;
+      }
+      if (result.o2 != null) {
+        throw result.o2;
+      }
+      throw new TApplicationException(TApplicationException.MISSING_RESULT, "get_type failed: unknown result");
+    }
+
+    public boolean create_type(Type type) throws AlreadyExistsException, InvalidObjectException, MetaException, TException
+    {
+      send_create_type(type);
+      return recv_create_type();
+    }
+
+    public void send_create_type(Type type) throws TException
+    {
+      oprot_.writeMessageBegin(new TMessage("create_type", TMessageType.CALL, ++seqid_));
+      create_type_args args = new create_type_args();
+      args.setType(type);
+      args.write(oprot_);
+      oprot_.writeMessageEnd();
+      oprot_.getTransport().flush();
+    }
+
+    public boolean recv_create_type() throws AlreadyExistsException, InvalidObjectException, MetaException, TException
+    {
+      TMessage msg = iprot_.readMessageBegin();
+      if (msg.type == TMessageType.EXCEPTION) {
+        TApplicationException x = TApplicationException.read(iprot_);
+        iprot_.readMessageEnd();
+        throw x;
+      }
+      if (msg.seqid != seqid_) {
+        throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "create_type failed: out of sequence response");
+      }
+      create_type_result result = new create_type_result();
+      result.read(iprot_);
+      iprot_.readMessageEnd();
+      if (result.isSetSuccess()) {
+        return result.success;
+      }
+      if (result.o1 != null) {
+        throw result.o1;
+      }
+      if (result.o2 != null) {
+        throw result.o2;
+      }
+      if (result.o3 != null) {
+        throw result.o3;
+      }
+      throw new TApplicationException(TApplicationException.MISSING_RESULT, "create_type failed: unknown result");
+    }
+
+    public boolean drop_type(String type) throws MetaException, NoSuchObjectException, TException
+    {
+      send_drop_type(type);
+      return recv_drop_type();
+    }
+
+    public void send_drop_type(String type) throws TException
+    {
+      oprot_.writeMessageBegin(new TMessage("drop_type", TMessageType.CALL, ++seqid_));
+      drop_type_args args = new drop_type_args();
+      args.setType(type);
+      args.write(oprot_);
+      oprot_.writeMessageEnd();
+      oprot_.getTransport().flush();
+    }
+
+    public boolean recv_drop_type() throws MetaException, NoSuchObjectException, TException
+    {
+      TMessage msg = iprot_.readMessageBegin();
+      if (msg.type == TMessageType.EXCEPTION) {
+        TApplicationException x = TApplicationException.read(iprot_);
+        iprot_.readMessageEnd();
+        throw x;
+      }
+      if (msg.seqid != seqid_) {
+        throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "drop_type failed: out of sequence response");
+      }
+      drop_type_result result = new drop_type_result();
+      result.read(iprot_);
+      iprot_.readMessageEnd();
+      if (result.isSetSuccess()) {
+        return result.success;
+      }
+      if (result.o1 != null) {
+        throw result.o1;
+      }
+      if (result.o2 != null) {
+        throw result.o2;
+      }
+      throw new TApplicationException(TApplicationException.MISSING_RESULT, "drop_type failed: unknown result");
+    }
+
+    public Map<String,Type> get_type_all(String name) throws MetaException, TException
+    {
+      send_get_type_all(name);
+      return recv_get_type_all();
+    }
+
+    public void send_get_type_all(String name) throws TException
+    {
+      oprot_.writeMessageBegin(new TMessage("get_type_all", TMessageType.CALL, ++seqid_));
+      get_type_all_args args = new get_type_all_args();
+      args.setName(name);
+      args.write(oprot_);
+      oprot_.writeMessageEnd();
+      oprot_.getTransport().flush();
+    }
+
+    public Map<String,Type> recv_get_type_all() throws MetaException, TException
+    {
+      TMessage msg = iprot_.readMessageBegin();
+      if (msg.type == TMessageType.EXCEPTION) {
+        TApplicationException x = TApplicationException.read(iprot_);
+        iprot_.readMessageEnd();
+        throw x;
+      }
+      if (msg.seqid != seqid_) {
+        throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "get_type_all failed: out of sequence response");
+      }
+      get_type_all_result result = new get_type_all_result();
+      result.read(iprot_);
+      iprot_.readMessageEnd();
+      if (result.isSetSuccess()) {
+        return result.success;
+      }
+      if (result.o2 != null) {
+        throw result.o2;
+      }
+      throw new TApplicationException(TApplicationException.MISSING_RESULT, "get_type_all failed: unknown result");
+    }
+
+    public List<FieldSchema> get_fields(String db_name, String table_name) throws MetaException, UnknownTableException, UnknownDBException, TException
+    {
+      send_get_fields(db_name, table_name);
+      return recv_get_fields();
+    }
+
+    public void send_get_fields(String db_name, String table_name) throws TException
+    {
+      oprot_.writeMessageBegin(new TMessage("get_fields", TMessageType.CALL, ++seqid_));
+      get_fields_args args = new get_fields_args();
+      args.setDb_name(db_name);
+      args.setTable_name(table_name);
+      args.write(oprot_);
+      oprot_.writeMessageEnd();
+      oprot_.getTransport().flush();
+    }
+
+    public List<FieldSchema> recv_get_fields() throws MetaException, UnknownTableException, UnknownDBException, TException
+    {
+      TMessage msg = iprot_.readMessageBegin();
+      if (msg.type == TMessageType.EXCEPTION) {
+        TApplicationException x = TApplicationException.read(iprot_);
+        iprot_.readMessageEnd();
+        throw x;
+      }
+      if (msg.seqid != seqid_) {
+        throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "get_fields failed: out of sequence response");
+      }
+      get_fields_result result = new get_fields_result();
+      result.read(iprot_);
+      iprot_.readMessageEnd();
+      if (result.isSetSuccess()) {
+        return result.success;
+      }
+      if (result.o1 != null) {
+        throw result.o1;
+      }
+      if (result.o2 != null) {
+        throw result.o2;
+      }
+      if (result.o3 != null) {
+        throw result.o3;
+      }
+      throw new TApplicationException(TApplicationException.MISSING_RESULT, "get_fields failed: unknown result");
+    }
+
+    public List<FieldSchema> get_schema(String db_name, String table_name) throws MetaException, UnknownTableException, UnknownDBException, TException
+    {
+      send_get_schema(db_name, table_name);
+      return recv_get_schema();
+    }
+
+    public void send_get_schema(String db_name, String table_name) throws TException
+    {
+      oprot_.writeMessageBegin(new TMessage("get_schema", TMessageType.CALL, ++seqid_));
+      get_schema_args args = new get_schema_args();
+      args.setDb_name(db_name);
+      args.setTable_name(table_name);
+      args.write(oprot_);
+      oprot_.writeMessageEnd();
+      oprot_.getTransport().flush();
+    }
+
+    public List<FieldSchema> recv_get_schema() throws MetaException, UnknownTableException, UnknownDBException, TException
+    {
+      TMessage msg = iprot_.readMessageBegin();
+      if (msg.type == TMessageType.EXCEPTION) {
+        TApplicationException x = TApplicationException.read(iprot_);
+        iprot_.readMessageEnd();
+        throw x;
+      }
+      if (msg.seqid != seqid_) {
+        throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "get_schema failed: out of sequence response");
+      }
+      get_schema_result result = new get_schema_result();
+      result.read(iprot_);
+      iprot_.readMessageEnd();
+      if (result.isSetSuccess()) {
+        return result.success;
+      }
+      if (result.o1 != null) {
+        throw result.o1;
+      }
+      if (result.o2 != null) {
+        throw result.o2;
+      }
+      if (result.o3 != null) {
+        throw result.o3;
+      }
+      throw new TApplicationException(TApplicationException.MISSING_RESULT, "get_schema failed: unknown result");
+    }
+
+    public void create_table(Table tbl) throws AlreadyExistsException, InvalidObjectException, MetaException, NoSuchObjectException, TException
+    {
+      send_create_table(tbl);
+      recv_create_table();
+    }
+
+    public void send_create_table(Table tbl) throws TException
+    {
+      oprot_.writeMessageBegin(new TMessage("create_table", TMessageType.CALL, ++seqid_));
+      create_table_args args = new create_table_args();
+      args.setTbl(tbl);
+      args.write(oprot_);
+      oprot_.writeMessageEnd();
+      oprot_.getTransport().flush();
+    }
+
+    public void recv_create_table() throws AlreadyExistsException, InvalidObjectException, MetaException, NoSuchObjectException, TException
+    {
+      TMessage msg = iprot_.readMessageBegin();
+      if (msg.type == TMessageType.EXCEPTION) {
+        TApplicationException x = TApplicationException.read(iprot_);
+        iprot_.readMessageEnd();
+        throw x;
+      }
+      if (msg.seqid != seqid_) {
+        throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "create_table failed: out of sequence response");
+      }
+      create_table_result result = new create_table_result();
+      result.read(iprot_);
+      iprot_.readMessageEnd();
+      if (result.o1 != null) {
+        throw result.o1;
+      }
+      if (result.o2 != null) {
+        throw result.o2;
+      }
+      if (result.o3 != null) {
+        throw result.o3;
+      }
+      if (result.o4 != null) {
+        throw result.o4;
+      }
+      return;
+    }
+
+    public void drop_table(String dbname, String name, boolean deleteData) throws NoSuchObjectException, MetaException, TException
+    {
+      send_drop_table(dbname, name, deleteData);
+      recv_drop_table();
+    }
+
+    public void send_drop_table(String dbname, String name, boolean deleteData) throws TException
+    {
+      oprot_.writeMessageBegin(new TMessage("drop_table", TMessageType.CALL, ++seqid_));
+      drop_table_args args = new drop_table_args();
+      args.setDbname(dbname);
+      args.setName(name);
+      args.setDeleteData(deleteData);
+      args.write(oprot_);
+      oprot_.writeMessageEnd();
+      oprot_.getTransport().flush();
+    }
+
+    public void recv_drop_table() throws NoSuchObjectException, MetaException, TException
+    {
+      TMessage msg = iprot_.readMessageBegin();
+      if (msg.type == TMessageType.EXCEPTION) {
+        TApplicationException x = TApplicationException.read(iprot_);
+        iprot_.readMessageEnd();
+        throw x;
+      }
+      if (msg.seqid != seqid_) {
+        throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "drop_table failed: out of sequence response");
+      }
+      drop_table_result result = new drop_table_result();
+      result.read(iprot_);
+      iprot_.readMessageEnd();
+      if (result.o1 != null) {
+        throw result.o1;
+      }
+      if (result.o3 != null) {
+        throw result.o3;
+      }
+      return;
+    }
+
+    public List<String> get_tables(String db_name, String pattern) throws MetaException, TException
+    {
+      send_get_tables(db_name, pattern);
+      return recv_get_tables();
+    }
+
+    public void send_get_tables(String db_name, String pattern) throws TException
+    {
+      oprot_.writeMessageBegin(new TMessage("get_tables", TMessageType.CALL, ++seqid_));
+      get_tables_args args = new get_tables_args();
+      args.setDb_name(db_name);
+      args.setPattern(pattern);
+      args.write(oprot_);
+      oprot_.writeMessageEnd();
+      oprot_.getTransport().flush();
+    }
+
+    public List<String> recv_get_tables() throws MetaException, TException
+    {
+      TMessage msg = iprot_.readMessageBegin();
+      if (msg.type == TMessageType.EXCEPTION) {
+        TApplicationException x = TApplicationException.read(iprot_);
+        iprot_.readMessageEnd();
+        throw x;
+      }
+      if (msg.seqid != seqid_) {
+        throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "get_tables failed: out of sequence response");
+      }
+      get_tables_result result = new get_tables_result();
+      result.read(iprot_);
+      iprot_.readMessageEnd();
+      if (result.isSetSuccess()) {
+        return result.success;
+      }
+      if (result.o1 != null) {
+        throw result.o1;
+      }
+      throw new TApplicationException(TApplicationException.MISSING_RESULT, "get_tables failed: unknown result");
+    }
+
+    public List<String> get_all_tables(String db_name) throws MetaException, TException
+    {
+      send_get_all_tables(db_name);
+      return recv_get_all_tables();
+    }
+
+    public void send_get_all_tables(String db_name) throws TException
+    {
+      oprot_.writeMessageBegin(new TMessage("get_all_tables", TMessageType.CALL, ++seqid_));
+      get_all_tables_args args = new get_all_tables_args();
+      args.setDb_name(db_name);
+      args.write(oprot_);
+      oprot_.writeMessageEnd();
+      oprot_.getTransport().flush();
+    }
+
+    public List<String> recv_get_all_tables() throws MetaException, TException
+    {
+      TMessage msg = iprot_.readMessageBegin();
+      if (msg.type == TMessageType.EXCEPTION) {
+        TApplicationException x = TApplicationException.read(iprot_);
+        iprot_.readMessageEnd();
+        throw x;
+      }
+      if (msg.seqid != seqid_) {
+        throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "get_all_tables failed: out of sequence response");
+      }
+      get_all_tables_result result = new get_all_tables_result();
+      result.read(iprot_);
+      iprot_.readMessageEnd();
+      if (result.isSetSuccess()) {
+        return result.success;
+      }
+      if (result.o1 != null) {
+        throw result.o1;
+      }
+      throw new TApplicationException(TApplicationException.MISSING_RESULT, "get_all_tables failed: unknown result");
+    }
+
+    public Table get_table(String dbname, String tbl_name) throws MetaException, NoSuchObjectException, TException
+    {
+      send_get_table(dbname, tbl_name);
+      return recv_get_table();
+    }
+
+    public void send_get_table(String dbname, String tbl_name) throws TException
+    {
+      oprot_.writeMessageBegin(new TMessage("get_table", TMessageType.CALL, ++seqid_));
+      get_table_args args = new get_table_args();
+      args.setDbname(dbname);
+      args.setTbl_name(tbl_name);
+      args.write(oprot_);
+      oprot_.writeMessageEnd();
+      oprot_.getTransport().flush();
+    }
+
+    public Table recv_get_table() throws MetaException, NoSuchObjectException, TException
+    {
+      TMessage msg = iprot_.readMessageBegin();
+      if (msg.type == TMessageType.EXCEPTION) {
+        TApplicationException x = TApplicationException.read(iprot_);
+        iprot_.readMessageEnd();
+        throw x;
+      }
+      if (msg.seqid != seqid_) {
+        throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "get_table failed: out of sequence response");
+      }
+      get_table_result result = new get_table_result();
+      result.read(iprot_);
+      iprot_.readMessageEnd();
+      if (result.isSetSuccess()) {
+        return result.success;
+      }
+      if (result.o1 != null) {
+        throw result.o1;
+      }
+      if (result.o2 != null) {
+        throw result.o2;
+      }
+      throw new TApplicationException(TApplicationException.MISSING_RESULT, "get_table failed: unknown result");
+    }
+
+    public void alter_table(String dbname, String tbl_name, Table new_tbl) throws InvalidOperationException, MetaException, TException
+    {
+      send_alter_table(dbname, tbl_name, new_tbl);
+      recv_alter_table();
+    }
+
+    public void send_alter_table(String dbname, String tbl_name, Table new_tbl) throws TException
+    {
+      oprot_.writeMessageBegin(new TMessage("alter_table", TMessageType.CALL, ++seqid_));
+      alter_table_args args = new alter_table_args();
+      args.setDbname(dbname);
+      args.setTbl_name(tbl_name);
+      args.setNew_tbl(new_tbl);
+      args.write(oprot_);
+      oprot_.writeMessageEnd();
+      oprot_.getTransport().flush();
+    }
+
+    public void recv_alter_table() throws InvalidOperationException, MetaException, TException
+    {
+      TMessage msg = iprot_.readMessageBegin();
+      if (msg.type == TMessageType.EXCEPTION) {
+        TApplicationException x = TApplicationException.read(iprot_);
+        iprot_.readMessageEnd();
+        throw x;
+      }
+      if (msg.seqid != seqid_) {
+        throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "alter_table failed: out of sequence response");
+      }
+      alter_table_result result = new alter_table_result();
+      result.read(iprot_);
+      iprot_.readMessageEnd();
+      if (result.o1 != null) {
+        throw result.o1;
+      }
+      if (result.o2 != null) {
+        throw result.o2;
+      }
+      return;
+    }
+
+    public Partition add_partition(Partition new_part) throws InvalidObjectException, AlreadyExistsException, MetaException, TException
+    {
+      send_add_partition(new_part);
+      return recv_add_partition();
+    }
+
+    public void send_add_partition(Partition new_part) throws TException
+    {
+      oprot_.writeMessageBegin(new TMessage("add_partition", TMessageType.CALL, ++seqid_));
+      add_partition_args args = new add_partition_args();
+      args.setNew_part(new_part);
+      args.write(oprot_);
+      oprot_.writeMessageEnd();
+      oprot_.getTransport().flush();
+    }
+
+    public Partition recv_add_partition() throws InvalidObjectException, AlreadyExistsException, MetaException, TException
+    {
+      TMessage msg = iprot_.readMessageBegin();
+      if (msg.type == TMessageType.EXCEPTION) {
+        TApplicationException x = TApplicationException.read(iprot_);
+        iprot_.readMessageEnd();
+        throw x;
+      }
+      if (msg.seqid != seqid_) {
+        throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "add_partition failed: out of sequence response");
+      }
+      add_partition_result result = new add_partition_result();
+      result.read(iprot_);
+      iprot_.readMessageEnd();
+      if (result.isSetSuccess()) {
+        return result.success;
+      }
+      if (result.o1 != null) {
+        throw result.o1;
+      }
+      if (result.o2 != null) {
+        throw result.o2;
+      }
+      if (result.o3 != null) {
+        throw result.o3;
+      }
+      throw new TApplicationException(TApplicationException.MISSING_RESULT, "add_partition failed: unknown result");
+    }
+
+    public Partition append_partition(String db_name, String tbl_name, List<String> part_vals) throws InvalidObjectException, AlreadyExistsException, MetaException, TException
+    {
+      send_append_partition(db_name, tbl_name, part_vals);
+      return recv_append_partition();
+    }
+
+    public void send_append_partition(String db_name, String tbl_name, List<String> part_vals) throws TException
+    {
+      oprot_.writeMessageBegin(new TMessage("append_partition", TMessageType.CALL, ++seqid_));
+      append_partition_args args = new append_partition_args();
+      args.setDb_name(db_name);
+      args.setTbl_name(tbl_name);
+      args.setPart_vals(part_vals);
+      args.write(oprot_);
+      oprot_.writeMessageEnd();
+      oprot_.getTransport().flush();
+    }
+
+    public Partition recv_append_partition() throws InvalidObjectException, AlreadyExistsException, MetaException, TException
+    {
+      TMessage msg = iprot_.readMessageBegin();
+      if (msg.type == TMessageType.EXCEPTION) {
+        TApplicationException x = TApplicationException.read(iprot_);
+        iprot_.readMessageEnd();
+        throw x;
+      }
+      if (msg.seqid != seqid_) {
+        throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "append_partition failed: out of sequence response");
+      }
+      append_partition_result result = new append_partition_result();
+      result.read(iprot_);
+      iprot_.readMessageEnd();
+      if (result.isSetSuccess()) {
+        return result.success;
+      }
+      if (result.o1 != null) {
+        throw result.o1;
+      }
+      if (result.o2 != null) {
+        throw result.o2;
+      }
+      if (result.o3 != null) {
+        throw result.o3;
+      }
+      throw new TApplicationException(TApplicationException.MISSING_RESULT, "append_partition failed: unknown result");
+    }
+
+    public Partition append_partition_by_name(String db_name, String tbl_name, String part_name) throws InvalidObjectException, AlreadyExistsException, MetaException, TException
+    {
+      send_append_partition_by_name(db_name, tbl_name, part_name);
+      return recv_append_partition_by_name();
+    }
+
+    public void send_append_partition_by_name(String db_name, String tbl_name, String part_name) throws TException
+    {
+      oprot_.writeMessageBegin(new TMessage("append_partition_by_name", TMessageType.CALL, ++seqid_));
+      append_partition_by_name_args args = new append_partition_by_name_args();
+      args.setDb_name(db_name);
+      args.setTbl_name(tbl_name);
+      args.setPart_name(part_name);
+      args.write(oprot_);
+      oprot_.writeMessageEnd();
+      oprot_.getTransport().flush();
+    }
+
+    public Partition recv_append_partition_by_name() throws InvalidObjectException, AlreadyExistsException, MetaException, TException
+    {
+      TMessage msg = iprot_.readMessageBegin();
+      if (msg.type == TMessageType.EXCEPTION) {
+        TApplicationException x = TApplicationException.read(iprot_);
+        iprot_.readMessageEnd();
+        throw x;
+      }
+      if (msg.seqid != seqid_) {
+        throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "append_partition_by_name failed: out of sequence response");
+      }
+      append_partition_by_name_result result = new append_partition_by_name_result();
+      result.read(iprot_);
+      iprot_.readMessageEnd();
+      if (result.isSetSuccess()) {
+        return result.success;
+      }
+      if (result.o1 != null) {
+        throw result.o1;
+      }
+      if (result.o2 != null) {
+        throw result.o2;
+      }
+      if (result.o3 != null) {
+        throw result.o3;
+      }
+      throw new TApplicationException(TApplicationException.MISSING_RESULT, "append_partition_by_name failed: unknown result");
+    }
+
+    public boolean drop_partition(String db_name, String tbl_name, List<String> part_vals, boolean deleteData) throws NoSuchObjectException, MetaException, TException
+    {
+      send_drop_partition(db_name, tbl_name, part_vals, deleteData);
+      return recv_drop_partition();
+    }
+
+    public void send_drop_partition(String db_name, String tbl_name, List<String> part_vals, boolean deleteData) throws TException
+    {
+      oprot_.writeMessageBegin(new TMessage("drop_partition", TMessageType.CALL, ++seqid_));
+      drop_partition_args args = new drop_partition_args();
+      args.setDb_name(db_name);
+      args.setTbl_name(tbl_name);
+      args.setPart_vals(part_vals);
+      args.setDeleteData(deleteData);
+      args.write(oprot_);
+      oprot_.writeMessageEnd();
+      oprot_.getTransport().flush();
+    }
+
+    public boolean recv_drop_partition() throws NoSuchObjectException, MetaException, TException
+    {
+      TMessage msg = iprot_.readMessageBegin();
+      if (msg.type == TMessageType.EXCEPTION) {
+        TApplicationException x = TApplicationException.read(iprot_);
+        iprot_.readMessageEnd();
+        throw x;
+      }
+      if (msg.seqid != seqid_) {
+        throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "drop_partition failed: out of sequence response");
+      }
+      drop_partition_result result = new drop_partition_result();
+      result.read(iprot_);
+      iprot_.readMessageEnd();
+      if (result.isSetSuccess()) {
+        return result.success;
+      }
+      if (result.o1 != null) {
+        throw result.o1;
+      }
+      if (result.o2 != null) {
+        throw result.o2;
+      }
+      throw new TApplicationException(TApplicationException.MISSING_RESULT, "drop_partition failed: unknown result");
+    }
+
+    public boolean drop_partition_by_name(String db_name, String tbl_name, String part_name, boolean deleteData) throws NoSuchObjectException, MetaException, TException
+    {
+      send_drop_partition_by_name(db_name, tbl_name, part_name, deleteData);
+      return recv_drop_partition_by_name();
+    }
+
+    public void send_drop_partition_by_name(String db_name, String tbl_name, String part_name, boolean deleteData) throws TException
+    {
+      oprot_.writeMessageBegin(new TMessage("drop_partition_by_name", TMessageType.CALL, ++seqid_));
+      drop_partition_by_name_args args = new drop_partition_by_name_args();
+      args.setDb_name(db_name);
+      args.setTbl_name(tbl_name);
+      args.setPart_name(part_name);
+      args.setDeleteData(deleteData);
+      args.write(oprot_);
+      oprot_.writeMessageEnd();
+      oprot_.getTransport().flush();
+    }
+
+    public boolean recv_drop_partition_by_name() throws NoSuchObjectException, MetaException, TException
+    {
+      TMessage msg = iprot_.readMessageBegin();
+      if (msg.type == TMessageType.EXCEPTION) {
+        TApplicationException x = TApplicationException.read(iprot_);
+        iprot_.readMessageEnd();
+        throw x;
+      }
+      if (msg.seqid != seqid_) {
+        throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "drop_partition_by_name failed: out of sequence response");
+      }
+      drop_partition_by_name_result result = new drop_partition_by_name_result();
+      result.read(iprot_);
+      iprot_.readMessageEnd();
+      if (result.isSetSuccess()) {
+        return result.success;
+      }
+      if (result.o1 != null) {
+        throw result.o1;
+      }
+      if (result.o2 != null) {
+        throw result.o2;
+      }
+      throw new TApplicationException(TApplicationException.MISSING_RESULT, "drop_partition_by_name failed: unknown result");
+    }
+
+    public Partition get_partition(String db_name, String tbl_name, List<String> part_vals) throws MetaException, NoSuchObjectException, TException
+    {
+      send_get_partition(db_name, tbl_name, part_vals);
+      return recv_get_partition();
+    }
+
+    public void send_get_partition(String db_name, String tbl_name, List<String> part_vals) throws TException
+    {
+      oprot_.writeMessageBegin(new TMessage("get_partition", TMessageType.CALL, ++seqid_));
+      get_partition_args args = new get_partition_args();
+      args.setDb_name(db_name);
+      args.setTbl_name(tbl_name);
+      args.setPart_vals(part_vals);
+      args.write(oprot_);
+      oprot_.writeMessageEnd();
+      oprot_.getTransport().flush();
+    }
+
+    public Partition recv_get_partition() throws MetaException, NoSuchObjectException, TException
+    {
+      TMessage msg = iprot_.readMessageBegin();
+      if (msg.type == TMessageType.EXCEPTION) {
+        TApplicationException x = TApplicationException.read(iprot_);
+        iprot_.readMessageEnd();
+        throw x;
+      }
+      if (msg.seqid != seqid_) {
+        throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "get_partition failed: out of sequence response");
+      }
+      get_partition_result result = new get_partition_result();
+      result.read(iprot_);
+      iprot_.readMessageEnd();
+      if (result.isSetSuccess()) {
+        return result.success;
+      }
+      if (result.o1 != null) {
+        throw result.o1;
+      }
+      if (result.o2 != null) {
+        throw result.o2;
+      }
+      throw new TApplicationException(TApplicationException.MISSING_RESULT, "get_partition failed: unknown result");
+    }
+
+    public Partition get_partition_by_name(String db_name, String tbl_name, String part_name) throws MetaException, NoSuchObjectException, TException
+    {
+      send_get_partition_by_name(db_name, tbl_name, part_name);
+      return recv_get_partition_by_name();
+    }
+
+    public void send_get_partition_by_name(String db_name, String tbl_name, String part_name) throws TException
+    {
+      oprot_.writeMessageBegin(new TMessage("get_partition_by_name", TMessageType.CALL, ++seqid_));
+      get_partition_by_name_args args = new get_partition_by_name_args();
+      args.setDb_name(db_name);
+      args.setTbl_name(tbl_name);
+      args.setPart_name(part_name);
+      args.write(oprot_);
+      oprot_.writeMessageEnd();
+      oprot_.getTransport().flush();
+    }
+
+    public Partition recv_get_partition_by_name() throws MetaException, NoSuchObjectException, TException
+    {
+      TMessage msg = iprot_.readMessageBegin();
+      if (msg.type == TMessageType.EXCEPTION) {
+        TApplicationException x = TApplicationException.read(iprot_);
+        iprot_.readMessageEnd();
+        throw x;
+      }
+      if (msg.seqid != seqid_) {
+        throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "get_partition_by_name failed: out of sequence response");
+      }
+      get_partition_by_name_result result = new get_partition_by_name_result();
+      result.read(iprot_);
+      iprot_.readMessageEnd();
+      if (result.isSetSuccess()) {
+        return result.success;
+      }
+      if (result.o1 != null) {
+        throw result.o1;
+      }
+      if (result.o2 != null) {
+        throw result.o2;
+      }
+      throw new TApplicationException(TApplicationException.MISSING_RESULT, "get_partition_by_name failed: unknown result");
+    }
+
+    public List<Partition> get_partitions(String db_name, String tbl_name, short max_parts) throws NoSuchObjectException, MetaException, TException
+    {
+      send_get_partitions(db_name, tbl_name, max_parts);
+      return recv_get_partitions();
+    }
+
+    public void send_get_partitions(String db_name, String tbl_name, short max_parts) throws TException
+    {
+      oprot_.writeMessageBegin(new TMessage("get_partitions", TMessageType.CALL, ++seqid_));
+      get_partitions_args args = new get_partitions_args();
+      args.setDb_name(db_name);
+      args.setTbl_name(tbl_name);
+      args.setMax_parts(max_parts);
+      args.write(oprot_);
+      oprot_.writeMessageEnd();
+      oprot_.getTransport().flush();
+    }
+
+    public List<Partition> recv_get_partitions() throws NoSuchObjectException, MetaException, TException
+    {
+      TMessage msg = iprot_.readMessageBegin();
+      if (msg.type == TMessageType.EXCEPTION) {
+        TApplicationException x = TApplicationException.read(iprot_);
+        iprot_.readMessageEnd();
+        throw x;
+      }
+      if (msg.seqid != seqid_) {
+        throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "get_partitions failed: out of sequence response");
+      }
+      get_partitions_result result = new get_partitions_result();
+      result.read(iprot_);
+      iprot_.readMessageEnd();
+      if (result.isSetSuccess()) {
+        return result.success;
+      }
+      if (result.o1 != null) {
+        throw result.o1;
+      }
+      if (result.o2 != null) {
+        throw result.o2;
+      }
+      throw new TApplicationException(TApplicationException.MISSING_RESULT, "get_partitions failed: unknown result");
+    }
+
+    public List<String> get_partition_names(String db_name, String tbl_name, short max_parts) throws MetaException, TException
+    {
+      send_get_partition_names(db_name, tbl_name, max_parts);
+      return recv_get_partition_names();
+    }
+
+    public void send_get_partition_names(String db_name, String tbl_name, short max_parts) throws TException
+    {
+      oprot_.writeMessageBegin(new TMessage("get_partition_names", TMessageType.CALL, ++seqid_));
+      get_partition_names_args args = new get_partition_names_args();
+      args.setDb_name(db_name);
+      args.setTbl_name(tbl_name);
+      args.setMax_parts(max_parts);
+      args.write(oprot_);
+      oprot_.writeMessageEnd();
+      oprot_.getTransport().flush();
+    }
+
+    public List<String> recv_get_partition_names() throws MetaException, TException
+    {
+      TMessage msg = iprot_.readMessageBegin();
+      if (msg.type == TMessageType.EXCEPTION) {
+        TApplicationException x = TApplicationException.read(iprot_);
+        iprot_.readMessageEnd();
+        throw x;
+      }
+      if (msg.seqid != seqid_) {
+        throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "get_partition_names failed: out of sequence response");
+      }
+      get_partition_names_result result = new get_partition_names_result();
+      result.read(iprot_);
+      iprot_.readMessageEnd();
+      if (result.isSetSuccess()) {
+        return result.success;
+      }
+      if (result.o2 != null) {
+        throw result.o2;
+      }
+      throw new TApplicationException(TApplicationException.MISSING_RESULT, "get_partition_names failed: unknown result");
+    }
+
+    public List<Partition> get_partitions_ps(String db_name, String tbl_name, List<String> part_vals, short max_parts) throws MetaException, TException
+    {
+      send_get_partitions_ps(db_name, tbl_name, part_vals, max_parts);
+      return recv_get_partitions_ps();
+    }
+
+    public void send_get_partitions_ps(String db_name, String tbl_name, List<String> part_vals, short max_parts) throws TException
+    {
+      oprot_.writeMessageBegin(new TMessage("get_partitions_ps", TMessageType.CALL, ++seqid_));
+      get_partitions_ps_args args = new get_partitions_ps_args();
+      args.setDb_name(db_name);
+      args.setTbl_name(tbl_name);
+      args.setPart_vals(part_vals);
+      args.setMax_parts(max_parts);
+      args.write(oprot_);
+      oprot_.writeMessageEnd();
+      oprot_.getTransport().flush();
+    }
+
+    public List<Partition> recv_get_partitions_ps() throws MetaException, TException
+    {
+      TMessage msg = iprot_.readMessageBegin();
+      if (msg.type == TMessageType.EXCEPTION) {
+        TApplicationException x = TApplicationException.read(iprot_);
+        iprot_.readMessageEnd();
+        throw x;
+      }
+      if (msg.seqid != seqid_) {
+        throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "get_partitions_ps failed: out of sequence response");
+      }
+      get_partitions_ps_result result = new get_partitions_ps_result();
+      result.read(iprot_);
+      iprot_.readMessageEnd();
+      if (result.isSetSuccess()) {
+        return result.success;
+      }
+      if (result.o1 != null) {
+        throw result.o1;
+      }
+      throw new TApplicationException(TApplicationException.MISSING_RESULT, "get_partitions_ps failed: unknown result");
+    }
+
+    public List<String> get_partition_names_ps(String db_name, String tbl_name, List<String> part_vals, short max_parts) throws MetaException, TException
+    {
+      send_get_partition_names_ps(db_name, tbl_name, part_vals, max_parts);
+      return recv_get_partition_names_ps();
+    }
+
+    public void send_get_partition_names_ps(String db_name, String tbl_name, List<String> part_vals, short max_parts) throws TException
+    {
+      oprot_.writeMessageBegin(new TMessage("get_partition_names_ps", TMessageType.CALL, ++seqid_));
+      get_partition_names_ps_args args = new get_partition_names_ps_args();
+      args.setDb_name(db_name);
+      args.setTbl_name(tbl_name);
+      args.setPart_vals(part_vals);
+      args.setMax_parts(max_parts);
+      args.write(oprot_);
+      oprot_.writeMessageEnd();
+      oprot_.getTransport().flush();
+    }
+
+    public List<String> recv_get_partition_names_ps() throws MetaException, TException
+    {
+      TMessage msg = iprot_.readMessageBegin();
+      if (msg.type == TMessageType.EXCEPTION) {
+        TApplicationException x = TApplicationException.read(iprot_);
+        iprot_.readMessageEnd();
+        throw x;
+      }
+      if (msg.seqid != seqid_) {
+        throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "get_partition_names_ps failed: out of sequence response");
+      }
+      get_partition_names_ps_result result = new get_partition_names_ps_result();
+      result.read(iprot_);
+      iprot_.readMessageEnd();
+      if (result.isSetSuccess()) {
+        return result.success;
+      }
+      if (result.o1 != null) {
+        throw result.o1;
+      }
+      throw new TApplicationException(TApplicationException.MISSING_RESULT, "get_partition_names_ps failed: unknown result");
+    }
+
+    public List<Partition> get_partitions_by_filter(String db_name, String tbl_name, String filter, short max_parts) throws MetaException, NoSuchObjectException, TException
+    {
+      send_get_partitions_by_filter(db_name, tbl_name, filter, max_parts);
+      return recv_get_partitions_by_filter();
+    }
+
+    public void send_get_partitions_by_filter(String db_name, String tbl_name, String filter, short max_parts) throws TException
+    {
+      oprot_.writeMessageBegin(new TMessage("get_partitions_by_filter", TMessageType.CALL, ++seqid_));
+      get_partitions_by_filter_args args = new get_partitions_by_filter_args();
+      args.setDb_name(db_name);
+      args.setTbl_name(tbl_name);
+      args.setFilter(filter);
+      args.setMax_parts(max_parts);
+      args.write(oprot_);
+      oprot_.writeMessageEnd();
+      oprot_.getTransport().flush();
+    }
+
+    public List<Partition> recv_get_partitions_by_filter() throws MetaException, NoSuchObjectException, TException
+    {
+      TMessage msg = iprot_.readMessageBegin();
+      if (msg.type == TMessageType.EXCEPTION) {
+        TApplicationException x = TApplicationException.read(iprot_);
+        iprot_.readMessageEnd();
+        throw x;
+      }
+      if (msg.seqid != seqid_) {
+        throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "get_partitions_by_filter failed: out of sequence response");
+      }
+      get_partitions_by_filter_result result = new get_partitions_by_filter_result();
+      result.read(iprot_);
+      iprot_.readMessageEnd();
+      if (result.isSetSuccess()) {
+        return result.success;
+      }
+      if (result.o1 != null) {
+        throw result.o1;
+      }
+      if (result.o2 != null) {
+        throw result.o2;
+      }
+      throw new TApplicationException(TApplicationException.MISSING_RESULT, "get_partitions_by_filter failed: unknown result");
+    }
+
+    public void alter_partition(String db_name, String tbl_name, Partition new_part) throws InvalidOperationException, MetaException, TException
+    {
+      send_alter_partition(db_name, tbl_name, new_part);
+      recv_alter_partition();
+    }
+
+    public void send_alter_partition(String db_name, String tbl_name, Partition new_part) throws TException
+    {
+      oprot_.writeMessageBegin(new TMessage("alter_partition", TMessageType.CALL, ++seqid_));
+      alter_partition_args args = new alter_partition_args();
+      args.setDb_name(db_name);
+      args.setTbl_name(tbl_name);
+      args.setNew_part(new_part);
+      args.write(oprot_);
+      oprot_.writeMessageEnd();
+      oprot_.getTransport().flush();
+    }
+
+    public void recv_alter_partition() throws InvalidOperationException, MetaException, TException
+    {
+      TMessage msg = iprot_.readMessageBegin();
+      if (msg.type == TMessageType.EXCEPTION) {
+        TApplicationException x = TApplicationException.read(iprot_);
+        iprot_.readMessageEnd();
+        throw x;
+      }
+      if (msg.seqid != seqid_) {
+        throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "alter_partition failed: out of sequence response");
+      }
+      alter_partition_result result = new alter_partition_result();
+      result.read(iprot_);
+      iprot_.readMessageEnd();
+      if (result.o1 != null) {
+        throw result.o1;
+      }
+      if (result.o2 != null) {
+        throw result.o2;
+      }
+      return;
+    }
+
+    public String get_config_value(String name, String defaultValue) throws ConfigValSecurityException, TException
+    {
+      send_get_config_value(name, defaultValue);
+      return recv_get_config_value();
+    }
+
+    public void send_get_config_value(String name, String defaultValue) throws TException
+    {
+      oprot_.writeMessageBegin(new TMessage("get_config_value", TMessageType.CALL, ++seqid_));
+      get_config_value_args args = new get_config_value_args();
+      args.setName(name);
+      args.setDefaultValue(defaultValue);
+      args.write(oprot_);
+      oprot_.writeMessageEnd();
+      oprot_.getTransport().flush();
+    }
+
+    public String recv_get_config_value() throws ConfigValSecurityException, TException
+    {
+      TMessage msg = iprot_.readMessageBegin();
+      if (msg.type == TMessageType.EXCEPTION) {
+        TApplicationException x = TApplicationException.read(iprot_);
+        iprot_.readMessageEnd();
+        throw x;
+      }
+      if (msg.seqid != seqid_) {
+        throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "get_config_value failed: out of sequence response");
+      }
+      get_config_value_result result = new get_config_value_result();
+      result.read(iprot_);
+      iprot_.readMessageEnd();
+      if (result.isSetSuccess()) {
+        return result.success;
+      }
+      if (result.o1 != null) {
+        throw result.o1;
+      }
+      throw new TApplicationException(TApplicationException.MISSING_RESULT, "get_config_value failed: unknown result");
+    }
+
+    public List<String> partition_name_to_vals(String part_name) throws MetaException, TException
+    {
+      send_partition_name_to_vals(part_name);
+      return recv_partition_name_to_vals();
+    }
+
+    public void send_partition_name_to_vals(String part_name) throws TException
+    {
+      oprot_.writeMessageBegin(new TMessage("partition_name_to_vals", TMessageType.CALL, ++seqid_));
+      partition_name_to_vals_args args = new partition_name_to_vals_args();
+      args.setPart_name(part_name);
+      args.write(oprot_);
+      oprot_.writeMessageEnd();
+      oprot_.getTransport().flush();
+    }
+
+    public List<String> recv_partition_name_to_vals() throws MetaException, TException
+    {
+      TMessage msg = iprot_.readMessageBegin();
+      if (msg.type == TMessageType.EXCEPTION) {
+        TApplicationException x = TApplicationException.read(iprot_);
+        iprot_.readMessageEnd();
+        throw x;
+      }
+      if (msg.seqid != seqid_) {
+        throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "partition_name_to_vals failed: out of sequence response");
+      }
+      partition_name_to_vals_result result = new partition_name_to_vals_result();
+      result.read(iprot_);
+      iprot_.readMessageEnd();
+      if (result.isSetSuccess()) {
+        return result.success;
+      }
+      if (result.o1 != null) {
+        throw result.o1;
+      }
+      throw new TApplicationException(TApplicationException.MISSING_RESULT, "partition_name_to_vals failed: unknown result");
+    }
+
+    public Map<String,String> partition_name_to_spec(String part_name) throws MetaException, TException
+    {
+      send_partition_name_to_spec(part_name);
+      return recv_partition_name_to_spec();
+    }
+
+    public void send_partition_name_to_spec(String part_name) throws TException
+    {
+      oprot_.writeMessageBegin(new TMessage("partition_name_to_spec", TMessageType.CALL, ++seqid_));
+      partition_name_to_spec_args args = new partition_name_to_spec_args();
+      args.setPart_name(part_name);
+      args.write(oprot_);
+      oprot_.writeMessageEnd();
+      oprot_.getTransport().flush();
+    }
+
+    public Map<String,String> recv_partition_name_to_spec() throws MetaException, TException
+    {
+      TMessage msg = iprot_.readMessageBegin();
+      if (msg.type == TMessageType.EXCEPTION) {
+        TApplicationException x = TApplicationException.read(iprot_);
+        iprot_.readMessageEnd();
+        throw x;
+      }
+      if (msg.seqid != seqid_) {
+        throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "partition_name_to_spec failed: out of sequence response");
+      }
+      partition_name_to_spec_result result = new partition_name_to_spec_result();
+      result.read(iprot_);
+      iprot_.readMessageEnd();
+      if (result.isSetSuccess()) {
+        return result.success;
+      }
+      if (result.o1 != null) {
+        throw result.o1;
+      }
+      throw new TApplicationException(TApplicationException.MISSING_RESULT, "partition_name_to_spec failed: unknown result");
+    }
+
+    public Index add_index(Index new_index, Table index_table) throws InvalidObjectException, AlreadyExistsException, MetaException, TException
+    {
+      send_add_index(new_index, index_table);
+      return recv_add_index();
+    }
+
+    public void send_add_index(Index new_index, Table index_table) throws TException
+    {
+      oprot_.writeMessageBegin(new TMessage("add_index", TMessageType.CALL, ++seqid_));
+      add_index_args args = new add_index_args();
+      args.setNew_index(new_index);
+      args.setIndex_table(index_table);
+      args.write(oprot_);
+      oprot_.writeMessageEnd();
+      oprot_.getTransport().flush();
+    }
+
+    public Index recv_add_index() throws InvalidObjectException, AlreadyExistsException, MetaException, TException
+    {
+      TMessage msg = iprot_.readMessageBegin();
+      if (msg.type == TMessageType.EXCEPTION) {
+        TApplicationException x = TApplicationException.read(iprot_);
+        iprot_.readMessageEnd();
+        throw x;
+      }
+      if (msg.seqid != seqid_) {
+        throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "add_index failed: out of sequence response");
+      }
+      add_index_result result = new add_index_result();
+      result.read(iprot_);
+      iprot_.readMessageEnd();
+      if (result.isSetSuccess()) {
+        return result.success;
+      }
+      if (result.o1 != null) {
+        throw result.o1;
+      }
+      if (result.o2 != null) {
+        throw result.o2;
+      }
+      if (result.o3 != null) {
+        throw result.o3;
+      }
+      throw new TApplicationException(TApplicationException.MISSING_RESULT, "add_index failed: unknown result");
+    }
+
+    public void alter_index(String dbname, String base_tbl_name, String idx_name, Index new_idx) throws InvalidOperationException, MetaException, TException
+    {
+      send_alter_index(dbname, base_tbl_name, idx_name, new_idx);
+      recv_alter_index();
+    }
+
+    public void send_alter_index(String dbname, String base_tbl_name, String idx_name, Index new_idx) throws TException
+    {
+      oprot_.writeMessageBegin(new TMessage("alter_index", TMessageType.CALL, ++seqid_));
+      alter_index_args args = new alter_index_args();
+      args.setDbname(dbname);
+      args.setBase_tbl_name(base_tbl_name);
+      args.setIdx_name(idx_name);
+      args.setNew_idx(new_idx);
+      args.write(oprot_);
+      oprot_.writeMessageEnd();
+      oprot_.getTransport().flush();
+    }
+
+    public void recv_alter_index() throws InvalidOperationException, MetaException, TException
+    {
+      TMessage msg = iprot_.readMessageBegin();
+      if (msg.type == TMessageType.EXCEPTION) {
+        TApplicationException x = TApplicationException.read(iprot_);
+        iprot_.readMessageEnd();
+        throw x;
+      }
+      if (msg.seqid != seqid_) {
+        throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "alter_index failed: out of sequence response");
+      }
+      alter_index_result result = new alter_index_result();
+      result.read(iprot_);
+      iprot_.readMessageEnd();
+      if (result.o1 != null) {
+        throw result.o1;
+      }
+      if (result.o2 != null) {
+        throw result.o2;
+      }
+      return;
+    }
+
+    public boolean drop_index_by_name(String db_name, String tbl_name, String index_name, boolean deleteData) throws NoSuchObjectException, MetaException, TException
+    {
+      send_drop_index_by_name(db_name, tbl_name, index_name, deleteData);
+      return recv_drop_index_by_name();
+    }
+
+    public void send_drop_index_by_name(String db_name, String tbl_name, String index_name, boolean deleteData) throws TException
+    {
+      oprot_.writeMessageBegin(new TMessage("drop_index_by_name", TMessageType.CALL, ++seqid_));
+      drop_index_by_name_args args = new drop_index_by_name_args();
+      args.setDb_name(db_name);
+      args.setTbl_name(tbl_name);
+      args.setIndex_name(index_name);
+      args.setDeleteData(deleteData);
+      args.write(oprot_);
+      oprot_.writeMessageEnd();
+      oprot_.getTransport().flush();
+    }
+
+    public boolean recv_drop_index_by_name() throws NoSuchObjectException, MetaException, TException
+    {
+      TMessage msg = iprot_.readMessageBegin();
+      if (msg.type == TMessageType.EXCEPTION) {
+        TApplicationException x = TApplicationException.read(iprot_);
+        iprot_.readMessageEnd();
+        throw x;
+      }
+      if (msg.seqid != seqid_) {
+        throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "drop_index_by_name failed: out of sequence response");
+      }
+      drop_index_by_name_result result = new drop_index_by_name_result();
+      result.read(iprot_);
+      iprot_.readMessageEnd();
+      if (result.isSetSuccess()) {
+        return result.success;
+      }
+      if (result.o1 != null) {
+        throw result.o1;
+      }
+      if (result.o2 != null) {
+        throw result.o2;
+      }
+      throw new TApplicationException(TApplicationException.MISSING_RESULT, "drop_index_by_name failed: unknown result");
+    }
+
+    public Index get_index_by_name(String db_name, String tbl_name, String index_name) throws MetaException, NoSuchObjectException, TException
+    {
+      send_get_index_by_name(db_name, tbl_name, index_name);
+      return recv_get_index_by_name();
+    }
+
+    public void send_get_index_by_name(String db_name, String tbl_name, String index_name) throws TException
+    {
+      oprot_.writeMessageBegin(new TMessage("get_index_by_name", TMessageType.CALL, ++seqid_));
+      get_index_by_name_args args = new get_index_by_name_args();
+      args.setDb_name(db_name);
+      args.setTbl_name(tbl_name);
+      args.setIndex_name(index_name);
+      args.write(oprot_);
+      oprot_.writeMessageEnd();
+      oprot_.getTransport().flush();
+    }
+
+    public Index recv_get_index_by_name() throws MetaException, NoSuchObjectException, TException
+    {
+      TMessage msg = iprot_.readMessageBegin();
+      if (msg.type == TMessageType.EXCEPTION) {
+        TApplicationException x = TApplicationException.read(iprot_);
+        iprot_.readMessageEnd();
+        throw x;
+      }
+      if (msg.seqid != seqid_) {
+        throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "get_index_by_name failed: out of sequence response");
+      }
+      get_index_by_name_result result = new get_index_by_name_result();
+      result.read(iprot_);
+      iprot_.readMessageEnd();
+      if (result.isSetSuccess()) {
+        return result.success;
+      }
+      if (result.o1 != null) {
+        throw result.o1;
+      }
+      if (result.o2 != null) {
+        throw result.o2;
+      }
+      throw new TApplicationException(TApplicationException.MISSING_RESULT, "get_index_by_name failed: unknown result");
+    }
+
+    public List<Index> get_indexes(String db_name, String tbl_name, short max_indexes) throws NoSuchObjectException, MetaException, TException
+    {
+      send_get_indexes(db_name, tbl_name, max_indexes);
+      return recv_get_indexes();
+    }
+
+    public void send_get_indexes(String db_name, String tbl_name, short max_indexes) throws TException
+    {
+      oprot_.writeMessageBegin(new TMessage("get_indexes", TMessageType.CALL, ++seqid_));
+      get_indexes_args args = new get_indexes_args();
+      args.setDb_name(db_name);
+      args.setTbl_name(tbl_name);
+      args.setMax_indexes(max_indexes);
+      args.write(oprot_);
+      oprot_.writeMessageEnd();
+      oprot_.getTransport().flush();
+    }
+
+    public List<Index> recv_get_indexes() throws NoSuchObjectException, MetaException, TException
+    {
+      TMessage msg = iprot_.readMessageBegin();
+      if (msg.type == TMessageType.EXCEPTION) {
+        TApplicationException x = TApplicationException.read(iprot_);
+        iprot_.readMessageEnd();
+        throw x;
+      }
+      if (msg.seqid != seqid_) {
+        throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "get_indexes failed: out of sequence response");
+      }
+      get_indexes_result result = new get_indexes_result();
+      result.read(iprot_);
+      iprot_.readMessageEnd();
+      if (result.isSetSuccess()) {
+        return result.success;
+      }
+      if (result.o1 != null) {
+        throw result.o1;
+      }
+      if (result.o2 != null) {
+        throw result.o2;
+      }
+      throw new TApplicationException(TApplicationException.MISSING_RESULT, "get_indexes failed: unknown result");
+    }
+
+    public List<String> get_index_names(String db_name, String tbl_name, short max_indexes) throws MetaException, TException
+    {
+      send_get_index_names(db_name, tbl_name, max_indexes);
+      return recv_get_index_names();
+    }
+
+    public void send_get_index_names(String db_name, String tbl_name, short max_indexes) throws TException
+    {
+      oprot_.writeMessageBegin(new TMessage("get_index_names", TMessageType.CALL, ++seqid_));
+      get_index_names_args args = new get_index_names_args();
+      args.setDb_name(db_name);
+      args.setTbl_name(tbl_name);
+      args.setMax_indexes(max_indexes);
+      args.write(oprot_);
+      oprot_.writeMessageEnd();
+      oprot_.getTransport().flush();
+    }
+
+    public List<String> recv_get_index_names() throws MetaException, TException
+    {
+      TMessage msg = iprot_.readMessageBegin();
+      if (msg.type == TMessageType.EXCEPTION) {
+        TApplicationException x = TApplicationException.read(iprot_);
+        iprot_.readMessageEnd();
+        throw x;
+      }
+      if (msg.seqid != seqid_) {
+        throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "get_index_names failed: out of sequence response");
+      }
+      get_index_names_result result = new get_index_names_result();
+      result.read(iprot_);
+      iprot_.readMessageEnd();
+      if (result.isSetSuccess()) {
+        return result.success;
+      }
+      if (result.o2 != null) {
+        throw result.o2;
+      }
+      throw new TApplicationException(TApplicationException.MISSING_RESULT, "get_index_names failed: unknown result");
+    }
+
+  }
+  public static class AsyncClient extends com.facebook.fb303.FacebookService.AsyncClient implements AsyncIface {
+    public static class Factory implements TAsyncClientFactory<AsyncClient> {
+      private TAsyncClientManager clientManager;
+      private TProtocolFactory protocolFactory;
+      public Factory(TAsyncClientManager clientManager, TProtocolFactory protocolFactory) {
+        this.clientManager = clientManager;
+        this.protocolFactory = protocolFactory;
+      }
+      public AsyncClient getAsyncClient(TNonblockingTransport transport) {
+        return new AsyncClient(protocolFactory, clientManager, transport);
+      }
+    }
+
+    public AsyncClient(TProtocolFactory protocolFactory, TAsyncClientManager clientManager, TNonblockingTransport transport) {
+      super(protocolFactory, clientManager, transport);
+    }
+
+    public void create_database(Database database, AsyncMethodCallback<create_database_call> resultHandler) throws TException {
+      checkReady();
+      create_database_call method_call = new create_database_call(database, resultHandler, this, protocolFactory, transport);
+      manager.call(method_call);
+    }
+
+    public static class create_database_call extends TAsyncMethodCall {
+      private Database database;
+      public create_database_call(Database database, AsyncMethodCallback<create_database_call> resultHandler, TAsyncClient client, TProtocolFactory protocolFactory, TNonblockingTransport transport) throws TException {
+        super(client, protocolFactory, transport, resultHandler, false);
+        this.database = database;
+      }
+
+      public void write_args(TProtocol prot) throws TException {
+        prot.writeMessageBegin(new TMessage("create_database", TMessageType.CALL, 0));
+        create_database_args args = new create_database_args();
+        args.setDatabase(database);
+        args.write(prot);
+        prot.writeMessageEnd();
+      }
+
+      public void getResult() throws AlreadyExistsException, InvalidObjectException, MetaException, TException {
+        if (getState() != State.RESPONSE_READ) {
+          throw new IllegalStateException("Method call not finished!");
+        }
+        TMemoryInputTransport memoryTransport = new TMemoryInputTransport(getFrameBuffer().array());
+        TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
+        (new Client(prot)).recv_create_database();
+      }
+    }
+
+    public void get_database(String name, AsyncMethodCallback<get_database_call> resultHandler) throws TException {
+      checkReady();
+      get_database_call method_call = new get_database_call(name, resultHandler, this, protocolFactory, transport);
+      manager.call(method_call);
+    }
+
+    public static class get_database_call extends TAsyncMethodCall {
+      private String name;
+      public get_database_call(String name, AsyncMethodCallback<get_database_call> resultHandler, TAsyncClient client, TProtocolFactory protocolFactory, TNonblockingTransport transport) throws TException {
+        super(client, protocolFactory, transport, resultHandler, false);
+        this.name = name;
+      }
+
+      public void write_args(TProtocol prot) throws TException {
+        prot.writeMessageBegin(new TMessage("get_database", TMessageType.CALL, 0));
+        get_database_args args = new get_database_args();
+        args.setName(name);
+        args.write(prot);
+        prot.writeMessageEnd();
+      }
+
+      public Database getResult() throws NoSuchObjectException, MetaException, TException {
+        if (getState() != State.RESPONSE_READ) {
+          throw new IllegalStateException("Method call not finished!");
+        }
+        TMemoryInputTransport memoryTransport = new TMemoryInputTransport(getFrameBuffer().array());
+        TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
+        return (new Client(prot)).recv_get_database();
+      }
+    }
+
+    public void drop_database(String name, boolean deleteData, AsyncMethodCallback<drop_database_call> resultHandler) throws TException {
+      checkReady();
+      drop_database_call method_call = new drop_database_call(name, deleteData, resultHandler, this, protocolFactory, transport);
+      manager.call(method_call);
+    }
+
+    public static class drop_database_call extends TAsyncMethodCall {
+      private String name;
+      private boolean deleteData;
+      public drop_database_call(String name, boolean deleteData, AsyncMethodCallback<drop_database_call> resultHandler, TAsyncClient client, TProtocolFactory protocolFactory, TNonblockingTransport transport) throws TException {
+        super(client, protocolFactory, transport, resultHandler, false);
+        this.name = name;
+        this.deleteData = deleteData;
+      }
+
+      public void write_args(TProtocol prot) throws TException {
+        prot.writeMessageBegin(new TMessage("drop_database", TMessageType.CALL, 0));
+        drop_database_args args = new drop_database_args();
+        args.setName(name);
+        args.setDeleteData(deleteData);
+        args.write(prot);
+        prot.writeMessageEnd();
+      }
+
+      public void getResult() throws NoSuchObjectException, InvalidOperationException, MetaException, TException {
+        if (getState() != State.RESPONSE_READ) {
+          throw new IllegalStateException("Method call not finished!");
+        }
+        TMemoryInputTransport memoryTransport = new TMemoryInputTransport(getFrameBuffer().array());
+        TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
+        (new Client(prot)).recv_drop_database();
+      }
+    }
+
+    public void get_databases(String pattern, AsyncMethodCallback<get_databases_call> resultHandler) throws TException {
+      checkReady();
+      get_databases_call method_call = new get_databases_call(pattern, resultHandler, this, protocolFactory, transport);
+      manager.call(method_call);
+    }
+
+    public static class get_databases_call extends TAsyncMethodCall {
+      private String pattern;
+      public get_databases_call(String pattern, AsyncMethodCallback<get_databases_call> resultHandler, TAsyncClient client, TProtocolFactory protocolFactory, TNonblockingTransport transport) throws TException {
+        super(client, protocolFactory, transport, resultHandler, false);
+        this.pattern = pattern;
+      }
+
+      public void write_args(TProtocol prot) throws TException {
+        prot.writeMessageBegin(new TMessage("get_databases", TMessageType.CALL, 0));
+        get_databases_args args = new get_databases_args();
+        args.setPattern(pattern);
+        args.write(prot);
+        prot.writeMessageEnd();
+      }
+
+      public List<String> getResult() throws MetaException, TException {
+        if (getState() != State.RESPONSE_READ) {
+          throw new IllegalStateException("Method call not finished!");
+        }
+        TMemoryInputTransport memoryTransport = new TMemoryInputTransport(getFrameBuffer().array());
+        TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
+        return (new Client(prot)).recv_get_databases();
+      }
+    }
+
+    public void get_all_databases(AsyncMethodCallback<get_all_databases_call> resultHandler) throws TException {
+      checkReady();
+      get_all_databases_call method_call = new get_all_databases_call(resultHandler, this, protocolFactory, transport);
+      manager.call(method_call);
+    }
+
+    public static class get_all_databases_call extends TAsyncMethodCall {
+      public get_all_databases_call(AsyncMethodCallback<get_all_databases_call> resultHandler, TAsyncClient client, TProtocolFactory protocolFactory, TNonblockingTransport transport) throws TException {
+        super(client, protocolFactory, transport, resultHandler, false);
+      }
+
+      public void write_args(TProtocol prot) throws TException {
+        prot.writeMessageBegin(new TMessage("get_all_databases", TMessageType.CALL, 0));
+        get_all_databases_args args = new get_all_databases_args();
+        args.write(prot);
+        prot.writeMessageEnd();
+      }
+
+      public List<String> getResult() throws MetaException, TException {
+        if (getState() != State.RESPONSE_READ) {
+          throw new IllegalStateException("Method call not finished!");
+        }
+        TMemoryInputTransport memoryTransport = new TMemoryInputTransport(getFrameBuffer().array());
+        TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
+        return (new Client(prot)).recv_get_all_databases();
+      }
+    }
+
+    public void get_type(String name, AsyncMethodCallback<get_type_call> resultHandler) throws TException {
+      checkReady();
+      get_type_call method_call = new get_type_call(name, resultHandler, this, protocolFactory, transport);
+      manager.call(method_call);
+    }
+
+    public static class get_type_call extends TAsyncMethodCall {
+      private String name;
+      public get_type_call(String name, AsyncMethodCallback<get_type_call> resultHandler, TAsyncClient client, TProtocolFactory protocolFactory, TNonblockingTransport transport) throws TException {
+        super(client, protocolFactory, transport, resultHandler, false);
+        this.name = name;
+      }
+
+      public void write_args(TProtocol prot) throws TException {
+        prot.writeMessageBegin(new TMessage("get_type", TMessageType.CALL, 0));
+        get_type_args args = new get_type_args();
+        args.setName(name);
+        args.write(prot);
+        prot.writeMessageEnd();
+      }
+
+      public Type getResult() throws MetaException, NoSuchObjectException, TException {
+        if (getState() != State.RESPONSE_READ) {
+          throw new IllegalStateException("Method call not finished!");
+        }
+        TMemoryInputTransport memoryTransport = new TMemoryInputTransport(getFrameBuffer().array());
+        TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
+        return (new Client(prot)).recv_get_type();
+      }
+    }
+
+    public void create_type(Type type, AsyncMethodCallback<create_type_call> resultHandler) throws TException {
+      checkReady();
+      create_type_call method_call = new create_type_call(type, resultHandler, this, protocolFactory, transport);
+      manager.call(method_call);
+    }
+
+    public static class create_type_call extends TAsyncMethodCall {
+      private Type type;
+      public create_type_call(Type type, AsyncMethodCallback<create_type_call> resultHandler, TAsyncClient client, TProtocolFactory protocolFactory, TNonblockingTransport transport) throws TException {
+        super(client, protocolFactory, transport, resultHandler, false);
+        this.type = type;
+      }
+
+      public void write_args(TProtocol prot) throws TException {
+        prot.writeMessageBegin(new TMessage("create_type", TMessageType.CALL, 0));
+        create_type_args args = new create_type_args();
+        args.setType(type);
+        args.write(prot);
+        prot.writeMessageEnd();
+      }
+
+      public boolean getResult() throws AlreadyExistsException, InvalidObjectException, MetaException, TException {
+        if (getState() != State.RESPONSE_READ) {
+          throw new IllegalStateException("Method call not finished!");
+        }
+        TMemoryInputTransport memoryTransport = new TMemoryInputTransport(getFrameBuffer().array());
+        TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
+        return (new Client(prot)).recv_create_type();
+      }
+    }
+
+    public void drop_type(String type, AsyncMethodCallback<drop_type_call> resultHandler) throws TException {
+      checkReady();
+      drop_type_call method_call = new drop_type_call(type, resultHandler, this, protocolFactory, transport);
+      manager.call(method_call);
+    }
+
+    public static class drop_type_call extends TAsyncMethodCall {
+      private String type;
+      public drop_type_call(String type, AsyncMethodCallback<drop_type_call> resultHandler, TAsyncClient client, TProtocolFactory protocolFactory, TNonblockingTransport transport) throws TException {
+        super(client, protocolFactory, transport, resultHandler, false);
+        this.type = type;
+      }
+
+      public void write_args(TProtocol prot) throws TException {
+        prot.writeMessageBegin(new TMessage("drop_type", TMessageType.CALL, 0));

[... 35869 lines stripped ...]


Mime
View raw message