<s> from thrift . Thrift import TType , TMessageType , TException , TApplicationException <EOL> import ExecStats . ttypes <EOL> import Status . ttypes <EOL> import Types . ttypes <EOL> import beeswaxd . ttypes <EOL> import TCLIService . ttypes <EOL> from thrift . transport import TTransport <EOL> from thrift . protocol import TBinaryProtocol , TProtocol <EOL> try : <EOL> from thrift . protocol import fastbinary <EOL> except : <EOL> fastbinary = None <EOL> class TImpalaQueryOptions ( object ) : <EOL> ABORT_ON_ERROR = <NUM_LIT:0> <EOL> MAX_ERRORS = <NUM_LIT:1> <EOL> DISABLE_CODEGEN = <NUM_LIT:2> <EOL> BATCH_SIZE = <NUM_LIT:3> <EOL> MEM_LIMIT = <NUM_LIT:4> <EOL> NUM_NODES = <NUM_LIT:5> <EOL> MAX_SCAN_RANGE_LENGTH = <NUM_LIT:6> <EOL> MAX_IO_BUFFERS = <NUM_LIT:7> <EOL> NUM_SCANNER_THREADS = <NUM_LIT:8> <EOL> ALLOW_UNSUPPORTED_FORMATS = <NUM_LIT:9> <EOL> DEFAULT_ORDER_BY_LIMIT = <NUM_LIT:10> <EOL> DEBUG_ACTION = <NUM_LIT:11> <EOL> ABORT_ON_DEFAULT_LIMIT_EXCEEDED = <NUM_LIT:12> <EOL> COMPRESSION_CODEC = <NUM_LIT> <EOL> SEQ_COMPRESSION_MODE = <NUM_LIT> <EOL> HBASE_CACHING = <NUM_LIT:15> <EOL> HBASE_CACHE_BLOCKS = <NUM_LIT:16> <EOL> PARQUET_FILE_SIZE = <NUM_LIT> <EOL> EXPLAIN_LEVEL = <NUM_LIT> <EOL> SYNC_DDL = <NUM_LIT> <EOL> REQUEST_POOL = <NUM_LIT:20> <EOL> V_CPU_CORES = <NUM_LIT> <EOL> RESERVATION_REQUEST_TIMEOUT = <NUM_LIT> <EOL> DISABLE_CACHED_READS = <NUM_LIT> <EOL> DISABLE_OUTERMOST_TOPN = <NUM_LIT> <EOL> RM_INITIAL_MEM = <NUM_LIT> <EOL> QUERY_TIMEOUT_S = <NUM_LIT> <EOL> MAX_BLOCK_MGR_MEMORY = <NUM_LIT> <EOL> APPX_COUNT_DISTINCT = <NUM_LIT> <EOL> DISABLE_UNSAFE_SPILLS = <NUM_LIT> <EOL> EXEC_SINGLE_NODE_ROWS_THRESHOLD = <NUM_LIT:30> <EOL> _VALUES_TO_NAMES = { <EOL> <NUM_LIT:0> : "<STR_LIT>" , <EOL> <NUM_LIT:1> : "<STR_LIT>" , <EOL> <NUM_LIT:2> : "<STR_LIT>" , <EOL> <NUM_LIT:3> : "<STR_LIT>" , <EOL> <NUM_LIT:4> : "<STR_LIT>" , <EOL> <NUM_LIT:5> : "<STR_LIT>" , <EOL> <NUM_LIT:6> : "<STR_LIT>" , <EOL> <NUM_LIT:7> : "<STR_LIT>" , <EOL> <NUM_LIT:8> : "<STR_LIT>" , <EOL> <NUM_LIT:9> : "<STR_LIT>" , <EOL> <NUM_LIT:10> : "<STR_LIT>" , <EOL> <NUM_LIT:11> : "<STR_LIT>" , <EOL> <NUM_LIT:12> : "<STR_LIT>" , <EOL> <NUM_LIT> : "<STR_LIT>" , <EOL> <NUM_LIT> : "<STR_LIT>" , <EOL> <NUM_LIT:15> : "<STR_LIT>" , <EOL> <NUM_LIT:16> : "<STR_LIT>" , <EOL> <NUM_LIT> : "<STR_LIT>" , <EOL> <NUM_LIT> : "<STR_LIT>" , <EOL> <NUM_LIT> : "<STR_LIT>" , <EOL> <NUM_LIT:20> : "<STR_LIT>" , <EOL> <NUM_LIT> : "<STR_LIT>" , <EOL> <NUM_LIT> : "<STR_LIT>" , <EOL> <NUM_LIT> : "<STR_LIT>" , <EOL> <NUM_LIT> : "<STR_LIT>" , <EOL> <NUM_LIT> : "<STR_LIT>" , <EOL> <NUM_LIT> : "<STR_LIT>" , <EOL> <NUM_LIT> : "<STR_LIT>" , <EOL> <NUM_LIT> : "<STR_LIT>" , <EOL> <NUM_LIT> : "<STR_LIT>" , <EOL> <NUM_LIT:30> : "<STR_LIT>" , <EOL> } <EOL> _NAMES_TO_VALUES = { <EOL> "<STR_LIT>" : <NUM_LIT:0> , <EOL> "<STR_LIT>" : <NUM_LIT:1> , <EOL> "<STR_LIT>" : <NUM_LIT:2> , <EOL> "<STR_LIT>" : <NUM_LIT:3> , <EOL> "<STR_LIT>" : <NUM_LIT:4> , <EOL> "<STR_LIT>" : <NUM_LIT:5> , <EOL> "<STR_LIT>" : <NUM_LIT:6> , <EOL> "<STR_LIT>" : <NUM_LIT:7> , <EOL> "<STR_LIT>" : <NUM_LIT:8> , <EOL> "<STR_LIT>" : <NUM_LIT:9> , <EOL> "<STR_LIT>" : <NUM_LIT:10> , <EOL> "<STR_LIT>" : <NUM_LIT:11> , <EOL> "<STR_LIT>" : <NUM_LIT:12> , <EOL> "<STR_LIT>" : <NUM_LIT> , <EOL> "<STR_LIT>" : <NUM_LIT> , <EOL> "<STR_LIT>" : <NUM_LIT:15> , <EOL> "<STR_LIT>" : <NUM_LIT:16> , <EOL> "<STR_LIT>" : <NUM_LIT> , <EOL> "<STR_LIT>" : <NUM_LIT> , <EOL> "<STR_LIT>" : <NUM_LIT> , <EOL> "<STR_LIT>" : <NUM_LIT:20> , <EOL> "<STR_LIT>" : <NUM_LIT> , <EOL> "<STR_LIT>" : <NUM_LIT> , <EOL> "<STR_LIT>" : <NUM_LIT> , <EOL> "<STR_LIT>" : <NUM_LIT> , <EOL> "<STR_LIT>" : <NUM_LIT> , <EOL> "<STR_LIT>" : <NUM_LIT> , <EOL> "<STR_LIT>" : <NUM_LIT> , <EOL> "<STR_LIT>" : <NUM_LIT> , <EOL> "<STR_LIT>" : <NUM_LIT> , <EOL> "<STR_LIT>" : <NUM_LIT:30> , <EOL> } <EOL> class TInsertResult ( object ) : <EOL> """<STR_LIT>""" <EOL> thrift_spec = ( <EOL> None , <EOL> ( <NUM_LIT:1> , TType . MAP , '<STR_LIT>' , ( TType . STRING , None , TType . I64 , None ) , None , ) , <EOL> ) <EOL> def __init__ ( self , rows_appended = None , ) : <EOL> self . rows_appended = rows_appended <EOL> def read ( self , iprot ) : <EOL> if iprot . __class__ == TBinaryProtocol . TBinaryProtocolAccelerated and isinstance ( iprot . trans , TTransport . CReadableTransport ) and self . thrift_spec is not None and fastbinary is not None : <EOL> fastbinary . decode_binary ( self , iprot . trans , ( self . __class__ , self . thrift_spec ) ) <EOL> return <EOL> iprot . readStructBegin ( ) <EOL> while True : <EOL> ( fname , ftype , fid ) = iprot . readFieldBegin ( ) <EOL> if ftype == TType . STOP : <EOL> break <EOL> if fid == <NUM_LIT:1> : <EOL> if ftype == TType . MAP : <EOL> self . rows_appended = { } <EOL> ( _ktype1 , _vtype2 , _size0 ) = iprot . readMapBegin ( ) <EOL> for _i4 in xrange ( _size0 ) : <EOL> _key5 = iprot . readString ( ) <EOL> _val6 = iprot . readI64 ( ) <EOL> self . rows_appended [ _key5 ] = _val6 <EOL> iprot . readMapEnd ( ) <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> iprot . readFieldEnd ( ) <EOL> iprot . readStructEnd ( ) <EOL> def write ( self , oprot ) : <EOL> if oprot . __class__ == TBinaryProtocol . TBinaryProtocolAccelerated and self . thrift_spec is not None and fastbinary is not None : <EOL> oprot . trans . write ( fastbinary . encode_binary ( self , ( self . __class__ , self . thrift_spec ) ) ) <EOL> return <EOL> oprot . writeStructBegin ( '<STR_LIT>' ) <EOL> if self . rows_appended is not None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . MAP , <NUM_LIT:1> ) <EOL> oprot . writeMapBegin ( TType . STRING , TType . I64 , len ( self . rows_appended ) ) <EOL> for kiter7 , viter8 in self . rows_appended . items ( ) : <EOL> oprot . writeString ( kiter7 ) <EOL> oprot . writeI64 ( viter8 ) <EOL> oprot . writeMapEnd ( ) <EOL> oprot . writeFieldEnd ( ) <EOL> oprot . writeFieldStop ( ) <EOL> oprot . writeStructEnd ( ) <EOL> def validate ( self ) : <EOL> if self . rows_appended is None : <EOL> raise TProtocol . TProtocolException ( message = '<STR_LIT>' ) <EOL> return <EOL> def __hash__ ( self ) : <EOL> value = <NUM_LIT> <EOL> value = ( value * <NUM_LIT> ) ^ hash ( self . rows_appended ) <EOL> return value <EOL> def __repr__ ( self ) : <EOL> L = [ '<STR_LIT>' % ( key , value ) <EOL> for key , value in self . __dict__ . iteritems ( ) ] <EOL> return '<STR_LIT>' % ( self . __class__ . __name__ , '<STR_LIT:U+002CU+0020>' . join ( L ) ) <EOL> def __eq__ ( self , other ) : <EOL> return isinstance ( other , self . __class__ ) and self . __dict__ == other . __dict__ <EOL> def __ne__ ( self , other ) : <EOL> return not ( self == other ) <EOL> class TPingImpalaServiceResp ( object ) : <EOL> """<STR_LIT>""" <EOL> thrift_spec = ( <EOL> None , <EOL> ( <NUM_LIT:1> , TType . STRING , '<STR_LIT:version>' , None , None , ) , <EOL> ) <EOL> def __init__ ( self , version = None , ) : <EOL> self . version = version <EOL> def read ( self , iprot ) : <EOL> if iprot . __class__ == TBinaryProtocol . TBinaryProtocolAccelerated and isinstance ( iprot . trans , TTransport . CReadableTransport ) and self . thrift_spec is not None and fastbinary is not None : <EOL> fastbinary . decode_binary ( self , iprot . trans , ( self . __class__ , self . thrift_spec ) ) <EOL> return <EOL> iprot . readStructBegin ( ) <EOL> while True : <EOL> ( fname , ftype , fid ) = iprot . readFieldBegin ( ) <EOL> if ftype == TType . STOP : <EOL> break <EOL> if fid == <NUM_LIT:1> : <EOL> if ftype == TType . STRING : <EOL> self . version = iprot . readString ( ) <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> iprot . readFieldEnd ( ) <EOL> iprot . readStructEnd ( ) <EOL> def write ( self , oprot ) : <EOL> if oprot . __class__ == TBinaryProtocol . TBinaryProtocolAccelerated and self . thrift_spec is not None and fastbinary is not None : <EOL> oprot . trans . write ( fastbinary . encode_binary ( self , ( self . __class__ , self . thrift_spec ) ) ) <EOL> return <EOL> oprot . writeStructBegin ( '<STR_LIT>' ) <EOL> if self . version is not None : <EOL> oprot . writeFieldBegin ( '<STR_LIT:version>' , TType . STRING , <NUM_LIT:1> ) <EOL> oprot . writeString ( self . version ) <EOL> oprot . writeFieldEnd ( ) <EOL> oprot . writeFieldStop ( ) <EOL> oprot . writeStructEnd ( ) <EOL> def validate ( self ) : <EOL> return <EOL> def __hash__ ( self ) : <EOL> value = <NUM_LIT> <EOL> value = ( value * <NUM_LIT> ) ^ hash ( self . version ) <EOL> return value <EOL> def __repr__ ( self ) : <EOL> L = [ '<STR_LIT>' % ( key , value ) <EOL> for key , value in self . __dict__ . iteritems ( ) ] <EOL> return '<STR_LIT>' % ( self . __class__ . __name__ , '<STR_LIT:U+002CU+0020>' . join ( L ) ) <EOL> def __eq__ ( self , other ) : <EOL> return isinstance ( other , self . __class__ ) and self . __dict__ == other . __dict__ <EOL> def __ne__ ( self , other ) : <EOL> return not ( self == other ) <EOL> class TResetTableReq ( object ) : <EOL> """<STR_LIT>""" <EOL> thrift_spec = ( <EOL> None , <EOL> ( <NUM_LIT:1> , TType . STRING , '<STR_LIT>' , None , None , ) , <EOL> ( <NUM_LIT:2> , TType . STRING , '<STR_LIT>' , None , None , ) , <EOL> ) <EOL> def __init__ ( self , db_name = None , table_name = None , ) : <EOL> self . db_name = db_name <EOL> self . table_name = table_name <EOL> def read ( self , iprot ) : <EOL> if iprot . __class__ == TBinaryProtocol . TBinaryProtocolAccelerated and isinstance ( iprot . trans , TTransport . CReadableTransport ) and self . thrift_spec is not None and fastbinary is not None : <EOL> fastbinary . decode_binary ( self , iprot . trans , ( self . __class__ , self . thrift_spec ) ) <EOL> return <EOL> iprot . readStructBegin ( ) <EOL> while True : <EOL> ( fname , ftype , fid ) = iprot . readFieldBegin ( ) <EOL> if ftype == TType . STOP : <EOL> break <EOL> if fid == <NUM_LIT:1> : <EOL> if ftype == TType . STRING : <EOL> self . db_name = iprot . readString ( ) <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> elif fid == <NUM_LIT:2> : <EOL> if ftype == TType . STRING : <EOL> self . table_name = iprot . readString ( ) <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> iprot . readFieldEnd ( ) <EOL> iprot . readStructEnd ( ) <EOL> def write ( self , oprot ) : <EOL> if oprot . __class__ == TBinaryProtocol . TBinaryProtocolAccelerated and self . thrift_spec is not None and fastbinary is not None : <EOL> oprot . trans . write ( fastbinary . encode_binary ( self , ( self . __class__ , self . thrift_spec ) ) ) <EOL> return <EOL> oprot . writeStructBegin ( '<STR_LIT>' ) <EOL> if self . db_name is not None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . STRING , <NUM_LIT:1> ) <EOL> oprot . writeString ( self . db_name ) <EOL> oprot . writeFieldEnd ( ) <EOL> if self . table_name is not None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . STRING , <NUM_LIT:2> ) <EOL> oprot . writeString ( self . table_name ) <EOL> oprot . writeFieldEnd ( ) <EOL> oprot . writeFieldStop ( ) <EOL> oprot . writeStructEnd ( ) <EOL> def validate ( self ) : <EOL> if self . db_name is None : <EOL> raise TProtocol . TProtocolException ( message = '<STR_LIT>' ) <EOL> if self . table_name is None : <EOL> raise TProtocol . TProtocolException ( message = '<STR_LIT>' ) <EOL> return <EOL> def __hash__ ( self ) : <EOL> value = <NUM_LIT> <EOL> value = ( value * <NUM_LIT> ) ^ hash ( self . db_name ) <EOL> value = ( value * <NUM_LIT> ) ^ hash ( self . table_name ) <EOL> return value <EOL> def __repr__ ( self ) : <EOL> L = [ '<STR_LIT>' % ( key , value ) <EOL> for key , value in self . __dict__ . iteritems ( ) ] <EOL> return '<STR_LIT>' % ( self . __class__ . __name__ , '<STR_LIT:U+002CU+0020>' . join ( L ) ) <EOL> def __eq__ ( self , other ) : <EOL> return isinstance ( other , self . __class__ ) and self . __dict__ == other . __dict__ <EOL> def __ne__ ( self , other ) : <EOL> return not ( self == other ) <EOL> class TGetExecSummaryReq ( object ) : <EOL> """<STR_LIT>""" <EOL> thrift_spec = ( <EOL> None , <EOL> ( <NUM_LIT:1> , TType . STRUCT , '<STR_LIT>' , ( TCLIService . ttypes . TOperationHandle , TCLIService . ttypes . TOperationHandle . thrift_spec ) , None , ) , <EOL> ( <NUM_LIT:2> , TType . STRUCT , '<STR_LIT>' , ( TCLIService . ttypes . TSessionHandle , TCLIService . ttypes . TSessionHandle . thrift_spec ) , None , ) , <EOL> ) <EOL> def __init__ ( self , operationHandle = None , sessionHandle = None , ) : <EOL> self . operationHandle = operationHandle <EOL> self . sessionHandle = sessionHandle <EOL> def read ( self , iprot ) : <EOL> if iprot . __class__ == TBinaryProtocol . TBinaryProtocolAccelerated and isinstance ( iprot . trans , TTransport . CReadableTransport ) and self . thrift_spec is not None and fastbinary is not None : <EOL> fastbinary . decode_binary ( self , iprot . trans , ( self . __class__ , self . thrift_spec ) ) <EOL> return <EOL> iprot . readStructBegin ( ) <EOL> while True : <EOL> ( fname , ftype , fid ) = iprot . readFieldBegin ( ) <EOL> if ftype == TType . STOP : <EOL> break <EOL> if fid == <NUM_LIT:1> : <EOL> if ftype == TType . STRUCT : <EOL> self . operationHandle = TCLIService . ttypes . TOperationHandle ( ) <EOL> self . operationHandle . read ( iprot ) <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> elif fid == <NUM_LIT:2> : <EOL> if ftype == TType . STRUCT : <EOL> self . sessionHandle = TCLIService . ttypes . TSessionHandle ( ) <EOL> self . sessionHandle . read ( iprot ) <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> iprot . readFieldEnd ( ) <EOL> iprot . readStructEnd ( ) <EOL> def write ( self , oprot ) : <EOL> if oprot . __class__ == TBinaryProtocol . TBinaryProtocolAccelerated and self . thrift_spec is not None and fastbinary is not None : <EOL> oprot . trans . write ( fastbinary . encode_binary ( self , ( self . __class__ , self . thrift_spec ) ) ) <EOL> return <EOL> oprot . writeStructBegin ( '<STR_LIT>' ) <EOL> if self . operationHandle is not None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . STRUCT , <NUM_LIT:1> ) <EOL> self . operationHandle . write ( oprot ) <EOL> oprot . writeFieldEnd ( ) <EOL> if self . sessionHandle is not None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . STRUCT , <NUM_LIT:2> ) <EOL> self . sessionHandle . write ( oprot ) <EOL> oprot . writeFieldEnd ( ) <EOL> oprot . writeFieldStop ( ) <EOL> oprot . writeStructEnd ( ) <EOL> def validate ( self ) : <EOL> return <EOL> def __hash__ ( self ) : <EOL> value = <NUM_LIT> <EOL> value = ( value * <NUM_LIT> ) ^ hash ( self . operationHandle ) <EOL> value = ( value * <NUM_LIT> ) ^ hash ( self . sessionHandle ) <EOL> return value <EOL> def __repr__ ( self ) : <EOL> L = [ '<STR_LIT>' % ( key , value ) <EOL> for key , value in self . __dict__ . iteritems ( ) ] <EOL> return '<STR_LIT>' % ( self . __class__ . __name__ , '<STR_LIT:U+002CU+0020>' . join ( L ) ) <EOL> def __eq__ ( self , other ) : <EOL> return isinstance ( other , self . __class__ ) and self . __dict__ == other . __dict__ <EOL> def __ne__ ( self , other ) : <EOL> return not ( self == other ) <EOL> class TGetExecSummaryResp ( object ) : <EOL> """<STR_LIT>""" <EOL> thrift_spec = ( <EOL> None , <EOL> ( <NUM_LIT:1> , TType . STRUCT , '<STR_LIT:status>' , ( TCLIService . ttypes . TStatus , TCLIService . ttypes . TStatus . thrift_spec ) , None , ) , <EOL> ( <NUM_LIT:2> , TType . STRUCT , '<STR_LIT>' , ( ExecStats . ttypes . TExecSummary , ExecStats . ttypes . TExecSummary . thrift_spec ) , None , ) , <EOL> ) <EOL> def __init__ ( self , status = None , summary = None , ) : <EOL> self . status = status <EOL> self . summary = summary <EOL> def read ( self , iprot ) : <EOL> if iprot . __class__ == TBinaryProtocol . TBinaryProtocolAccelerated and isinstance ( iprot . trans , TTransport . CReadableTransport ) and self . thrift_spec is not None and fastbinary is not None : <EOL> fastbinary . decode_binary ( self , iprot . trans , ( self . __class__ , self . thrift_spec ) ) <EOL> return <EOL> iprot . readStructBegin ( ) <EOL> while True : <EOL> ( fname , ftype , fid ) = iprot . readFieldBegin ( ) <EOL> if ftype == TType . STOP : <EOL> break <EOL> if fid == <NUM_LIT:1> : <EOL> if ftype == TType . STRUCT : <EOL> self . status = TCLIService . ttypes . TStatus ( ) <EOL> self . status . read ( iprot ) <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> elif fid == <NUM_LIT:2> : <EOL> if ftype == TType . STRUCT : <EOL> self . summary = ExecStats . ttypes . TExecSummary ( ) <EOL> self . summary . read ( iprot ) <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> iprot . readFieldEnd ( ) <EOL> iprot . readStructEnd ( ) <EOL> def write ( self , oprot ) : <EOL> if oprot . __class__ == TBinaryProtocol . TBinaryProtocolAccelerated and self . thrift_spec is not None and fastbinary is not None : <EOL> oprot . trans . write ( fastbinary . encode_binary ( self , ( self . __class__ , self . thrift_spec ) ) ) <EOL> return <EOL> oprot . writeStructBegin ( '<STR_LIT>' ) <EOL> if self . status is not None : <EOL> oprot . writeFieldBegin ( '<STR_LIT:status>' , TType . STRUCT , <NUM_LIT:1> ) <EOL> self . status . write ( oprot ) <EOL> oprot . writeFieldEnd ( ) <EOL> if self . summary is not None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . STRUCT , <NUM_LIT:2> ) <EOL> self . summary . write ( oprot ) <EOL> oprot . writeFieldEnd ( ) <EOL> oprot . writeFieldStop ( ) <EOL> oprot . writeStructEnd ( ) <EOL> def validate ( self ) : <EOL> if self . status is None : <EOL> raise TProtocol . TProtocolException ( message = '<STR_LIT>' ) <EOL> return <EOL> def __hash__ ( self ) : <EOL> value = <NUM_LIT> <EOL> value = ( value * <NUM_LIT> ) ^ hash ( self . status ) <EOL> value = ( value * <NUM_LIT> ) ^ hash ( self . summary ) <EOL> return value <EOL> def __repr__ ( self ) : <EOL> L = [ '<STR_LIT>' % ( key , value ) <EOL> for key , value in self . __dict__ . iteritems ( ) ] <EOL> return '<STR_LIT>' % ( self . __class__ . __name__ , '<STR_LIT:U+002CU+0020>' . join ( L ) ) <EOL> def __eq__ ( self , other ) : <EOL> return isinstance ( other , self . __class__ ) and self . __dict__ == other . __dict__ <EOL> def __ne__ ( self , other ) : <EOL> return not ( self == other ) <EOL> class TGetRuntimeProfileReq ( object ) : <EOL> """<STR_LIT>""" <EOL> thrift_spec = ( <EOL> None , <EOL> ( <NUM_LIT:1> , TType . STRUCT , '<STR_LIT>' , ( TCLIService . ttypes . TOperationHandle , TCLIService . ttypes . TOperationHandle . thrift_spec ) , None , ) , <EOL> ( <NUM_LIT:2> , TType . STRUCT , '<STR_LIT>' , ( TCLIService . ttypes . TSessionHandle , TCLIService . ttypes . TSessionHandle . thrift_spec ) , None , ) , <EOL> ) <EOL> def __init__ ( self , operationHandle = None , sessionHandle = None , ) : <EOL> self . operationHandle = operationHandle <EOL> self . sessionHandle = sessionHandle <EOL> def read ( self , iprot ) : <EOL> if iprot . __class__ == TBinaryProtocol . TBinaryProtocolAccelerated and isinstance ( iprot . trans , TTransport . CReadableTransport ) and self . thrift_spec is not None and fastbinary is not None : <EOL> fastbinary . decode_binary ( self , iprot . trans , ( self . __class__ , self . thrift_spec ) ) <EOL> return <EOL> iprot . readStructBegin ( ) <EOL> while True : <EOL> ( fname , ftype , fid ) = iprot . readFieldBegin ( ) <EOL> if ftype == TType . STOP : <EOL> break <EOL> if fid == <NUM_LIT:1> : <EOL> if ftype == TType . STRUCT : <EOL> self . operationHandle = TCLIService . ttypes . TOperationHandle ( ) <EOL> self . operationHandle . read ( iprot ) <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> elif fid == <NUM_LIT:2> : <EOL> if ftype == TType . STRUCT : <EOL> self . sessionHandle = TCLIService . ttypes . TSessionHandle ( ) <EOL> self . sessionHandle . read ( iprot ) <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> iprot . readFieldEnd ( ) <EOL> iprot . readStructEnd ( ) <EOL> def write ( self , oprot ) : <EOL> if oprot . __class__ == TBinaryProtocol . TBinaryProtocolAccelerated and self . thrift_spec is not None and fastbinary is not None : <EOL> oprot . trans . write ( fastbinary . encode_binary ( self , ( self . __class__ , self . thrift_spec ) ) ) <EOL> return <EOL> oprot . writeStructBegin ( '<STR_LIT>' ) <EOL> if self . operationHandle is not None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . STRUCT , <NUM_LIT:1> ) <EOL> self . operationHandle . write ( oprot ) <EOL> oprot . writeFieldEnd ( ) <EOL> if self . sessionHandle is not None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . STRUCT , <NUM_LIT:2> ) <EOL> self . sessionHandle . write ( oprot ) <EOL> oprot . writeFieldEnd ( ) <EOL> oprot . writeFieldStop ( ) <EOL> oprot . writeStructEnd ( ) <EOL> def validate ( self ) : <EOL> return <EOL> def __hash__ ( self ) : <EOL> value = <NUM_LIT> <EOL> value = ( value * <NUM_LIT> ) ^ hash ( self . operationHandle ) <EOL> value = ( value * <NUM_LIT> ) ^ hash ( self . sessionHandle ) <EOL> return value <EOL> def __repr__ ( self ) : <EOL> L = [ '<STR_LIT>' % ( key , value ) <EOL> for key , value in self . __dict__ . iteritems ( ) ] <EOL> return '<STR_LIT>' % ( self . __class__ . __name__ , '<STR_LIT:U+002CU+0020>' . join ( L ) ) <EOL> def __eq__ ( self , other ) : <EOL> return isinstance ( other , self . __class__ ) and self . __dict__ == other . __dict__ <EOL> def __ne__ ( self , other ) : <EOL> return not ( self == other ) <EOL> class TGetRuntimeProfileResp ( object ) : <EOL> """<STR_LIT>""" <EOL> thrift_spec = ( <EOL> None , <EOL> ( <NUM_LIT:1> , TType . STRUCT , '<STR_LIT:status>' , ( TCLIService . ttypes . TStatus , TCLIService . ttypes . TStatus . thrift_spec ) , None , ) , <EOL> ( <NUM_LIT:2> , TType . STRING , '<STR_LIT>' , None , None , ) , <EOL> ) <EOL> def __init__ ( self , status = None , profile = None , ) : <EOL> self . status = status <EOL> self . profile = profile <EOL> def read ( self , iprot ) : <EOL> if iprot . __class__ == TBinaryProtocol . TBinaryProtocolAccelerated and isinstance ( iprot . trans , TTransport . CReadableTransport ) and self . thrift_spec is not None and fastbinary is not None : <EOL> fastbinary . decode_binary ( self , iprot . trans , ( self . __class__ , self . thrift_spec ) ) <EOL> return <EOL> iprot . readStructBegin ( ) <EOL> while True : <EOL> ( fname , ftype , fid ) = iprot . readFieldBegin ( ) <EOL> if ftype == TType . STOP : <EOL> break <EOL> if fid == <NUM_LIT:1> : <EOL> if ftype == TType . STRUCT : <EOL> self . status = TCLIService . ttypes . TStatus ( ) <EOL> self . status . read ( iprot ) <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> elif fid == <NUM_LIT:2> : <EOL> if ftype == TType . STRING : <EOL> self . profile = iprot . readString ( ) <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> iprot . readFieldEnd ( ) <EOL> iprot . readStructEnd ( ) <EOL> def write ( self , oprot ) : <EOL> if oprot . __class__ == TBinaryProtocol . TBinaryProtocolAccelerated and self . thrift_spec is not None and fastbinary is not None : <EOL> oprot . trans . write ( fastbinary . encode_binary ( self , ( self . __class__ , self . thrift_spec ) ) ) <EOL> return <EOL> oprot . writeStructBegin ( '<STR_LIT>' ) <EOL> if self . status is not None : <EOL> oprot . writeFieldBegin ( '<STR_LIT:status>' , TType . STRUCT , <NUM_LIT:1> ) <EOL> self . status . write ( oprot ) <EOL> oprot . writeFieldEnd ( ) <EOL> if self . profile is not None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . STRING , <NUM_LIT:2> ) <EOL> oprot . writeString ( self . profile ) <EOL> oprot . writeFieldEnd ( ) <EOL> oprot . writeFieldStop ( ) <EOL> oprot . writeStructEnd ( ) <EOL> def validate ( self ) : <EOL> if self . status is None : <EOL> raise TProtocol . TProtocolException ( message = '<STR_LIT>' ) <EOL> return <EOL> def __hash__ ( self ) : <EOL> value = <NUM_LIT> <EOL> value = ( value * <NUM_LIT> ) ^ hash ( self . status ) <EOL> value = ( value * <NUM_LIT> ) ^ hash ( self . profile ) <EOL> return value <EOL> def __repr__ ( self ) : <EOL> L = [ '<STR_LIT>' % ( key , value ) <EOL> for key , value in self . __dict__ . iteritems ( ) ] <EOL> return '<STR_LIT>' % ( self . __class__ . __name__ , '<STR_LIT:U+002CU+0020>' . join ( L ) ) <EOL> def __eq__ ( self , other ) : <EOL> return isinstance ( other , self . __class__ ) and self . __dict__ == other . __dict__ <EOL> def __ne__ ( self , other ) : <EOL> return not ( self == other ) </s>
