You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by kg...@apache.org on 2018/03/07 08:19:31 UTC
[14/22] hive git commit: HIVE-18715: Remove index support from
metastore (Zoltan Haindrich reviewed by Ashutosh Chauhan)
http://git-wip-us.apache.org/repos/asf/hive/blob/7c22d74c/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java
index 9a97d6b..8f3b848 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java
@@ -214,18 +214,6 @@ import org.slf4j.LoggerFactory;
public boolean isPartitionMarkedForEvent(String db_name, String tbl_name, Map<String,String> part_vals, PartitionEventType eventType) throws MetaException, NoSuchObjectException, UnknownDBException, UnknownTableException, UnknownPartitionException, InvalidPartitionException, org.apache.thrift.TException;
- public Index add_index(Index new_index, Table index_table) throws InvalidObjectException, AlreadyExistsException, MetaException, org.apache.thrift.TException;
-
- public void alter_index(String dbname, String base_tbl_name, String idx_name, Index new_idx) throws InvalidOperationException, MetaException, org.apache.thrift.TException;
-
- public boolean drop_index_by_name(String db_name, String tbl_name, String index_name, boolean deleteData) throws NoSuchObjectException, MetaException, org.apache.thrift.TException;
-
- public Index get_index_by_name(String db_name, String tbl_name, String index_name) throws MetaException, NoSuchObjectException, org.apache.thrift.TException;
-
- public List<Index> get_indexes(String db_name, String tbl_name, short max_indexes) throws NoSuchObjectException, MetaException, org.apache.thrift.TException;
-
- public List<String> get_index_names(String db_name, String tbl_name, short max_indexes) throws MetaException, org.apache.thrift.TException;
-
public PrimaryKeysResponse get_primary_keys(PrimaryKeysRequest request) throws MetaException, NoSuchObjectException, org.apache.thrift.TException;
public ForeignKeysResponse get_foreign_keys(ForeignKeysRequest request) throws MetaException, NoSuchObjectException, org.apache.thrift.TException;
@@ -590,18 +578,6 @@ import org.slf4j.LoggerFactory;
public void isPartitionMarkedForEvent(String db_name, String tbl_name, Map<String,String> part_vals, PartitionEventType eventType, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
- public void add_index(Index new_index, Table index_table, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
-
- public void alter_index(String dbname, String base_tbl_name, String idx_name, Index new_idx, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
-
- public void drop_index_by_name(String db_name, String tbl_name, String index_name, boolean deleteData, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
-
- public void get_index_by_name(String db_name, String tbl_name, String index_name, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
-
- public void get_indexes(String db_name, String tbl_name, short max_indexes, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
-
- public void get_index_names(String db_name, String tbl_name, short max_indexes, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
-
public void get_primary_keys(PrimaryKeysRequest request, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
public void get_foreign_keys(ForeignKeysRequest request, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
@@ -3426,190 +3402,6 @@ import org.slf4j.LoggerFactory;
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "isPartitionMarkedForEvent failed: unknown result");
}
- public Index add_index(Index new_index, Table index_table) throws InvalidObjectException, AlreadyExistsException, MetaException, org.apache.thrift.TException
- {
- send_add_index(new_index, index_table);
- return recv_add_index();
- }
-
- public void send_add_index(Index new_index, Table index_table) throws org.apache.thrift.TException
- {
- add_index_args args = new add_index_args();
- args.setNew_index(new_index);
- args.setIndex_table(index_table);
- sendBase("add_index", args);
- }
-
- public Index recv_add_index() throws InvalidObjectException, AlreadyExistsException, MetaException, org.apache.thrift.TException
- {
- add_index_result result = new add_index_result();
- receiveBase(result, "add_index");
- 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 org.apache.thrift.TApplicationException(org.apache.thrift.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, org.apache.thrift.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 org.apache.thrift.TException
- {
- 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);
- sendBase("alter_index", args);
- }
-
- public void recv_alter_index() throws InvalidOperationException, MetaException, org.apache.thrift.TException
- {
- alter_index_result result = new alter_index_result();
- receiveBase(result, "alter_index");
- 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, org.apache.thrift.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 org.apache.thrift.TException
- {
- 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);
- sendBase("drop_index_by_name", args);
- }
-
- public boolean recv_drop_index_by_name() throws NoSuchObjectException, MetaException, org.apache.thrift.TException
- {
- drop_index_by_name_result result = new drop_index_by_name_result();
- receiveBase(result, "drop_index_by_name");
- if (result.isSetSuccess()) {
- return result.success;
- }
- if (result.o1 != null) {
- throw result.o1;
- }
- if (result.o2 != null) {
- throw result.o2;
- }
- throw new org.apache.thrift.TApplicationException(org.apache.thrift.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, org.apache.thrift.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 org.apache.thrift.TException
- {
- 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);
- sendBase("get_index_by_name", args);
- }
-
- public Index recv_get_index_by_name() throws MetaException, NoSuchObjectException, org.apache.thrift.TException
- {
- get_index_by_name_result result = new get_index_by_name_result();
- receiveBase(result, "get_index_by_name");
- if (result.isSetSuccess()) {
- return result.success;
- }
- if (result.o1 != null) {
- throw result.o1;
- }
- if (result.o2 != null) {
- throw result.o2;
- }
- throw new org.apache.thrift.TApplicationException(org.apache.thrift.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, org.apache.thrift.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 org.apache.thrift.TException
- {
- get_indexes_args args = new get_indexes_args();
- args.setDb_name(db_name);
- args.setTbl_name(tbl_name);
- args.setMax_indexes(max_indexes);
- sendBase("get_indexes", args);
- }
-
- public List<Index> recv_get_indexes() throws NoSuchObjectException, MetaException, org.apache.thrift.TException
- {
- get_indexes_result result = new get_indexes_result();
- receiveBase(result, "get_indexes");
- if (result.isSetSuccess()) {
- return result.success;
- }
- if (result.o1 != null) {
- throw result.o1;
- }
- if (result.o2 != null) {
- throw result.o2;
- }
- throw new org.apache.thrift.TApplicationException(org.apache.thrift.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, org.apache.thrift.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 org.apache.thrift.TException
- {
- 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);
- sendBase("get_index_names", args);
- }
-
- public List<String> recv_get_index_names() throws MetaException, org.apache.thrift.TException
- {
- get_index_names_result result = new get_index_names_result();
- receiveBase(result, "get_index_names");
- if (result.isSetSuccess()) {
- return result.success;
- }
- if (result.o2 != null) {
- throw result.o2;
- }
- throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "get_index_names failed: unknown result");
- }
-
public PrimaryKeysResponse get_primary_keys(PrimaryKeysRequest request) throws MetaException, NoSuchObjectException, org.apache.thrift.TException
{
send_get_primary_keys(request);
@@ -9377,237 +9169,6 @@ import org.slf4j.LoggerFactory;
}
}
- public void add_index(Index new_index, Table index_table, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
- checkReady();
- add_index_call method_call = new add_index_call(new_index, index_table, resultHandler, this, ___protocolFactory, ___transport);
- this.___currentMethod = method_call;
- ___manager.call(method_call);
- }
-
- @org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public static class add_index_call extends org.apache.thrift.async.TAsyncMethodCall {
- private Index new_index;
- private Table index_table;
- public add_index_call(Index new_index, Table index_table, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
- super(client, protocolFactory, transport, resultHandler, false);
- this.new_index = new_index;
- this.index_table = index_table;
- }
-
- public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
- prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("add_index", org.apache.thrift.protocol.TMessageType.CALL, 0));
- add_index_args args = new add_index_args();
- args.setNew_index(new_index);
- args.setIndex_table(index_table);
- args.write(prot);
- prot.writeMessageEnd();
- }
-
- public Index getResult() throws InvalidObjectException, AlreadyExistsException, MetaException, org.apache.thrift.TException {
- if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
- throw new IllegalStateException("Method call not finished!");
- }
- org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
- org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
- return (new Client(prot)).recv_add_index();
- }
- }
-
- public void alter_index(String dbname, String base_tbl_name, String idx_name, Index new_idx, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
- checkReady();
- alter_index_call method_call = new alter_index_call(dbname, base_tbl_name, idx_name, new_idx, resultHandler, this, ___protocolFactory, ___transport);
- this.___currentMethod = method_call;
- ___manager.call(method_call);
- }
-
- @org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public static class alter_index_call extends org.apache.thrift.async.TAsyncMethodCall {
- private String dbname;
- private String base_tbl_name;
- private String idx_name;
- private Index new_idx;
- public alter_index_call(String dbname, String base_tbl_name, String idx_name, Index new_idx, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
- super(client, protocolFactory, transport, resultHandler, false);
- this.dbname = dbname;
- this.base_tbl_name = base_tbl_name;
- this.idx_name = idx_name;
- this.new_idx = new_idx;
- }
-
- public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
- prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("alter_index", org.apache.thrift.protocol.TMessageType.CALL, 0));
- 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(prot);
- prot.writeMessageEnd();
- }
-
- public void getResult() throws InvalidOperationException, MetaException, org.apache.thrift.TException {
- if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
- throw new IllegalStateException("Method call not finished!");
- }
- org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
- org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
- (new Client(prot)).recv_alter_index();
- }
- }
-
- public void drop_index_by_name(String db_name, String tbl_name, String index_name, boolean deleteData, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
- checkReady();
- drop_index_by_name_call method_call = new drop_index_by_name_call(db_name, tbl_name, index_name, deleteData, resultHandler, this, ___protocolFactory, ___transport);
- this.___currentMethod = method_call;
- ___manager.call(method_call);
- }
-
- @org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public static class drop_index_by_name_call extends org.apache.thrift.async.TAsyncMethodCall {
- private String db_name;
- private String tbl_name;
- private String index_name;
- private boolean deleteData;
- public drop_index_by_name_call(String db_name, String tbl_name, String index_name, boolean deleteData, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
- super(client, protocolFactory, transport, resultHandler, false);
- this.db_name = db_name;
- this.tbl_name = tbl_name;
- this.index_name = index_name;
- this.deleteData = deleteData;
- }
-
- public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
- prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("drop_index_by_name", org.apache.thrift.protocol.TMessageType.CALL, 0));
- 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(prot);
- prot.writeMessageEnd();
- }
-
- public boolean getResult() throws NoSuchObjectException, MetaException, org.apache.thrift.TException {
- if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
- throw new IllegalStateException("Method call not finished!");
- }
- org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
- org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
- return (new Client(prot)).recv_drop_index_by_name();
- }
- }
-
- public void get_index_by_name(String db_name, String tbl_name, String index_name, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
- checkReady();
- get_index_by_name_call method_call = new get_index_by_name_call(db_name, tbl_name, index_name, resultHandler, this, ___protocolFactory, ___transport);
- this.___currentMethod = method_call;
- ___manager.call(method_call);
- }
-
- @org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public static class get_index_by_name_call extends org.apache.thrift.async.TAsyncMethodCall {
- private String db_name;
- private String tbl_name;
- private String index_name;
- public get_index_by_name_call(String db_name, String tbl_name, String index_name, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
- super(client, protocolFactory, transport, resultHandler, false);
- this.db_name = db_name;
- this.tbl_name = tbl_name;
- this.index_name = index_name;
- }
-
- public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
- prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("get_index_by_name", org.apache.thrift.protocol.TMessageType.CALL, 0));
- 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(prot);
- prot.writeMessageEnd();
- }
-
- public Index getResult() throws MetaException, NoSuchObjectException, org.apache.thrift.TException {
- if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
- throw new IllegalStateException("Method call not finished!");
- }
- org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
- org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
- return (new Client(prot)).recv_get_index_by_name();
- }
- }
-
- public void get_indexes(String db_name, String tbl_name, short max_indexes, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
- checkReady();
- get_indexes_call method_call = new get_indexes_call(db_name, tbl_name, max_indexes, resultHandler, this, ___protocolFactory, ___transport);
- this.___currentMethod = method_call;
- ___manager.call(method_call);
- }
-
- @org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public static class get_indexes_call extends org.apache.thrift.async.TAsyncMethodCall {
- private String db_name;
- private String tbl_name;
- private short max_indexes;
- public get_indexes_call(String db_name, String tbl_name, short max_indexes, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
- super(client, protocolFactory, transport, resultHandler, false);
- this.db_name = db_name;
- this.tbl_name = tbl_name;
- this.max_indexes = max_indexes;
- }
-
- public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
- prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("get_indexes", org.apache.thrift.protocol.TMessageType.CALL, 0));
- 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(prot);
- prot.writeMessageEnd();
- }
-
- public List<Index> getResult() throws NoSuchObjectException, MetaException, org.apache.thrift.TException {
- if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
- throw new IllegalStateException("Method call not finished!");
- }
- org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
- org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
- return (new Client(prot)).recv_get_indexes();
- }
- }
-
- public void get_index_names(String db_name, String tbl_name, short max_indexes, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
- checkReady();
- get_index_names_call method_call = new get_index_names_call(db_name, tbl_name, max_indexes, resultHandler, this, ___protocolFactory, ___transport);
- this.___currentMethod = method_call;
- ___manager.call(method_call);
- }
-
- @org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public static class get_index_names_call extends org.apache.thrift.async.TAsyncMethodCall {
- private String db_name;
- private String tbl_name;
- private short max_indexes;
- public get_index_names_call(String db_name, String tbl_name, short max_indexes, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
- super(client, protocolFactory, transport, resultHandler, false);
- this.db_name = db_name;
- this.tbl_name = tbl_name;
- this.max_indexes = max_indexes;
- }
-
- public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
- prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("get_index_names", org.apache.thrift.protocol.TMessageType.CALL, 0));
- 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(prot);
- prot.writeMessageEnd();
- }
-
- public List<String> getResult() throws MetaException, org.apache.thrift.TException {
- if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
- throw new IllegalStateException("Method call not finished!");
- }
- org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
- org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
- return (new Client(prot)).recv_get_index_names();
- }
- }
-
public void get_primary_keys(PrimaryKeysRequest request, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
checkReady();
get_primary_keys_call method_call = new get_primary_keys_call(request, resultHandler, this, ___protocolFactory, ___transport);
@@ -12781,12 +12342,6 @@ import org.slf4j.LoggerFactory;
processMap.put("partition_name_to_spec", new partition_name_to_spec());
processMap.put("markPartitionForEvent", new markPartitionForEvent());
processMap.put("isPartitionMarkedForEvent", new isPartitionMarkedForEvent());
- processMap.put("add_index", new add_index());
- processMap.put("alter_index", new alter_index());
- processMap.put("drop_index_by_name", new drop_index_by_name());
- processMap.put("get_index_by_name", new get_index_by_name());
- processMap.put("get_indexes", new get_indexes());
- processMap.put("get_index_names", new get_index_names());
processMap.put("get_primary_keys", new get_primary_keys());
processMap.put("get_foreign_keys", new get_foreign_keys());
processMap.put("get_unique_constraints", new get_unique_constraints());
@@ -15171,163 +14726,6 @@ import org.slf4j.LoggerFactory;
}
}
- @org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public static class add_index<I extends Iface> extends org.apache.thrift.ProcessFunction<I, add_index_args> {
- public add_index() {
- super("add_index");
- }
-
- public add_index_args getEmptyArgsInstance() {
- return new add_index_args();
- }
-
- protected boolean isOneway() {
- return false;
- }
-
- public add_index_result getResult(I iface, add_index_args args) throws org.apache.thrift.TException {
- add_index_result result = new add_index_result();
- try {
- result.success = iface.add_index(args.new_index, args.index_table);
- } catch (InvalidObjectException o1) {
- result.o1 = o1;
- } catch (AlreadyExistsException o2) {
- result.o2 = o2;
- } catch (MetaException o3) {
- result.o3 = o3;
- }
- return result;
- }
- }
-
- @org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public static class alter_index<I extends Iface> extends org.apache.thrift.ProcessFunction<I, alter_index_args> {
- public alter_index() {
- super("alter_index");
- }
-
- public alter_index_args getEmptyArgsInstance() {
- return new alter_index_args();
- }
-
- protected boolean isOneway() {
- return false;
- }
-
- public alter_index_result getResult(I iface, alter_index_args args) throws org.apache.thrift.TException {
- alter_index_result result = new alter_index_result();
- try {
- iface.alter_index(args.dbname, args.base_tbl_name, args.idx_name, args.new_idx);
- } catch (InvalidOperationException o1) {
- result.o1 = o1;
- } catch (MetaException o2) {
- result.o2 = o2;
- }
- return result;
- }
- }
-
- @org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public static class drop_index_by_name<I extends Iface> extends org.apache.thrift.ProcessFunction<I, drop_index_by_name_args> {
- public drop_index_by_name() {
- super("drop_index_by_name");
- }
-
- public drop_index_by_name_args getEmptyArgsInstance() {
- return new drop_index_by_name_args();
- }
-
- protected boolean isOneway() {
- return false;
- }
-
- public drop_index_by_name_result getResult(I iface, drop_index_by_name_args args) throws org.apache.thrift.TException {
- drop_index_by_name_result result = new drop_index_by_name_result();
- try {
- result.success = iface.drop_index_by_name(args.db_name, args.tbl_name, args.index_name, args.deleteData);
- result.setSuccessIsSet(true);
- } catch (NoSuchObjectException o1) {
- result.o1 = o1;
- } catch (MetaException o2) {
- result.o2 = o2;
- }
- return result;
- }
- }
-
- @org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public static class get_index_by_name<I extends Iface> extends org.apache.thrift.ProcessFunction<I, get_index_by_name_args> {
- public get_index_by_name() {
- super("get_index_by_name");
- }
-
- public get_index_by_name_args getEmptyArgsInstance() {
- return new get_index_by_name_args();
- }
-
- protected boolean isOneway() {
- return false;
- }
-
- public get_index_by_name_result getResult(I iface, get_index_by_name_args args) throws org.apache.thrift.TException {
- get_index_by_name_result result = new get_index_by_name_result();
- try {
- result.success = iface.get_index_by_name(args.db_name, args.tbl_name, args.index_name);
- } catch (MetaException o1) {
- result.o1 = o1;
- } catch (NoSuchObjectException o2) {
- result.o2 = o2;
- }
- return result;
- }
- }
-
- @org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public static class get_indexes<I extends Iface> extends org.apache.thrift.ProcessFunction<I, get_indexes_args> {
- public get_indexes() {
- super("get_indexes");
- }
-
- public get_indexes_args getEmptyArgsInstance() {
- return new get_indexes_args();
- }
-
- protected boolean isOneway() {
- return false;
- }
-
- public get_indexes_result getResult(I iface, get_indexes_args args) throws org.apache.thrift.TException {
- get_indexes_result result = new get_indexes_result();
- try {
- result.success = iface.get_indexes(args.db_name, args.tbl_name, args.max_indexes);
- } catch (NoSuchObjectException o1) {
- result.o1 = o1;
- } catch (MetaException o2) {
- result.o2 = o2;
- }
- return result;
- }
- }
-
- @org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public static class get_index_names<I extends Iface> extends org.apache.thrift.ProcessFunction<I, get_index_names_args> {
- public get_index_names() {
- super("get_index_names");
- }
-
- public get_index_names_args getEmptyArgsInstance() {
- return new get_index_names_args();
- }
-
- protected boolean isOneway() {
- return false;
- }
-
- public get_index_names_result getResult(I iface, get_index_names_args args) throws org.apache.thrift.TException {
- get_index_names_result result = new get_index_names_result();
- try {
- result.success = iface.get_index_names(args.db_name, args.tbl_name, args.max_indexes);
- } catch (MetaException o2) {
- result.o2 = o2;
- }
- return result;
- }
- }
-
@org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public static class get_primary_keys<I extends Iface> extends org.apache.thrift.ProcessFunction<I, get_primary_keys_args> {
public get_primary_keys() {
super("get_primary_keys");
@@ -17761,12 +17159,6 @@ import org.slf4j.LoggerFactory;
processMap.put("partition_name_to_spec", new partition_name_to_spec());
processMap.put("markPartitionForEvent", new markPartitionForEvent());
processMap.put("isPartitionMarkedForEvent", new isPartitionMarkedForEvent());
- processMap.put("add_index", new add_index());
- processMap.put("alter_index", new alter_index());
- processMap.put("drop_index_by_name", new drop_index_by_name());
- processMap.put("get_index_by_name", new get_index_by_name());
- processMap.put("get_indexes", new get_indexes());
- processMap.put("get_index_names", new get_index_names());
processMap.put("get_primary_keys", new get_primary_keys());
processMap.put("get_foreign_keys", new get_foreign_keys());
processMap.put("get_unique_constraints", new get_unique_constraints());
@@ -23285,211 +22677,20 @@ import org.slf4j.LoggerFactory;
}
}
- @org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public static class add_index<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, add_index_args, Index> {
- public add_index() {
- super("add_index");
- }
-
- public add_index_args getEmptyArgsInstance() {
- return new add_index_args();
- }
-
- public AsyncMethodCallback<Index> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
- final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<Index>() {
- public void onComplete(Index o) {
- add_index_result result = new add_index_result();
- result.success = o;
- try {
- fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
- return;
- } catch (Exception e) {
- LOGGER.error("Exception writing to internal frame buffer", e);
- }
- fb.close();
- }
- public void onError(Exception e) {
- byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
- org.apache.thrift.TBase msg;
- add_index_result result = new add_index_result();
- if (e instanceof InvalidObjectException) {
- result.o1 = (InvalidObjectException) e;
- result.setO1IsSet(true);
- msg = result;
- }
- else if (e instanceof AlreadyExistsException) {
- result.o2 = (AlreadyExistsException) e;
- result.setO2IsSet(true);
- msg = result;
- }
- else if (e instanceof MetaException) {
- result.o3 = (MetaException) e;
- result.setO3IsSet(true);
- msg = result;
- }
- else
- {
- msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION;
- msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage());
- }
- try {
- fcall.sendResponse(fb,msg,msgType,seqid);
- return;
- } catch (Exception ex) {
- LOGGER.error("Exception writing to internal frame buffer", ex);
- }
- fb.close();
- }
- };
- }
-
- protected boolean isOneway() {
- return false;
- }
-
- public void start(I iface, add_index_args args, org.apache.thrift.async.AsyncMethodCallback<Index> resultHandler) throws TException {
- iface.add_index(args.new_index, args.index_table,resultHandler);
- }
- }
-
- @org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public static class alter_index<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, alter_index_args, Void> {
- public alter_index() {
- super("alter_index");
- }
-
- public alter_index_args getEmptyArgsInstance() {
- return new alter_index_args();
- }
-
- public AsyncMethodCallback<Void> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
- final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<Void>() {
- public void onComplete(Void o) {
- alter_index_result result = new alter_index_result();
- try {
- fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
- return;
- } catch (Exception e) {
- LOGGER.error("Exception writing to internal frame buffer", e);
- }
- fb.close();
- }
- public void onError(Exception e) {
- byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
- org.apache.thrift.TBase msg;
- alter_index_result result = new alter_index_result();
- if (e instanceof InvalidOperationException) {
- result.o1 = (InvalidOperationException) e;
- result.setO1IsSet(true);
- msg = result;
- }
- else if (e instanceof MetaException) {
- result.o2 = (MetaException) e;
- result.setO2IsSet(true);
- msg = result;
- }
- else
- {
- msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION;
- msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage());
- }
- try {
- fcall.sendResponse(fb,msg,msgType,seqid);
- return;
- } catch (Exception ex) {
- LOGGER.error("Exception writing to internal frame buffer", ex);
- }
- fb.close();
- }
- };
- }
-
- protected boolean isOneway() {
- return false;
- }
-
- public void start(I iface, alter_index_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException {
- iface.alter_index(args.dbname, args.base_tbl_name, args.idx_name, args.new_idx,resultHandler);
- }
- }
-
- @org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public static class drop_index_by_name<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, drop_index_by_name_args, Boolean> {
- public drop_index_by_name() {
- super("drop_index_by_name");
- }
-
- public drop_index_by_name_args getEmptyArgsInstance() {
- return new drop_index_by_name_args();
- }
-
- public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
- final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<Boolean>() {
- public void onComplete(Boolean o) {
- drop_index_by_name_result result = new drop_index_by_name_result();
- result.success = o;
- result.setSuccessIsSet(true);
- try {
- fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
- return;
- } catch (Exception e) {
- LOGGER.error("Exception writing to internal frame buffer", e);
- }
- fb.close();
- }
- public void onError(Exception e) {
- byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
- org.apache.thrift.TBase msg;
- drop_index_by_name_result result = new drop_index_by_name_result();
- if (e instanceof NoSuchObjectException) {
- result.o1 = (NoSuchObjectException) e;
- result.setO1IsSet(true);
- msg = result;
- }
- else if (e instanceof MetaException) {
- result.o2 = (MetaException) e;
- result.setO2IsSet(true);
- msg = result;
- }
- else
- {
- msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION;
- msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage());
- }
- try {
- fcall.sendResponse(fb,msg,msgType,seqid);
- return;
- } catch (Exception ex) {
- LOGGER.error("Exception writing to internal frame buffer", ex);
- }
- fb.close();
- }
- };
- }
-
- protected boolean isOneway() {
- return false;
- }
-
- public void start(I iface, drop_index_by_name_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
- iface.drop_index_by_name(args.db_name, args.tbl_name, args.index_name, args.deleteData,resultHandler);
- }
- }
-
- @org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public static class get_index_by_name<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, get_index_by_name_args, Index> {
- public get_index_by_name() {
- super("get_index_by_name");
+ @org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public static class get_primary_keys<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, get_primary_keys_args, PrimaryKeysResponse> {
+ public get_primary_keys() {
+ super("get_primary_keys");
}
- public get_index_by_name_args getEmptyArgsInstance() {
- return new get_index_by_name_args();
+ public get_primary_keys_args getEmptyArgsInstance() {
+ return new get_primary_keys_args();
}
- public AsyncMethodCallback<Index> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<PrimaryKeysResponse> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<Index>() {
- public void onComplete(Index o) {
- get_index_by_name_result result = new get_index_by_name_result();
+ return new AsyncMethodCallback<PrimaryKeysResponse>() {
+ public void onComplete(PrimaryKeysResponse o) {
+ get_primary_keys_result result = new get_primary_keys_result();
result.success = o;
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
@@ -23502,188 +22703,7 @@ import org.slf4j.LoggerFactory;
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- get_index_by_name_result result = new get_index_by_name_result();
- if (e instanceof MetaException) {
- result.o1 = (MetaException) e;
- result.setO1IsSet(true);
- msg = result;
- }
- else if (e instanceof NoSuchObjectException) {
- result.o2 = (NoSuchObjectException) e;
- result.setO2IsSet(true);
- msg = result;
- }
- else
- {
- msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION;
- msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage());
- }
- try {
- fcall.sendResponse(fb,msg,msgType,seqid);
- return;
- } catch (Exception ex) {
- LOGGER.error("Exception writing to internal frame buffer", ex);
- }
- fb.close();
- }
- };
- }
-
- protected boolean isOneway() {
- return false;
- }
-
- public void start(I iface, get_index_by_name_args args, org.apache.thrift.async.AsyncMethodCallback<Index> resultHandler) throws TException {
- iface.get_index_by_name(args.db_name, args.tbl_name, args.index_name,resultHandler);
- }
- }
-
- @org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public static class get_indexes<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, get_indexes_args, List<Index>> {
- public get_indexes() {
- super("get_indexes");
- }
-
- public get_indexes_args getEmptyArgsInstance() {
- return new get_indexes_args();
- }
-
- public AsyncMethodCallback<List<Index>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
- final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<List<Index>>() {
- public void onComplete(List<Index> o) {
- get_indexes_result result = new get_indexes_result();
- result.success = o;
- try {
- fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
- return;
- } catch (Exception e) {
- LOGGER.error("Exception writing to internal frame buffer", e);
- }
- fb.close();
- }
- public void onError(Exception e) {
- byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
- org.apache.thrift.TBase msg;
- get_indexes_result result = new get_indexes_result();
- if (e instanceof NoSuchObjectException) {
- result.o1 = (NoSuchObjectException) e;
- result.setO1IsSet(true);
- msg = result;
- }
- else if (e instanceof MetaException) {
- result.o2 = (MetaException) e;
- result.setO2IsSet(true);
- msg = result;
- }
- else
- {
- msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION;
- msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage());
- }
- try {
- fcall.sendResponse(fb,msg,msgType,seqid);
- return;
- } catch (Exception ex) {
- LOGGER.error("Exception writing to internal frame buffer", ex);
- }
- fb.close();
- }
- };
- }
-
- protected boolean isOneway() {
- return false;
- }
-
- public void start(I iface, get_indexes_args args, org.apache.thrift.async.AsyncMethodCallback<List<Index>> resultHandler) throws TException {
- iface.get_indexes(args.db_name, args.tbl_name, args.max_indexes,resultHandler);
- }
- }
-
- @org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public static class get_index_names<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, get_index_names_args, List<String>> {
- public get_index_names() {
- super("get_index_names");
- }
-
- public get_index_names_args getEmptyArgsInstance() {
- return new get_index_names_args();
- }
-
- public AsyncMethodCallback<List<String>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
- final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<List<String>>() {
- public void onComplete(List<String> o) {
- get_index_names_result result = new get_index_names_result();
- result.success = o;
- try {
- fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
- return;
- } catch (Exception e) {
- LOGGER.error("Exception writing to internal frame buffer", e);
- }
- fb.close();
- }
- public void onError(Exception e) {
- byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
- org.apache.thrift.TBase msg;
- get_index_names_result result = new get_index_names_result();
- if (e instanceof MetaException) {
- result.o2 = (MetaException) e;
- result.setO2IsSet(true);
- msg = result;
- }
- else
- {
- msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION;
- msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage());
- }
- try {
- fcall.sendResponse(fb,msg,msgType,seqid);
- return;
- } catch (Exception ex) {
- LOGGER.error("Exception writing to internal frame buffer", ex);
- }
- fb.close();
- }
- };
- }
-
- protected boolean isOneway() {
- return false;
- }
-
- public void start(I iface, get_index_names_args args, org.apache.thrift.async.AsyncMethodCallback<List<String>> resultHandler) throws TException {
- iface.get_index_names(args.db_name, args.tbl_name, args.max_indexes,resultHandler);
- }
- }
-
- @org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public static class get_primary_keys<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, get_primary_keys_args, PrimaryKeysResponse> {
- public get_primary_keys() {
- super("get_primary_keys");
- }
-
- public get_primary_keys_args getEmptyArgsInstance() {
- return new get_primary_keys_args();
- }
-
- public AsyncMethodCallback<PrimaryKeysResponse> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
- final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<PrimaryKeysResponse>() {
- public void onComplete(PrimaryKeysResponse o) {
- get_primary_keys_result result = new get_primary_keys_result();
- result.success = o;
- try {
- fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
- return;
- } catch (Exception e) {
- LOGGER.error("Exception writing to internal frame buffer", e);
- }
- fb.close();
- }
- public void onError(Exception e) {
- byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
- org.apache.thrift.TBase msg;
- get_primary_keys_result result = new get_primary_keys_result();
+ get_primary_keys_result result = new get_primary_keys_result();
if (e instanceof MetaException) {
result.o1 = (MetaException) e;
result.setO1IsSet(true);
@@ -34664,13 +33684,13 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list874 = iprot.readListBegin();
- struct.success = new ArrayList<String>(_list874.size);
- String _elem875;
- for (int _i876 = 0; _i876 < _list874.size; ++_i876)
+ org.apache.thrift.protocol.TList _list864 = iprot.readListBegin();
+ struct.success = new ArrayList<String>(_list864.size);
+ String _elem865;
+ for (int _i866 = 0; _i866 < _list864.size; ++_i866)
{
- _elem875 = iprot.readString();
- struct.success.add(_elem875);
+ _elem865 = iprot.readString();
+ struct.success.add(_elem865);
}
iprot.readListEnd();
}
@@ -34705,9 +33725,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.success.size()));
- for (String _iter877 : struct.success)
+ for (String _iter867 : struct.success)
{
- oprot.writeString(_iter877);
+ oprot.writeString(_iter867);
}
oprot.writeListEnd();
}
@@ -34746,9 +33766,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (String _iter878 : struct.success)
+ for (String _iter868 : struct.success)
{
- oprot.writeString(_iter878);
+ oprot.writeString(_iter868);
}
}
}
@@ -34763,13 +33783,13 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list879 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.success = new ArrayList<String>(_list879.size);
- String _elem880;
- for (int _i881 = 0; _i881 < _list879.size; ++_i881)
+ org.apache.thrift.protocol.TList _list869 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.success = new ArrayList<String>(_list869.size);
+ String _elem870;
+ for (int _i871 = 0; _i871 < _list869.size; ++_i871)
{
- _elem880 = iprot.readString();
- struct.success.add(_elem880);
+ _elem870 = iprot.readString();
+ struct.success.add(_elem870);
}
}
struct.setSuccessIsSet(true);
@@ -35423,13 +34443,13 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list882 = iprot.readListBegin();
- struct.success = new ArrayList<String>(_list882.size);
- String _elem883;
- for (int _i884 = 0; _i884 < _list882.size; ++_i884)
+ org.apache.thrift.protocol.TList _list872 = iprot.readListBegin();
+ struct.success = new ArrayList<String>(_list872.size);
+ String _elem873;
+ for (int _i874 = 0; _i874 < _list872.size; ++_i874)
{
- _elem883 = iprot.readString();
- struct.success.add(_elem883);
+ _elem873 = iprot.readString();
+ struct.success.add(_elem873);
}
iprot.readListEnd();
}
@@ -35464,9 +34484,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.success.size()));
- for (String _iter885 : struct.success)
+ for (String _iter875 : struct.success)
{
- oprot.writeString(_iter885);
+ oprot.writeString(_iter875);
}
oprot.writeListEnd();
}
@@ -35505,9 +34525,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (String _iter886 : struct.success)
+ for (String _iter876 : struct.success)
{
- oprot.writeString(_iter886);
+ oprot.writeString(_iter876);
}
}
}
@@ -35522,13 +34542,13 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list887 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.success = new ArrayList<String>(_list887.size);
- String _elem888;
- for (int _i889 = 0; _i889 < _list887.size; ++_i889)
+ org.apache.thrift.protocol.TList _list877 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.success = new ArrayList<String>(_list877.size);
+ String _elem878;
+ for (int _i879 = 0; _i879 < _list877.size; ++_i879)
{
- _elem888 = iprot.readString();
- struct.success.add(_elem888);
+ _elem878 = iprot.readString();
+ struct.success.add(_elem878);
}
}
struct.setSuccessIsSet(true);
@@ -40135,16 +39155,16 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
- org.apache.thrift.protocol.TMap _map890 = iprot.readMapBegin();
- struct.success = new HashMap<String,Type>(2*_map890.size);
- String _key891;
- Type _val892;
- for (int _i893 = 0; _i893 < _map890.size; ++_i893)
+ org.apache.thrift.protocol.TMap _map880 = iprot.readMapBegin();
+ struct.success = new HashMap<String,Type>(2*_map880.size);
+ String _key881;
+ Type _val882;
+ for (int _i883 = 0; _i883 < _map880.size; ++_i883)
{
- _key891 = iprot.readString();
- _val892 = new Type();
- _val892.read(iprot);
- struct.success.put(_key891, _val892);
+ _key881 = iprot.readString();
+ _val882 = new Type();
+ _val882.read(iprot);
+ struct.success.put(_key881, _val882);
}
iprot.readMapEnd();
}
@@ -40179,10 +39199,10 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, struct.success.size()));
- for (Map.Entry<String, Type> _iter894 : struct.success.entrySet())
+ for (Map.Entry<String, Type> _iter884 : struct.success.entrySet())
{
- oprot.writeString(_iter894.getKey());
- _iter894.getValue().write(oprot);
+ oprot.writeString(_iter884.getKey());
+ _iter884.getValue().write(oprot);
}
oprot.writeMapEnd();
}
@@ -40221,10 +39241,10 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (Map.Entry<String, Type> _iter895 : struct.success.entrySet())
+ for (Map.Entry<String, Type> _iter885 : struct.success.entrySet())
{
- oprot.writeString(_iter895.getKey());
- _iter895.getValue().write(oprot);
+ oprot.writeString(_iter885.getKey());
+ _iter885.getValue().write(oprot);
}
}
}
@@ -40239,16 +39259,16 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TMap _map896 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.success = new HashMap<String,Type>(2*_map896.size);
- String _key897;
- Type _val898;
- for (int _i899 = 0; _i899 < _map896.size; ++_i899)
+ org.apache.thrift.protocol.TMap _map886 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.success = new HashMap<String,Type>(2*_map886.size);
+ String _key887;
+ Type _val888;
+ for (int _i889 = 0; _i889 < _map886.size; ++_i889)
{
- _key897 = iprot.readString();
- _val898 = new Type();
- _val898.read(iprot);
- struct.success.put(_key897, _val898);
+ _key887 = iprot.readString();
+ _val888 = new Type();
+ _val888.read(iprot);
+ struct.success.put(_key887, _val888);
}
}
struct.setSuccessIsSet(true);
@@ -41283,14 +40303,14 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list900 = iprot.readListBegin();
- struct.success = new ArrayList<FieldSchema>(_list900.size);
- FieldSchema _elem901;
- for (int _i902 = 0; _i902 < _list900.size; ++_i902)
+ org.apache.thrift.protocol.TList _list890 = iprot.readListBegin();
+ struct.success = new ArrayList<FieldSchema>(_list890.size);
+ FieldSchema _elem891;
+ for (int _i892 = 0; _i892 < _list890.size; ++_i892)
{
- _elem901 = new FieldSchema();
- _elem901.read(iprot);
- struct.success.add(_elem901);
+ _elem891 = new FieldSchema();
+ _elem891.read(iprot);
+ struct.success.add(_elem891);
}
iprot.readListEnd();
}
@@ -41343,9 +40363,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.success.size()));
- for (FieldSchema _iter903 : struct.success)
+ for (FieldSchema _iter893 : struct.success)
{
- _iter903.write(oprot);
+ _iter893.write(oprot);
}
oprot.writeListEnd();
}
@@ -41400,9 +40420,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (FieldSchema _iter904 : struct.success)
+ for (FieldSchema _iter894 : struct.success)
{
- _iter904.write(oprot);
+ _iter894.write(oprot);
}
}
}
@@ -41423,14 +40443,14 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(4);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list905 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.success = new ArrayList<FieldSchema>(_list905.size);
- FieldSchema _elem906;
- for (int _i907 = 0; _i907 < _list905.size; ++_i907)
+ org.apache.thrift.protocol.TList _list895 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.success = new ArrayList<FieldSchema>(_list895.size);
+ FieldSchema _elem896;
+ for (int _i897 = 0; _i897 < _list895.size; ++_i897)
{
- _elem906 = new FieldSchema();
- _elem906.read(iprot);
- struct.success.add(_elem906);
+ _elem896 = new FieldSchema();
+ _elem896.read(iprot);
+ struct.success.add(_elem896);
}
}
struct.setSuccessIsSet(true);
@@ -42584,14 +41604,14 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list908 = iprot.readListBegin();
- struct.success = new ArrayList<FieldSchema>(_list908.size);
- FieldSchema _elem909;
- for (int _i910 = 0; _i910 < _list908.size; ++_i910)
+ org.apache.thrift.protocol.TList _list898 = iprot.readListBegin();
+ struct.success = new ArrayList<FieldSchema>(_list898.size);
+ FieldSchema _elem899;
+ for (int _i900 = 0; _i900 < _list898.size; ++_i900)
{
- _elem909 = new FieldSchema();
- _elem909.read(iprot);
- struct.success.add(_elem909);
+ _elem899 = new FieldSchema();
+ _elem899.read(iprot);
+ struct.success.add(_elem899);
}
iprot.readListEnd();
}
@@ -42644,9 +41664,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.success.size()));
- for (FieldSchema _iter911 : struct.success)
+ for (FieldSchema _iter901 : struct.success)
{
- _iter911.write(oprot);
+ _iter901.write(oprot);
}
oprot.writeListEnd();
}
@@ -42701,9 +41721,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (FieldSchema _iter912 : struct.success)
+ for (FieldSchema _iter902 : struct.success)
{
- _iter912.write(oprot);
+ _iter902.write(oprot);
}
}
}
@@ -42724,14 +41744,14 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(4);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list913 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.success = new ArrayList<FieldSchema>(_list913.size);
- FieldSchema _elem914;
- for (int _i915 = 0; _i915 < _list913.size; ++_i915)
+ org.apache.thrift.protocol.TList _list903 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.success = new ArrayList<FieldSchema>(_list903.size);
+ FieldSchema _elem904;
+ for (int _i905 = 0; _i905 < _list903.size; ++_i905)
{
- _elem914 = new FieldSchema();
- _elem914.read(iprot);
- struct.success.add(_elem914);
+ _elem904 = new FieldSchema();
+ _elem904.read(iprot);
+ struct.success.add(_elem904);
}
}
struct.setSuccessIsSet(true);
@@ -43776,14 +42796,14 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list916 = iprot.readListBegin();
- struct.success = new ArrayList<FieldSchema>(_list916.size);
- FieldSchema _elem917;
- for (int _i918 = 0; _i918 < _list916.size; ++_i918)
+ org.apache.thrift.protocol.TList _list906 = iprot.readListBegin();
+ struct.success = new ArrayList<FieldSchema>(_list906.size);
+ FieldSchema _elem907;
+ for (int _i908 = 0; _i908 < _list906.size; ++_i908)
{
- _elem917 = new FieldSchema();
- _elem917.read(iprot);
- struct.success.add(_elem917);
+ _elem907 = new FieldSchema();
+ _elem907.read(iprot);
+ struct.success.add(_elem907);
}
iprot.readListEnd();
}
@@ -43836,9 +42856,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.success.size()));
- for (FieldSchema _iter919 : struct.success)
+ for (FieldSchema _iter909 : struct.success)
{
- _iter919.write(oprot);
+ _iter909.write(oprot);
}
oprot.writeListEnd();
}
@@ -43893,9 +42913,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (FieldSchema _iter920 : struct.success)
+ for (FieldSchema _iter910 : struct.success)
{
- _iter920.write(oprot);
+ _iter910.write(oprot);
}
}
}
@@ -43916,14 +42936,14 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(4);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list921 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.success = new ArrayList<FieldSchema>(_list921.size);
- FieldSchema _elem922;
- for (int _i923 = 0; _i923 < _list921.size; ++_i923)
+ org.apache.thrift.protocol.TList _list911 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.success = new ArrayList<FieldSchema>(_list911.size);
+ FieldSchema _elem912;
+ for (int _i913 = 0; _i913 < _list911.size; ++_i913)
{
- _elem922 = new FieldSchema();
- _elem922.read(iprot);
- struct.success.add(_elem922);
+ _elem912 = new FieldSchema();
+ _elem912.read(iprot);
+ struct.success.add(_elem912);
}
}
struct.setSuccessIsSet(true);
@@ -45077,14 +44097,14 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list924 = iprot.readListBegin();
- struct.success = new ArrayList<FieldSchema>(_list924.size);
- FieldSchema _elem925;
- for (int _i926 = 0; _i926 < _list924.size; ++_i926)
+ org.apache.thrift.protocol.TList _list914 = iprot.readListBegin();
+ struct.success = new ArrayList<FieldSchema>(_list914.size);
+ FieldSchema _elem915;
+ for (int _i916 = 0; _i916 < _list914.size; ++_i916)
{
- _elem925 = new FieldSchema();
- _elem925.read(iprot);
- struct.success.add(_elem925);
+ _elem915 = new FieldSchema();
+ _elem915.read(iprot);
+ struct.success.add(_elem915);
}
iprot.readListEnd();
}
@@ -45137,9 +44157,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.success.size()));
- for (FieldSchema _iter927 : struct.success)
+ for (FieldSchema _iter917 : struct.success)
{
- _iter927.write(oprot);
+ _iter917.write(oprot);
}
oprot.writeListEnd();
}
@@ -45194,9 +44214,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (FieldSchema _iter928 : struct.success)
+ for (FieldSchema _iter918 : struct.success)
{
- _iter928.write(oprot);
+ _iter918.write(oprot);
}
}
}
@@ -45217,14 +44237,14 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(4);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list929 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.success = new ArrayList<FieldSchema>(_list929.size);
- FieldSchema _elem930;
- for (int _i931 = 0; _i931 < _list929.size; ++_i931)
+ org.apache.thrift.protocol.TList _list919 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.success = new ArrayList<FieldSchema>(_list919.size);
+ FieldSchema _elem920;
+ for (int _i921 = 0; _i921 < _list919.size; ++_i921)
{
- _elem930 = new FieldSchema();
- _elem930.read(iprot);
- struct.success.add(_elem930);
+ _elem920 = new FieldSchema();
+ _elem920.read(iprot);
+ struct.success.add(_elem920);
}
}
struct.setSuccessIsSet(true);
@@ -48252,14 +47272,14 @@ import org.slf4j.LoggerFactory;
case 2: // PRIMARY_KEYS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list932 = iprot.readListBegin();
- struct.primaryKeys = new ArrayList<SQLPrimaryKey>(_list932.size);
- SQLPrimaryKey _elem933;
- for (int _i934 = 0; _i934 < _list932.size; ++_i934)
+ org.apache.thrift.protocol.TList _list922 = iprot.readListBegin();
+ struct.primaryKeys = new ArrayList<SQLPrimaryKey>(_list922.size);
+ SQLPrimaryKey _elem923;
+ for (int _i924 = 0; _i924 < _list922.size; ++_i924)
{
- _elem933 = new SQLPrimaryKey();
- _elem933.read(iprot);
- struct.primaryKeys.add(_elem933);
+ _elem923 = new SQLPrimaryKey();
+ _elem923.read(iprot);
+ struct.primaryKeys.add(_elem923);
}
iprot.readListEnd();
}
@@ -48271,14 +47291,14 @@ import org.slf4j.LoggerFactory;
case 3: // FOREIGN_KEYS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list935 = iprot.readListBegin();
- struct.foreignKeys = new ArrayList<SQLForeignKey>(_list935.size);
- SQLForeignKey _elem936;
- for (int _i937 = 0; _i937 < _list935.size; ++_i937)
+ org.apache.thrift.protocol.TList _list925 = iprot.readListBegin();
+ struct.foreignKeys = new ArrayList<SQLForeignKey>(_list925.size);
+ SQLForeignKey _elem926;
+ for (int _i927 = 0; _i927 < _list925.size; ++_i927)
{
- _elem936 = new SQLForeignKey();
- _elem936.read(iprot);
- struct.foreignKeys.add(_elem936);
+ _elem926 = new SQLForeignKey();
+ _elem926.read(iprot);
+ struct.foreignKeys.add(_elem926);
}
iprot.readListEnd();
}
@@ -48290,14 +47310,14 @@ import org.slf4j.LoggerFactory;
case 4: // UNIQUE_CONSTRAINTS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list938 = iprot.readListBegin();
- struct.uniqueConstraints = new ArrayList<SQLUniqueConstraint>(_list938.size);
- SQLUniqueConstraint _elem939;
- for (int _i940 = 0; _i940 < _list938.size; ++_i940)
+ org.apache.thrift.protocol.TList _list928 = iprot.readListBegin();
+ struct.uniqueConstraints = new ArrayList<SQLUniqueConstraint>(_list928.size);
+ SQLUniqueConstraint _elem929;
+ for (int _i930 = 0; _i930 < _list928.size; ++_i930)
{
- _elem939 = new SQLUniqueConstraint();
- _elem939.read(iprot);
- struct.uniqueConstraints.add(_elem939);
+ _elem929 = new SQLUniqueConstraint();
+ _elem929.read(iprot);
+ struct.uniqueConstraints.add(_elem929);
}
iprot.readListEnd();
}
@@ -48309,14 +47329,14 @@ import org.slf4j.LoggerFactory;
case 5: // NOT_NULL_CONSTRAINTS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list941 = iprot.readListBegin();
- struct.notNullConstraints = new ArrayList<SQLNotNullConstraint>(_list941.size);
- SQLNotNullConstraint _elem942;
- for (int _i943 = 0; _i943 < _list941.size; ++_i943)
+ org.apache.thrift.protocol.TList _list931 = iprot.readListBegin();
+ struct.notNullConstraints = new ArrayList<SQLNotNullConstraint>(_list931.size);
+ SQLNotNullConstraint _elem932;
+ for (int _i933 = 0; _i933 < _list931.size; ++_i933)
{
- _elem942 = new SQLNotNullConstraint();
- _elem942.read(iprot);
- struct.notNullConstraints.add(_elem942);
+ _elem932 = new SQLNotNullConstraint();
+ _elem932.read(iprot);
+ struct.notNullConstraints.add(_elem932);
}
iprot.readListEnd();
}
@@ -48328,14 +47348,14 @@ import org.slf4j.LoggerFactory;
case 6: // DEFAULT_CONSTRAINTS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list944 = iprot.readListBegin();
- struct.defaultConstraints = new ArrayList<SQLDefaultConstraint>(_list944.size);
- SQLDefaultConstraint _elem945;
- for (int _i946 = 0; _i946 < _list944.size; ++_i946)
+ org.apache.thrift.protocol.TList _list934 = iprot.readListBegin();
+ struct.defaultConstraints = new ArrayList<SQLDefaultConstraint>(_list934.size);
+ SQLDefaultConstraint _elem935;
+ for (int _i936 = 0; _i936 < _list934.size; ++_i936)
{
- _elem945 = new SQLDefaultConstraint();
- _elem945.read(iprot);
- struct.defaultConstraints.add(_elem945);
+ _elem935 = new SQLDefaultConstraint();
+ _elem935.read(iprot);
+ struct.defaultConstraints.add(_elem935);
}
iprot.readListEnd();
}
@@ -48366,9 +47386,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(PRIMARY_KEYS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.primaryKeys.size()));
- for (SQLPrimaryKey _iter947 : struct.primaryKeys)
+ for (SQLPrimaryKey _iter937 : struct.primaryKeys)
{
- _iter947.write(oprot);
+ _iter937.write(oprot);
}
oprot.writeListEnd();
}
@@ -48378,9 +47398,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(FOREIGN_KEYS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.foreignKeys.size()));
- for (SQLForeignKey _iter948 : struct.foreignKeys)
+ for (SQLForeignKey _iter938 : struct.foreignKeys)
{
- _iter948.write(oprot);
+ _iter938.write(oprot);
}
oprot.writeListEnd();
}
@@ -48390,9 +47410,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(UNIQUE_CONSTRAINTS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.uniqueConstraints.size()));
- for (SQLUniqueConstraint _iter949 : struct.uniqueConstraints)
+ for (SQLUniqueConstraint _iter939 : struct.uniqueConstraints)
{
- _iter949.write(oprot);
+ _iter939.write(oprot);
}
oprot.writeListEnd();
}
@@ -48402,9 +47422,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(NOT_NULL_CONSTRAINTS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.notNullConstraints.size()));
- for (SQLNotNullConstraint _iter950 : struct.notNullConstraints)
+ for (SQLNotNullConstraint _iter940 : struct.notNullConstraints)
{
- _iter950.write(oprot);
+ _iter940.write(oprot);
}
oprot.writeListEnd();
}
@@ -48414,9 +47434,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(DEFAULT_CONSTRAINTS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.defaultConstraints.size()));
- for (SQLDefaultConstraint _iter951 : struct.defaultConstraints)
+ for (SQLDefaultConstraint _iter941 : struct.defaultConstraints)
{
- _iter951.write(oprot);
+ _iter941.write(oprot);
}
oprot.writeListEnd();
}
@@ -48465,45 +47485,45 @@ import org.slf4j.LoggerFactory;
if (struct.isSetPrimaryKeys()) {
{
oprot.writeI32(struct.primaryKeys.size());
- for (SQLPrimaryKey _iter952 : struct.primaryKeys)
+ for (SQLPrimaryKey _iter942 : struct.primaryKeys)
{
- _iter952.write(oprot);
+ _iter942.write(oprot);
}
}
}
if (struct.isSetForeignKeys()) {
{
oprot.writeI32(struct.foreignKeys.size());
- for (SQLForeignKey _iter953 : struct.foreignKeys)
+ for (SQLForeignKey _iter943 : struct.foreignKeys)
{
- _iter953.write(oprot);
+ _iter943.write(oprot);
}
}
}
if (struct.isSetUniqueConstraints()) {
{
oprot.writeI32(struct.uniqueConstraints.size());
- for (SQLUniqueConstraint _iter954 : struct.uniqueConstraints)
+ for (SQLUniqueConstraint _iter944 : struct.uniqueConstraints)
{
- _iter954.write(oprot);
+ _iter944.write(oprot);
}
}
}
if (struct.isSetNotNullConstraints()) {
{
oprot.writeI32(struct.notNullConstraints.size());
- for (SQLNotNullConstraint _iter955 : struct.notNullConstraints)
+ for (SQLNotNullConstraint _iter945 : struct.notNullConstraints)
{
- _iter955.write(oprot);
+ _iter945.write(oprot);
}
}
}
if (struct.isSetDefaultConstraints()) {
{
oprot.writeI32(struct.defaultConstraints.size());
- for (SQLDefaultConstraint _iter956 : struct.defaultConstraints)
+ for (SQLDefaultConstraint _iter946 : struct.defaultConstraints)
{
- _iter956.write(oprot);
+ _iter946.write(oprot);
}
}
}
@@ -48520,70 +47540,70 @@ import org.slf4j.LoggerFactory;
}
if (incoming.get(1)) {
{
- org.apache.thrift.protocol.TList _list957 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.primaryKeys = new ArrayList<SQLPrimaryKey>(_list957.size);
- SQLPrimaryKey _elem958;
- for (int _i959 = 0; _i959 < _list957.size; ++_i959)
+ org.apache.thrift.protocol.TList _list947 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.primaryKeys = new ArrayList<SQLPrimaryKey>(_list947.size);
+ SQLPrimaryKey _elem948;
+ for (int _i949 = 0; _i949 < _list947.size; ++_i949)
{
- _elem958 = new SQLPrimaryKey();
- _elem958.read(iprot);
- struct.primaryKeys.add(_elem958);
+ _elem948 = new SQLPrimaryKey();
+ _elem948.read(iprot);
+ struct.primaryKeys.add(_elem948);
}
}
struct.setPrimaryKeysIsSet(true);
}
if (incoming.get(2)) {
{
- org.apache.thrift.protocol.TList _list960 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.foreignKeys = new ArrayList<SQLForeignKey>(_list960.size);
- SQLForeignKey _elem961;
- for (int _i962 = 0; _i962 < _list960.size; ++_i962)
+ org.apache.thrift.protocol.TList _list950 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.foreignKeys = new ArrayList<SQLForeignKey>(_list950.size);
+ SQLForeignKey _elem9
<TRUNCATED>