You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by su...@apache.org on 2015/07/17 21:52:54 UTC
[02/48] hive git commit: HIVE-9152 - Dynamic Partition Pruning [Spark
Branch] (Chao Sun, reviewed by Xuefu Zhang and Chengxiang Li)
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()]