http://git-wip-us.apache.org/repos/asf/hive/blob/42216997/service/src/gen/thrift/gen-php/ThriftHive.php ---------------------------------------------------------------------- diff --git a/service/src/gen/thrift/gen-php/ThriftHive.php b/service/src/gen/thrift/gen-php/ThriftHive.php index 8fc3ff4..2c783b6 100644 --- a/service/src/gen/thrift/gen-php/ThriftHive.php +++ b/service/src/gen/thrift/gen-php/ThriftHive.php @@ -1,7 +1,7 @@ <?php namespace ; /** - * Autogenerated by Thrift Compiler (0.9.0) + * Autogenerated by Thrift Compiler (0.9.2) * * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING * @generated @@ -12,18 +12,54 @@ use Thrift\Type\TMessageType; use Thrift\Exception\TException; use Thrift\Exception\TProtocolException; use Thrift\Protocol\TProtocol; +use Thrift\Protocol\TBinaryProtocolAccelerated; use Thrift\Exception\TApplicationException; interface ThriftHiveIf extends \metastore\ThriftHiveMetastoreIf { + /** + * @param string $query + * @throws \HiveServerException + */ public function execute($query); + /** + * @return string + * @throws \HiveServerException + */ public function fetchOne(); + /** + * @param int $numRows + * @return string[] + * @throws \HiveServerException + */ public function fetchN($numRows); + /** + * @return string[] + * @throws \HiveServerException + */ public function fetchAll(); + /** + * @return \metastore\Schema + * @throws \HiveServerException + */ public function getSchema(); + /** + * @return \metastore\Schema + * @throws \HiveServerException + */ public function getThriftSchema(); + /** + * @return \HiveClusterStatus + * @throws \HiveServerException + */ public function getClusterStatus(); + /** + * @return \QueryPlan + * @throws \HiveServerException + */ public function getQueryPlan(); + /** + */ public function clean(); } @@ -42,7 +78,7 @@ class ThriftHiveClient extends \metastore\ThriftHiveMetastoreClient implements \ { $args = new \ThriftHive_execute_args(); $args->query = $query; - $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary'); + $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary'); if ($bin_accel) { thrift_protocol_write_binary($this->output_, 'execute', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); @@ -58,7 +94,7 @@ class ThriftHiveClient extends \metastore\ThriftHiveMetastoreClient implements \ public function recv_execute() { - $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary'); + $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary'); if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\ThriftHive_execute_result', $this->input_->isStrictRead()); else { @@ -92,7 +128,7 @@ class ThriftHiveClient extends \metastore\ThriftHiveMetastoreClient implements \ public function send_fetchOne() { $args = new \ThriftHive_fetchOne_args(); - $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary'); + $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary'); if ($bin_accel) { thrift_protocol_write_binary($this->output_, 'fetchOne', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); @@ -108,7 +144,7 @@ class ThriftHiveClient extends \metastore\ThriftHiveMetastoreClient implements \ public function recv_fetchOne() { - $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary'); + $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary'); if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\ThriftHive_fetchOne_result', $this->input_->isStrictRead()); else { @@ -146,7 +182,7 @@ class ThriftHiveClient extends \metastore\ThriftHiveMetastoreClient implements \ { $args = new \ThriftHive_fetchN_args(); $args->numRows = $numRows; - $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary'); + $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary'); if ($bin_accel) { thrift_protocol_write_binary($this->output_, 'fetchN', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); @@ -162,7 +198,7 @@ class ThriftHiveClient extends \metastore\ThriftHiveMetastoreClient implements \ public function recv_fetchN() { - $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary'); + $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary'); if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\ThriftHive_fetchN_result', $this->input_->isStrictRead()); else { @@ -199,7 +235,7 @@ class ThriftHiveClient extends \metastore\ThriftHiveMetastoreClient implements \ public function send_fetchAll() { $args = new \ThriftHive_fetchAll_args(); - $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary'); + $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary'); if ($bin_accel) { thrift_protocol_write_binary($this->output_, 'fetchAll', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); @@ -215,7 +251,7 @@ class ThriftHiveClient extends \metastore\ThriftHiveMetastoreClient implements \ public function recv_fetchAll() { - $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary'); + $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary'); if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\ThriftHive_fetchAll_result', $this->input_->isStrictRead()); else { @@ -252,7 +288,7 @@ class ThriftHiveClient extends \metastore\ThriftHiveMetastoreClient implements \ public function send_getSchema() { $args = new \ThriftHive_getSchema_args(); - $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary'); + $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary'); if ($bin_accel) { thrift_protocol_write_binary($this->output_, 'getSchema', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); @@ -268,7 +304,7 @@ class ThriftHiveClient extends \metastore\ThriftHiveMetastoreClient implements \ public function recv_getSchema() { - $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary'); + $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary'); if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\ThriftHive_getSchema_result', $this->input_->isStrictRead()); else { @@ -305,7 +341,7 @@ class ThriftHiveClient extends \metastore\ThriftHiveMetastoreClient implements \ public function send_getThriftSchema() { $args = new \ThriftHive_getThriftSchema_args(); - $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary'); + $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary'); if ($bin_accel) { thrift_protocol_write_binary($this->output_, 'getThriftSchema', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); @@ -321,7 +357,7 @@ class ThriftHiveClient extends \metastore\ThriftHiveMetastoreClient implements \ public function recv_getThriftSchema() { - $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary'); + $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary'); if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\ThriftHive_getThriftSchema_result', $this->input_->isStrictRead()); else { @@ -358,7 +394,7 @@ class ThriftHiveClient extends \metastore\ThriftHiveMetastoreClient implements \ public function send_getClusterStatus() { $args = new \ThriftHive_getClusterStatus_args(); - $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary'); + $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary'); if ($bin_accel) { thrift_protocol_write_binary($this->output_, 'getClusterStatus', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); @@ -374,7 +410,7 @@ class ThriftHiveClient extends \metastore\ThriftHiveMetastoreClient implements \ public function recv_getClusterStatus() { - $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary'); + $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary'); if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\ThriftHive_getClusterStatus_result', $this->input_->isStrictRead()); else { @@ -411,7 +447,7 @@ class ThriftHiveClient extends \metastore\ThriftHiveMetastoreClient implements \ public function send_getQueryPlan() { $args = new \ThriftHive_getQueryPlan_args(); - $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary'); + $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary'); if ($bin_accel) { thrift_protocol_write_binary($this->output_, 'getQueryPlan', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); @@ -427,7 +463,7 @@ class ThriftHiveClient extends \metastore\ThriftHiveMetastoreClient implements \ public function recv_getQueryPlan() { - $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary'); + $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary'); if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\ThriftHive_getQueryPlan_result', $this->input_->isStrictRead()); else { @@ -464,7 +500,7 @@ class ThriftHiveClient extends \metastore\ThriftHiveMetastoreClient implements \ public function send_clean() { $args = new \ThriftHive_clean_args(); - $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary'); + $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary'); if ($bin_accel) { thrift_protocol_write_binary($this->output_, 'clean', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); @@ -480,7 +516,7 @@ class ThriftHiveClient extends \metastore\ThriftHiveMetastoreClient implements \ public function recv_clean() { - $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary'); + $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary'); if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\ThriftHive_clean_result', $this->input_->isStrictRead()); else { @@ -509,6 +545,9 @@ class ThriftHiveClient extends \metastore\ThriftHiveMetastoreClient implements \ class ThriftHive_execute_args { static $_TSPEC; + /** + * @var string + */ public $query = null; public function __construct($vals=null) { @@ -581,6 +620,9 @@ class ThriftHive_execute_args { class ThriftHive_execute_result { static $_TSPEC; + /** + * @var \HiveServerException + */ public $ex = null; public function __construct($vals=null) { @@ -705,7 +747,13 @@ class ThriftHive_fetchOne_args { class ThriftHive_fetchOne_result { static $_TSPEC; + /** + * @var string + */ public $success = null; + /** + * @var \HiveServerException + */ public $ex = null; public function __construct($vals=null) { @@ -799,6 +847,9 @@ class ThriftHive_fetchOne_result { class ThriftHive_fetchN_args { static $_TSPEC; + /** + * @var int + */ public $numRows = null; public function __construct($vals=null) { @@ -871,7 +922,13 @@ class ThriftHive_fetchN_args { class ThriftHive_fetchN_result { static $_TSPEC; + /** + * @var string[] + */ public $success = null; + /** + * @var \HiveServerException + */ public $ex = null; public function __construct($vals=null) { @@ -1041,7 +1098,13 @@ class ThriftHive_fetchAll_args { class ThriftHive_fetchAll_result { static $_TSPEC; + /** + * @var string[] + */ public $success = null; + /** + * @var \HiveServerException + */ public $ex = null; public function __construct($vals=null) { @@ -1211,7 +1274,13 @@ class ThriftHive_getSchema_args { class ThriftHive_getSchema_result { static $_TSPEC; + /** + * @var \metastore\Schema + */ public $success = null; + /** + * @var \HiveServerException + */ public $ex = null; public function __construct($vals=null) { @@ -1360,7 +1429,13 @@ class ThriftHive_getThriftSchema_args { class ThriftHive_getThriftSchema_result { static $_TSPEC; + /** + * @var \metastore\Schema + */ public $success = null; + /** + * @var \HiveServerException + */ public $ex = null; public function __construct($vals=null) { @@ -1509,7 +1584,13 @@ class ThriftHive_getClusterStatus_args { class ThriftHive_getClusterStatus_result { static $_TSPEC; + /** + * @var \HiveClusterStatus + */ public $success = null; + /** + * @var \HiveServerException + */ public $ex = null; public function __construct($vals=null) { @@ -1658,7 +1739,13 @@ class ThriftHive_getQueryPlan_args { class ThriftHive_getQueryPlan_result { static $_TSPEC; + /** + * @var \QueryPlan + */ public $success = null; + /** + * @var \HiveServerException + */ public $ex = null; public function __construct($vals=null) {
http://git-wip-us.apache.org/repos/asf/hive/blob/42216997/service/src/gen/thrift/gen-php/Types.php ---------------------------------------------------------------------- diff --git a/service/src/gen/thrift/gen-php/Types.php b/service/src/gen/thrift/gen-php/Types.php index f4225ad..d8f3c5b 100644 --- a/service/src/gen/thrift/gen-php/Types.php +++ b/service/src/gen/thrift/gen-php/Types.php @@ -2,7 +2,7 @@ namespace ; /** - * Autogenerated by Thrift Compiler (0.9.0) + * Autogenerated by Thrift Compiler (0.9.2) * * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING * @generated @@ -13,6 +13,7 @@ use Thrift\Type\TMessageType; use Thrift\Exception\TException; use Thrift\Exception\TProtocolException; use Thrift\Protocol\TProtocol; +use Thrift\Protocol\TBinaryProtocolAccelerated; use Thrift\Exception\TApplicationException; @@ -28,11 +29,29 @@ final class JobTrackerState { class HiveClusterStatus { static $_TSPEC; + /** + * @var int + */ public $taskTrackers = null; + /** + * @var int + */ public $mapTasks = null; + /** + * @var int + */ public $reduceTasks = null; + /** + * @var int + */ public $maxMapTasks = null; + /** + * @var int + */ public $maxReduceTasks = null; + /** + * @var int + */ public $state = null; public function __construct($vals=null) { @@ -200,8 +219,17 @@ class HiveClusterStatus { class HiveServerException extends TException { static $_TSPEC; + /** + * @var string + */ public $message = null; + /** + * @var int + */ public $errorCode = null; + /** + * @var string + */ public $SQLState = null; public function __construct($vals=null) { http://git-wip-us.apache.org/repos/asf/hive/blob/42216997/service/src/gen/thrift/gen-py/TCLIService/TCLIService-remote ---------------------------------------------------------------------- diff --git a/service/src/gen/thrift/gen-py/TCLIService/TCLIService-remote b/service/src/gen/thrift/gen-py/TCLIService/TCLIService-remote old mode 100644 new mode 100755 index f6ff43f..2bfca56 --- a/service/src/gen/thrift/gen-py/TCLIService/TCLIService-remote +++ b/service/src/gen/thrift/gen-py/TCLIService/TCLIService-remote @@ -1,6 +1,6 @@ #!/usr/bin/env python # -# Autogenerated by Thrift Compiler (0.9.0) +# Autogenerated by Thrift Compiler (0.9.2) # # DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING # @@ -12,37 +12,38 @@ import pprint from urlparse import urlparse from thrift.transport import TTransport from thrift.transport import TSocket +from thrift.transport import TSSLSocket from thrift.transport import THttpClient from thrift.protocol import TBinaryProtocol -import TCLIService -from ttypes import * +from TCLIService import TCLIService +from TCLIService.ttypes import * if len(sys.argv) <= 1 or sys.argv[1] == '--help': - print '' - print 'Usage: ' + sys.argv[0] + ' [-h host[:port]] [-u url] [-f[ramed]] function [arg1 [arg2...]]' - print '' - print 'Functions:' - print ' TOpenSessionResp OpenSession(TOpenSessionReq req)' - print ' TCloseSessionResp CloseSession(TCloseSessionReq req)' - print ' TGetInfoResp GetInfo(TGetInfoReq req)' - print ' TExecuteStatementResp ExecuteStatement(TExecuteStatementReq req)' - print ' TGetTypeInfoResp GetTypeInfo(TGetTypeInfoReq req)' - print ' TGetCatalogsResp GetCatalogs(TGetCatalogsReq req)' - print ' TGetSchemasResp GetSchemas(TGetSchemasReq req)' - print ' TGetTablesResp GetTables(TGetTablesReq req)' - print ' TGetTableTypesResp GetTableTypes(TGetTableTypesReq req)' - print ' TGetColumnsResp GetColumns(TGetColumnsReq req)' - print ' TGetFunctionsResp GetFunctions(TGetFunctionsReq req)' - print ' TGetOperationStatusResp GetOperationStatus(TGetOperationStatusReq req)' - print ' TCancelOperationResp CancelOperation(TCancelOperationReq req)' - print ' TCloseOperationResp CloseOperation(TCloseOperationReq req)' - print ' TGetResultSetMetadataResp GetResultSetMetadata(TGetResultSetMetadataReq req)' - print ' TFetchResultsResp FetchResults(TFetchResultsReq req)' - print ' TGetDelegationTokenResp GetDelegationToken(TGetDelegationTokenReq req)' - print ' TCancelDelegationTokenResp CancelDelegationToken(TCancelDelegationTokenReq req)' - print ' TRenewDelegationTokenResp RenewDelegationToken(TRenewDelegationTokenReq req)' - print '' + print('') + print('Usage: ' + sys.argv[0] + ' [-h host[:port]] [-u url] [-f[ramed]] [-s[sl]] function [arg1 [arg2...]]') + print('') + print('Functions:') + print(' TOpenSessionResp OpenSession(TOpenSessionReq req)') + print(' TCloseSessionResp CloseSession(TCloseSessionReq req)') + print(' TGetInfoResp GetInfo(TGetInfoReq req)') + print(' TExecuteStatementResp ExecuteStatement(TExecuteStatementReq req)') + print(' TGetTypeInfoResp GetTypeInfo(TGetTypeInfoReq req)') + print(' TGetCatalogsResp GetCatalogs(TGetCatalogsReq req)') + print(' TGetSchemasResp GetSchemas(TGetSchemasReq req)') + print(' TGetTablesResp GetTables(TGetTablesReq req)') + print(' TGetTableTypesResp GetTableTypes(TGetTableTypesReq req)') + print(' TGetColumnsResp GetColumns(TGetColumnsReq req)') + print(' TGetFunctionsResp GetFunctions(TGetFunctionsReq req)') + print(' TGetOperationStatusResp GetOperationStatus(TGetOperationStatusReq req)') + print(' TCancelOperationResp CancelOperation(TCancelOperationReq req)') + print(' TCloseOperationResp CloseOperation(TCloseOperationReq req)') + print(' TGetResultSetMetadataResp GetResultSetMetadata(TGetResultSetMetadataReq req)') + print(' TFetchResultsResp FetchResults(TFetchResultsReq req)') + print(' TGetDelegationTokenResp GetDelegationToken(TGetDelegationTokenReq req)') + print(' TCancelDelegationTokenResp CancelDelegationToken(TCancelDelegationTokenReq req)') + print(' TRenewDelegationTokenResp RenewDelegationToken(TRenewDelegationTokenReq req)') + print('') sys.exit(0) pp = pprint.PrettyPrinter(indent = 2) @@ -50,6 +51,7 @@ host = 'localhost' port = 9090 uri = '' framed = False +ssl = False http = False argi = 1 @@ -78,13 +80,17 @@ if sys.argv[argi] == '-f' or sys.argv[argi] == '-framed': framed = True argi += 1 +if sys.argv[argi] == '-s' or sys.argv[argi] == '-ssl': + ssl = True + argi += 1 + cmd = sys.argv[argi] args = sys.argv[argi+1:] if http: transport = THttpClient.THttpClient(host, port, uri) else: - socket = TSocket.TSocket(host, port) + socket = TSSLSocket.TSSLSocket(host, port, validate=False) if ssl else TSocket.TSocket(host, port) if framed: transport = TTransport.TFramedTransport(socket) else: @@ -95,120 +101,120 @@ transport.open() if cmd == 'OpenSession': if len(args) != 1: - print 'OpenSession requires 1 args' + print('OpenSession requires 1 args') sys.exit(1) pp.pprint(client.OpenSession(eval(args[0]),)) elif cmd == 'CloseSession': if len(args) != 1: - print 'CloseSession requires 1 args' + print('CloseSession requires 1 args') sys.exit(1) pp.pprint(client.CloseSession(eval(args[0]),)) elif cmd == 'GetInfo': if len(args) != 1: - print 'GetInfo requires 1 args' + print('GetInfo requires 1 args') sys.exit(1) pp.pprint(client.GetInfo(eval(args[0]),)) elif cmd == 'ExecuteStatement': if len(args) != 1: - print 'ExecuteStatement requires 1 args' + print('ExecuteStatement requires 1 args') sys.exit(1) pp.pprint(client.ExecuteStatement(eval(args[0]),)) elif cmd == 'GetTypeInfo': if len(args) != 1: - print 'GetTypeInfo requires 1 args' + print('GetTypeInfo requires 1 args') sys.exit(1) pp.pprint(client.GetTypeInfo(eval(args[0]),)) elif cmd == 'GetCatalogs': if len(args) != 1: - print 'GetCatalogs requires 1 args' + print('GetCatalogs requires 1 args') sys.exit(1) pp.pprint(client.GetCatalogs(eval(args[0]),)) elif cmd == 'GetSchemas': if len(args) != 1: - print 'GetSchemas requires 1 args' + print('GetSchemas requires 1 args') sys.exit(1) pp.pprint(client.GetSchemas(eval(args[0]),)) elif cmd == 'GetTables': if len(args) != 1: - print 'GetTables requires 1 args' + print('GetTables requires 1 args') sys.exit(1) pp.pprint(client.GetTables(eval(args[0]),)) elif cmd == 'GetTableTypes': if len(args) != 1: - print 'GetTableTypes requires 1 args' + print('GetTableTypes requires 1 args') sys.exit(1) pp.pprint(client.GetTableTypes(eval(args[0]),)) elif cmd == 'GetColumns': if len(args) != 1: - print 'GetColumns requires 1 args' + print('GetColumns requires 1 args') sys.exit(1) pp.pprint(client.GetColumns(eval(args[0]),)) elif cmd == 'GetFunctions': if len(args) != 1: - print 'GetFunctions requires 1 args' + print('GetFunctions requires 1 args') sys.exit(1) pp.pprint(client.GetFunctions(eval(args[0]),)) elif cmd == 'GetOperationStatus': if len(args) != 1: - print 'GetOperationStatus requires 1 args' + print('GetOperationStatus requires 1 args') sys.exit(1) pp.pprint(client.GetOperationStatus(eval(args[0]),)) elif cmd == 'CancelOperation': if len(args) != 1: - print 'CancelOperation requires 1 args' + print('CancelOperation requires 1 args') sys.exit(1) pp.pprint(client.CancelOperation(eval(args[0]),)) elif cmd == 'CloseOperation': if len(args) != 1: - print 'CloseOperation requires 1 args' + print('CloseOperation requires 1 args') sys.exit(1) pp.pprint(client.CloseOperation(eval(args[0]),)) elif cmd == 'GetResultSetMetadata': if len(args) != 1: - print 'GetResultSetMetadata requires 1 args' + print('GetResultSetMetadata requires 1 args') sys.exit(1) pp.pprint(client.GetResultSetMetadata(eval(args[0]),)) elif cmd == 'FetchResults': if len(args) != 1: - print 'FetchResults requires 1 args' + print('FetchResults requires 1 args') sys.exit(1) pp.pprint(client.FetchResults(eval(args[0]),)) elif cmd == 'GetDelegationToken': if len(args) != 1: - print 'GetDelegationToken requires 1 args' + print('GetDelegationToken requires 1 args') sys.exit(1) pp.pprint(client.GetDelegationToken(eval(args[0]),)) elif cmd == 'CancelDelegationToken': if len(args) != 1: - print 'CancelDelegationToken requires 1 args' + print('CancelDelegationToken requires 1 args') sys.exit(1) pp.pprint(client.CancelDelegationToken(eval(args[0]),)) elif cmd == 'RenewDelegationToken': if len(args) != 1: - print 'RenewDelegationToken requires 1 args' + print('RenewDelegationToken requires 1 args') sys.exit(1) pp.pprint(client.RenewDelegationToken(eval(args[0]),)) else: - print 'Unrecognized method %s' % cmd + print('Unrecognized method %s' % cmd) sys.exit(1) transport.close() http://git-wip-us.apache.org/repos/asf/hive/blob/42216997/service/src/gen/thrift/gen-py/TCLIService/TCLIService.py ---------------------------------------------------------------------- diff --git a/service/src/gen/thrift/gen-py/TCLIService/TCLIService.py b/service/src/gen/thrift/gen-py/TCLIService/TCLIService.py index ebc6574..0067195 100644 --- a/service/src/gen/thrift/gen-py/TCLIService/TCLIService.py +++ b/service/src/gen/thrift/gen-py/TCLIService/TCLIService.py @@ -1,5 +1,5 @@ # -# Autogenerated by Thrift Compiler (0.9.0) +# Autogenerated by Thrift Compiler (0.9.2) # # DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING # @@ -175,16 +175,17 @@ class Client(Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_OpenSession(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_OpenSession(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = OpenSession_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success raise TApplicationException(TApplicationException.MISSING_RESULT, "OpenSession failed: unknown result"); @@ -205,16 +206,17 @@ class Client(Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_CloseSession(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_CloseSession(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = CloseSession_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success raise TApplicationException(TApplicationException.MISSING_RESULT, "CloseSession failed: unknown result"); @@ -235,16 +237,17 @@ class Client(Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_GetInfo(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_GetInfo(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = GetInfo_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success raise TApplicationException(TApplicationException.MISSING_RESULT, "GetInfo failed: unknown result"); @@ -265,16 +268,17 @@ class Client(Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_ExecuteStatement(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_ExecuteStatement(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = ExecuteStatement_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success raise TApplicationException(TApplicationException.MISSING_RESULT, "ExecuteStatement failed: unknown result"); @@ -295,16 +299,17 @@ class Client(Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_GetTypeInfo(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_GetTypeInfo(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = GetTypeInfo_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success raise TApplicationException(TApplicationException.MISSING_RESULT, "GetTypeInfo failed: unknown result"); @@ -325,16 +330,17 @@ class Client(Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_GetCatalogs(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_GetCatalogs(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = GetCatalogs_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success raise TApplicationException(TApplicationException.MISSING_RESULT, "GetCatalogs failed: unknown result"); @@ -355,16 +361,17 @@ class Client(Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_GetSchemas(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_GetSchemas(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = GetSchemas_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success raise TApplicationException(TApplicationException.MISSING_RESULT, "GetSchemas failed: unknown result"); @@ -385,16 +392,17 @@ class Client(Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_GetTables(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_GetTables(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = GetTables_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success raise TApplicationException(TApplicationException.MISSING_RESULT, "GetTables failed: unknown result"); @@ -415,16 +423,17 @@ class Client(Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_GetTableTypes(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_GetTableTypes(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = GetTableTypes_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success raise TApplicationException(TApplicationException.MISSING_RESULT, "GetTableTypes failed: unknown result"); @@ -445,16 +454,17 @@ class Client(Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_GetColumns(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_GetColumns(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = GetColumns_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success raise TApplicationException(TApplicationException.MISSING_RESULT, "GetColumns failed: unknown result"); @@ -475,16 +485,17 @@ class Client(Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_GetFunctions(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_GetFunctions(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = GetFunctions_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success raise TApplicationException(TApplicationException.MISSING_RESULT, "GetFunctions failed: unknown result"); @@ -505,16 +516,17 @@ class Client(Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_GetOperationStatus(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_GetOperationStatus(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = GetOperationStatus_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success raise TApplicationException(TApplicationException.MISSING_RESULT, "GetOperationStatus failed: unknown result"); @@ -535,16 +547,17 @@ class Client(Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_CancelOperation(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_CancelOperation(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = CancelOperation_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success raise TApplicationException(TApplicationException.MISSING_RESULT, "CancelOperation failed: unknown result"); @@ -565,16 +578,17 @@ class Client(Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_CloseOperation(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_CloseOperation(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = CloseOperation_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success raise TApplicationException(TApplicationException.MISSING_RESULT, "CloseOperation failed: unknown result"); @@ -595,16 +609,17 @@ class Client(Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_GetResultSetMetadata(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_GetResultSetMetadata(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = GetResultSetMetadata_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success raise TApplicationException(TApplicationException.MISSING_RESULT, "GetResultSetMetadata failed: unknown result"); @@ -625,16 +640,17 @@ class Client(Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_FetchResults(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_FetchResults(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = FetchResults_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success raise TApplicationException(TApplicationException.MISSING_RESULT, "FetchResults failed: unknown result"); @@ -655,16 +671,17 @@ class Client(Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_GetDelegationToken(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_GetDelegationToken(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = GetDelegationToken_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success raise TApplicationException(TApplicationException.MISSING_RESULT, "GetDelegationToken failed: unknown result"); @@ -685,16 +702,17 @@ class Client(Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_CancelDelegationToken(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_CancelDelegationToken(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = CancelDelegationToken_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success raise TApplicationException(TApplicationException.MISSING_RESULT, "CancelDelegationToken failed: unknown result"); @@ -715,16 +733,17 @@ class Client(Iface): self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_RenewDelegationToken(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + def recv_RenewDelegationToken(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = RenewDelegationToken_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success raise TApplicationException(TApplicationException.MISSING_RESULT, "RenewDelegationToken failed: unknown result"); @@ -1031,6 +1050,11 @@ class OpenSession_args: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.req) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -1091,6 +1115,11 @@ class OpenSession_result: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.success) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -1152,6 +1181,11 @@ class CloseSession_args: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.req) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -1212,6 +1246,11 @@ class CloseSession_result: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.success) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -1273,6 +1312,11 @@ class GetInfo_args: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.req) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -1333,6 +1377,11 @@ class GetInfo_result: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.success) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -1394,6 +1443,11 @@ class ExecuteStatement_args: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.req) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -1454,6 +1508,11 @@ class ExecuteStatement_result: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.success) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -1515,6 +1574,11 @@ class GetTypeInfo_args: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.req) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -1575,6 +1639,11 @@ class GetTypeInfo_result: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.success) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -1636,6 +1705,11 @@ class GetCatalogs_args: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.req) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -1696,6 +1770,11 @@ class GetCatalogs_result: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.success) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -1757,6 +1836,11 @@ class GetSchemas_args: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.req) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -1817,6 +1901,11 @@ class GetSchemas_result: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.success) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -1878,6 +1967,11 @@ class GetTables_args: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.req) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -1938,6 +2032,11 @@ class GetTables_result: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.success) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -1999,6 +2098,11 @@ class GetTableTypes_args: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.req) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -2059,6 +2163,11 @@ class GetTableTypes_result: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.success) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -2120,6 +2229,11 @@ class GetColumns_args: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.req) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -2180,6 +2294,11 @@ class GetColumns_result: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.success) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -2241,6 +2360,11 @@ class GetFunctions_args: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.req) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -2301,6 +2425,11 @@ class GetFunctions_result: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.success) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -2362,6 +2491,11 @@ class GetOperationStatus_args: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.req) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -2422,6 +2556,11 @@ class GetOperationStatus_result: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.success) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -2483,6 +2622,11 @@ class CancelOperation_args: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.req) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -2543,6 +2687,11 @@ class CancelOperation_result: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.success) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -2604,6 +2753,11 @@ class CloseOperation_args: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.req) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -2664,6 +2818,11 @@ class CloseOperation_result: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.success) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -2725,6 +2884,11 @@ class GetResultSetMetadata_args: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.req) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -2785,6 +2949,11 @@ class GetResultSetMetadata_result: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.success) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -2846,6 +3015,11 @@ class FetchResults_args: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.req) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -2906,6 +3080,11 @@ class FetchResults_result: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.success) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -2967,6 +3146,11 @@ class GetDelegationToken_args: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.req) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -3027,6 +3211,11 @@ class GetDelegationToken_result: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.success) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -3088,6 +3277,11 @@ class CancelDelegationToken_args: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.req) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -3148,6 +3342,11 @@ class CancelDelegationToken_result: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.success) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -3209,6 +3408,11 @@ class RenewDelegationToken_args: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.req) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -3269,6 +3473,11 @@ class RenewDelegationToken_result: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.success) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] http://git-wip-us.apache.org/repos/asf/hive/blob/42216997/service/src/gen/thrift/gen-py/TCLIService/constants.py ---------------------------------------------------------------------- diff --git a/service/src/gen/thrift/gen-py/TCLIService/constants.py b/service/src/gen/thrift/gen-py/TCLIService/constants.py index eafcb05..9fb1a86 100644 --- a/service/src/gen/thrift/gen-py/TCLIService/constants.py +++ b/service/src/gen/thrift/gen-py/TCLIService/constants.py @@ -1,5 +1,5 @@ # -# Autogenerated by Thrift Compiler (0.9.0) +# Autogenerated by Thrift Compiler (0.9.2) # # DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING # http://git-wip-us.apache.org/repos/asf/hive/blob/42216997/service/src/gen/thrift/gen-py/TCLIService/ttypes.py ---------------------------------------------------------------------- diff --git a/service/src/gen/thrift/gen-py/TCLIService/ttypes.py b/service/src/gen/thrift/gen-py/TCLIService/ttypes.py index 068727c..efee8ef 100644 --- a/service/src/gen/thrift/gen-py/TCLIService/ttypes.py +++ b/service/src/gen/thrift/gen-py/TCLIService/ttypes.py @@ -1,5 +1,5 @@ # -# Autogenerated by Thrift Compiler (0.9.0) +# Autogenerated by Thrift Compiler (0.9.2) # # DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING # @@ -449,6 +449,12 @@ class TTypeQualifierValue: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.i32Value) + value = (value * 31) ^ hash(self.stringValue) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -486,7 +492,7 @@ class TTypeQualifiers: if fid == 1: if ftype == TType.MAP: self.qualifiers = {} - (_ktype1, _vtype2, _size0 ) = iprot.readMapBegin() + (_ktype1, _vtype2, _size0 ) = iprot.readMapBegin() for _i4 in xrange(_size0): _key5 = iprot.readString(); _val6 = TTypeQualifierValue() @@ -522,6 +528,11 @@ class TTypeQualifiers: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.qualifiers) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -597,6 +608,12 @@ class TPrimitiveTypeEntry: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.type) + value = (value * 31) ^ hash(self.typeQualifiers) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -659,6 +676,11 @@ class TArrayTypeEntry: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.objectTypePtr) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -735,6 +757,12 @@ class TMapTypeEntry: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.keyTypePtr) + value = (value * 31) ^ hash(self.valueTypePtr) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -772,7 +800,7 @@ class TStructTypeEntry: if fid == 1: if ftype == TType.MAP: self.nameToTypePtr = {} - (_ktype10, _vtype11, _size9 ) = iprot.readMapBegin() + (_ktype10, _vtype11, _size9 ) = iprot.readMapBegin() for _i13 in xrange(_size9): _key14 = iprot.readString(); _val15 = iprot.readI32(); @@ -807,6 +835,11 @@ class TStructTypeEntry: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.nameToTypePtr) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -844,7 +877,7 @@ class TUnionTypeEntry: if fid == 1: if ftype == TType.MAP: self.nameToTypePtr = {} - (_ktype19, _vtype20, _size18 ) = iprot.readMapBegin() + (_ktype19, _vtype20, _size18 ) = iprot.readMapBegin() for _i22 in xrange(_size18): _key23 = iprot.readString(); _val24 = iprot.readI32(); @@ -879,6 +912,11 @@ class TUnionTypeEntry: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.nameToTypePtr) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -941,6 +979,11 @@ class TUserDefinedTypeEntry: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.typeClassName) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -1067,6 +1110,16 @@ class TTypeEntry: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.primitiveEntry) + value = (value * 31) ^ hash(self.arrayEntry) + value = (value * 31) ^ hash(self.mapEntry) + value = (value * 31) ^ hash(self.structEntry) + value = (value * 31) ^ hash(self.unionEntry) + value = (value * 31) ^ hash(self.userDefinedTypeEntry) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -1138,6 +1191,11 @@ class TTypeDesc: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.types) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -1241,6 +1299,14 @@ class TColumnDesc: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.columnName) + value = (value * 31) ^ hash(self.typeDesc) + value = (value * 31) ^ hash(self.position) + value = (value * 31) ^ hash(self.comment) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -1312,6 +1378,11 @@ class TTableSchema: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.columns) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -1372,6 +1443,11 @@ class TBoolValue: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.value) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -1432,6 +1508,11 @@ class TByteValue: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.value) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -1492,6 +1573,11 @@ class TI16Value: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.value) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -1552,6 +1638,11 @@ class TI32Value: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.value) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -1612,6 +1703,11 @@ class TI64Value: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.value) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -1672,6 +1768,11 @@ class TDoubleValue: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.value) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -1732,6 +1833,11 @@ class TStringValue: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.value) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -1871,6 +1977,17 @@ class TColumnValue: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.boolVal) + value = (value * 31) ^ hash(self.byteVal) + value = (value * 31) ^ hash(self.i16Val) + value = (value * 31) ^ hash(self.i32Val) + value = (value * 31) ^ hash(self.i64Val) + value = (value * 31) ^ hash(self.doubleVal) + value = (value * 31) ^ hash(self.stringVal) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -1942,6 +2059,11 @@ class TRow: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.colVals) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -2026,6 +2148,12 @@ class TBoolColumn: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.values) + value = (value * 31) ^ hash(self.nulls) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -2110,6 +2238,12 @@ class TByteColumn: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.values) + value = (value * 31) ^ hash(self.nulls) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -2194,6 +2328,12 @@ class TI16Column: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.values) + value = (value * 31) ^ hash(self.nulls) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -2278,6 +2418,12 @@ class TI32Column: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.values) + value = (value * 31) ^ hash(self.nulls) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -2362,6 +2508,12 @@ class TI64Column: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.values) + value = (value * 31) ^ hash(self.nulls) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -2446,6 +2598,12 @@ class TDoubleColumn: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.values) + value = (value * 31) ^ hash(self.nulls) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -2530,6 +2688,12 @@ class TStringColumn: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.values) + value = (value * 31) ^ hash(self.nulls) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -2614,6 +2778,12 @@ class TBinaryColumn: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.values) + value = (value * 31) ^ hash(self.nulls) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -2766,6 +2936,18 @@ class TColumn: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.boolVal) + value = (value * 31) ^ hash(self.byteVal) + value = (value * 31) ^ hash(self.i16Val) + value = (value * 31) ^ hash(self.i32Val) + value = (value * 31) ^ hash(self.i64Val) + value = (value * 31) ^ hash(self.doubleVal) + value = (value * 31) ^ hash(self.stringVal) + value = (value * 31) ^ hash(self.binaryVal) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -2872,6 +3054,13 @@ class TRowSet: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.startRowOffset) + value = (value * 31) ^ hash(self.rows) + value = (value * 31) ^ hash(self.columns) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -2990,6 +3179,15 @@ class TStatus: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.statusCode) + value = (value * 31) ^ hash(self.infoMessages) + value = (value * 31) ^ hash(self.sqlState) + value = (value * 31) ^ hash(self.errorCode) + value = (value * 31) ^ hash(self.errorMessage) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -3066,6 +3264,12 @@ class THandleIdentifier: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.guid) + value = (value * 31) ^ hash(self.secret) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -3129,6 +3333,11 @@ class TSessionHandle: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.sessionId) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -3232,6 +3441,14 @@ class TOperationHandle: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.operationId) + value = (value * 31) ^ hash(self.operationType) + value = (value * 31) ^ hash(self.hasResultSet) + value = (value * 31) ^ hash(self.modifiedRowCount) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -3293,7 +3510,7 @@ class TOpenSessionReq: elif fid == 4: if ftype == TType.MAP: self.configuration = {} - (_ktype126, _vtype127, _size125 ) = iprot.readMapBegin() + (_ktype126, _vtype127, _size125 ) = iprot.readMapBegin() for _i129 in xrange(_size125): _key130 = iprot.readString(); _val131 = iprot.readString(); @@ -3340,6 +3557,14 @@ class TOpenSessionReq: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.client_protocol) + value = (value * 31) ^ hash(self.username) + value = (value * 31) ^ hash(self.password) + value = (value * 31) ^ hash(self.configuration) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -3403,7 +3628,7 @@ class TOpenSessionResp: elif fid == 4: if ftype == TType.MAP: self.configuration = {} - (_ktype135, _vtype136, _size134 ) = iprot.readMapBegin() + (_ktype135, _vtype136, _size134 ) = iprot.readMapBegin() for _i138 in xrange(_size134): _key139 = iprot.readString(); _val140 = iprot.readString(); @@ -3452,6 +3677,14 @@ class TOpenSessionResp: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.status) + value = (value * 31) ^ hash(self.serverProtocolVersion) + value = (value * 31) ^ hash(self.sessionHandle) + value = (value * 31) ^ hash(self.configuration) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -3515,6 +3748,11 @@ class TCloseSessionReq: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.sessionHandle) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -3578,6 +3816,11 @@ class TCloseSessionResp: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.status) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -3698,6 +3941,16 @@ class TGetInfoValue: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.stringValue) + value = (value * 31) ^ hash(self.smallIntValue) + value = (value * 31) ^ hash(self.integerBitmask) + value = (value * 31) ^ hash(self.integerFlag) + value = (value * 31) ^ hash(self.binaryValue) + value = (value * 31) ^ hash(self.lenValue) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -3775,6 +4028,12 @@ class TGetInfoReq: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.sessionHandle) + value = (value * 31) ^ hash(self.infoType) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -3853,6 +4112,12 @@ class TGetInfoResp: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.status) + value = (value * 31) ^ hash(self.infoValue) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -3910,7 +4175,7 @@ class TExecuteStatementReq: elif fid == 3: if ftype == TType.MAP: self.confOverlay = {} - (_ktype144, _vtype145, _size143 ) = iprot.readMapBegin() + (_ktype144, _vtype145, _size143 ) = iprot.readMapBegin() for _i147 in xrange(_size143): _key148 = iprot.readString(); _val149 = iprot.readString(); @@ -3964,6 +4229,14 @@ class TExecuteStatementReq: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.sessionHandle) + value = (value * 31) ^ hash(self.statement) + value = (value * 31) ^ hash(self.confOverlay) + value = (value * 31) ^ hash(self.runAsync) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -4040,6 +4313,12 @@ class TExecuteStatementResp: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.status) + value = (value * 31) ^ hash(self.operationHandle) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -4103,6 +4382,11 @@ class TGetTypeInfoReq: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.sessionHandle) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -4179,6 +4463,12 @@ class TGetTypeInfoResp: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.status) + value = (value * 31) ^ hash(self.operationHandle) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -4242,6 +4532,11 @@ class TGetCatalogsReq: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.sessionHandle) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -4318,6 +4613,12 @@ class TGetCatalogsResp: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.status) + value = (value * 31) ^ hash(self.operationHandle) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -4405,6 +4706,13 @@ class TGetSchemasReq: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.sessionHandle) + value = (value * 31) ^ hash(self.catalogName) + value = (value * 31) ^ hash(self.schemaName) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -4481,6 +4789,12 @@ class TGetSchemasResp: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.status) + value = (value * 31) ^ hash(self.operationHandle) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -4600,6 +4914,15 @@ class TGetTablesReq: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.sessionHandle) + value = (value * 31) ^ hash(self.catalogName) + value = (value * 31) ^ hash(self.schemaName) + value = (value * 31) ^ hash(self.tableName) + value = (value * 31) ^ hash(self.tableTypes) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -4676,6 +4999,12 @@ class TGetTablesResp: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.status) + value = (value * 31) ^ hash(self.operationHandle) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -4739,6 +5068,11 @@ class TGetTableTypesReq: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.sessionHandle) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -4815,6 +5149,12 @@ class TGetTableTypesResp: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.status) + value = (value * 31) ^ hash(self.operationHandle) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -4926,6 +5266,15 @@ class TGetColumnsReq: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.sessionHandle) + value = (value * 31) ^ hash(self.catalogName) + value = (value * 31) ^ hash(self.schemaName) + value = (value * 31) ^ hash(self.tableName) + value = (value * 31) ^ hash(self.columnName) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -5002,6 +5351,12 @@ class TGetColumnsResp: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.status) + value = (value * 31) ^ hash(self.operationHandle) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -5103,6 +5458,14 @@ class TGetFunctionsReq: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.sessionHandle) + value = (value * 31) ^ hash(self.catalogName) + value = (value * 31) ^ hash(self.schemaName) + value = (value * 31) ^ hash(self.functionName) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -5179,6 +5542,12 @@ class TGetFunctionsResp: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.status) + value = (value * 31) ^ hash(self.operationHandle) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -5242,6 +5611,11 @@ class TGetOperationStatusReq: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.operationHandle) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -5353,6 +5727,15 @@ class TGetOperationStatusResp: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.status) + value = (value * 31) ^ hash(self.operationState) + value = (value * 31) ^ hash(self.sqlState) + value = (value * 31) ^ hash(self.errorCode) + value = (value * 31) ^ hash(self.errorMessage) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -5416,6 +5799,11 @@ class TCancelOperationReq: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.operationHandle) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -5479,6 +5867,11 @@ class TCancelOperationResp: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.status) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -5542,6 +5935,11 @@ class TCloseOperationReq: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.operationHandle) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -5605,6 +6003,11 @@ class TCloseOperationResp: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.status) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -5668,6 +6071,11 @@ class TGetResultSetMetadataReq: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.operationHandle) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -5744,6 +6152,12 @@ class TGetResultSetMetadataResp: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.status) + value = (value * 31) ^ hash(self.schema) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -5847,6 +6261,14 @@ class TFetchResultsReq: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.operationHandle) + value = (value * 31) ^ hash(self.orientation) + value = (value * 31) ^ hash(self.maxRows) + value = (value * 31) ^ hash(self.fetchType) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -5935,6 +6357,13 @@ class TFetchResultsResp: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.status) + value = (value * 31) ^ hash(self.hasMoreRows) + value = (value * 31) ^ hash(self.results) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -6026,6 +6455,13 @@ class TGetDelegationTokenReq: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.sessionHandle) + value = (value * 31) ^ hash(self.owner) + value = (value * 31) ^ hash(self.renewer) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -6101,6 +6537,12 @@ class TGetDelegationTokenResp: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.status) + value = (value * 31) ^ hash(self.delegationToken) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -6178,6 +6620,12 @@ class TCancelDelegationTokenReq: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.sessionHandle) + value = (value * 31) ^ hash(self.delegationToken) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -6241,6 +6689,11 @@ class TCancelDelegationTokenResp: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.status) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -6318,6 +6771,12 @@ class TRenewDelegationTokenReq: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.sessionHandle) + value = (value * 31) ^ hash(self.delegationToken) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()] @@ -6381,6 +6840,11 @@ class TRenewDelegationTokenResp: return + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.status) + return value + def __repr__(self): L = ['%s=%r' % (key, value) for key, value in self.__dict__.iteritems()]
