<s> from thrift . Thrift import TType , TMessageType , TException , TApplicationException <EOL> import logging <EOL> from ttypes import * <EOL> from thrift . Thrift import TProcessor <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 Iface ( object ) : <EOL> def query ( self , query ) : <EOL> """<STR_LIT>""" <EOL> pass <EOL> def executeAndWait ( self , query , clientCtx ) : <EOL> """<STR_LIT>""" <EOL> pass <EOL> def explain ( self , query ) : <EOL> """<STR_LIT>""" <EOL> pass <EOL> def fetch ( self , query_id , start_over , fetch_size ) : <EOL> """<STR_LIT>""" <EOL> pass <EOL> def get_state ( self , handle ) : <EOL> """<STR_LIT>""" <EOL> pass <EOL> def get_results_metadata ( self , handle ) : <EOL> """<STR_LIT>""" <EOL> pass <EOL> def echo ( self , s ) : <EOL> """<STR_LIT>""" <EOL> pass <EOL> def dump_config ( self ) : <EOL> """<STR_LIT>""" <EOL> pass <EOL> def get_log ( self , context ) : <EOL> """<STR_LIT>""" <EOL> pass <EOL> def get_default_configuration ( self , include_hadoop ) : <EOL> """<STR_LIT>""" <EOL> pass <EOL> def close ( self , handle ) : <EOL> """<STR_LIT>""" <EOL> pass <EOL> def clean ( self , log_context ) : <EOL> """<STR_LIT>""" <EOL> pass <EOL> class Client ( Iface ) : <EOL> def __init__ ( self , iprot , oprot = None ) : <EOL> self . _iprot = self . _oprot = iprot <EOL> if oprot is not None : <EOL> self . _oprot = oprot <EOL> self . _seqid = <NUM_LIT:0> <EOL> def query ( self , query ) : <EOL> """<STR_LIT>""" <EOL> self . send_query ( query ) <EOL> return self . recv_query ( ) <EOL> def send_query ( self , query ) : <EOL> self . _oprot . writeMessageBegin ( '<STR_LIT>' , TMessageType . CALL , self . _seqid ) <EOL> args = query_args ( ) <EOL> args . query = query <EOL> args . write ( self . _oprot ) <EOL> self . _oprot . writeMessageEnd ( ) <EOL> self . _oprot . trans . flush ( ) <EOL> def recv_query ( self ) : <EOL> iprot = self . _iprot <EOL> ( fname , mtype , rseqid ) = iprot . readMessageBegin ( ) <EOL> if mtype == TMessageType . EXCEPTION : <EOL> x = TApplicationException ( ) <EOL> x . read ( iprot ) <EOL> iprot . readMessageEnd ( ) <EOL> raise x <EOL> result = query_result ( ) <EOL> result . read ( iprot ) <EOL> iprot . readMessageEnd ( ) <EOL> if result . success is not None : <EOL> return result . success <EOL> if result . error is not None : <EOL> raise result . error <EOL> raise TApplicationException ( TApplicationException . MISSING_RESULT , "<STR_LIT>" ) <EOL> def executeAndWait ( self , query , clientCtx ) : <EOL> """<STR_LIT>""" <EOL> self . send_executeAndWait ( query , clientCtx ) <EOL> return self . recv_executeAndWait ( ) <EOL> def send_executeAndWait ( self , query , clientCtx ) : <EOL> self . _oprot . writeMessageBegin ( '<STR_LIT>' , TMessageType . CALL , self . _seqid ) <EOL> args = executeAndWait_args ( ) <EOL> args . query = query <EOL> args . clientCtx = clientCtx <EOL> args . write ( self . _oprot ) <EOL> self . _oprot . writeMessageEnd ( ) <EOL> self . _oprot . trans . flush ( ) <EOL> def recv_executeAndWait ( self ) : <EOL> iprot = self . _iprot <EOL> ( fname , mtype , rseqid ) = iprot . readMessageBegin ( ) <EOL> if mtype == TMessageType . EXCEPTION : <EOL> x = TApplicationException ( ) <EOL> x . read ( iprot ) <EOL> iprot . readMessageEnd ( ) <EOL> raise x <EOL> result = executeAndWait_result ( ) <EOL> result . read ( iprot ) <EOL> iprot . readMessageEnd ( ) <EOL> if result . success is not None : <EOL> return result . success <EOL> if result . error is not None : <EOL> raise result . error <EOL> raise TApplicationException ( TApplicationException . MISSING_RESULT , "<STR_LIT>" ) <EOL> def explain ( self , query ) : <EOL> """<STR_LIT>""" <EOL> self . send_explain ( query ) <EOL> return self . recv_explain ( ) <EOL> def send_explain ( self , query ) : <EOL> self . _oprot . writeMessageBegin ( '<STR_LIT>' , TMessageType . CALL , self . _seqid ) <EOL> args = explain_args ( ) <EOL> args . query = query <EOL> args . write ( self . _oprot ) <EOL> self . _oprot . writeMessageEnd ( ) <EOL> self . _oprot . trans . flush ( ) <EOL> def recv_explain ( self ) : <EOL> iprot = self . _iprot <EOL> ( fname , mtype , rseqid ) = iprot . readMessageBegin ( ) <EOL> if mtype == TMessageType . EXCEPTION : <EOL> x = TApplicationException ( ) <EOL> x . read ( iprot ) <EOL> iprot . readMessageEnd ( ) <EOL> raise x <EOL> result = explain_result ( ) <EOL> result . read ( iprot ) <EOL> iprot . readMessageEnd ( ) <EOL> if result . success is not None : <EOL> return result . success <EOL> if result . error is not None : <EOL> raise result . error <EOL> raise TApplicationException ( TApplicationException . MISSING_RESULT , "<STR_LIT>" ) <EOL> def fetch ( self , query_id , start_over , fetch_size ) : <EOL> """<STR_LIT>""" <EOL> self . send_fetch ( query_id , start_over , fetch_size ) <EOL> return self . recv_fetch ( ) <EOL> def send_fetch ( self , query_id , start_over , fetch_size ) : <EOL> self . _oprot . writeMessageBegin ( '<STR_LIT>' , TMessageType . CALL , self . _seqid ) <EOL> args = fetch_args ( ) <EOL> args . query_id = query_id <EOL> args . start_over = start_over <EOL> args . fetch_size = fetch_size <EOL> args . write ( self . _oprot ) <EOL> self . _oprot . writeMessageEnd ( ) <EOL> self . _oprot . trans . flush ( ) <EOL> def recv_fetch ( self ) : <EOL> iprot = self . _iprot <EOL> ( fname , mtype , rseqid ) = iprot . readMessageBegin ( ) <EOL> if mtype == TMessageType . EXCEPTION : <EOL> x = TApplicationException ( ) <EOL> x . read ( iprot ) <EOL> iprot . readMessageEnd ( ) <EOL> raise x <EOL> result = fetch_result ( ) <EOL> result . read ( iprot ) <EOL> iprot . readMessageEnd ( ) <EOL> if result . success is not None : <EOL> return result . success <EOL> if result . error is not None : <EOL> raise result . error <EOL> if result . error2 is not None : <EOL> raise result . error2 <EOL> raise TApplicationException ( TApplicationException . MISSING_RESULT , "<STR_LIT>" ) <EOL> def get_state ( self , handle ) : <EOL> """<STR_LIT>""" <EOL> self . send_get_state ( handle ) <EOL> return self . recv_get_state ( ) <EOL> def send_get_state ( self , handle ) : <EOL> self . _oprot . writeMessageBegin ( '<STR_LIT>' , TMessageType . CALL , self . _seqid ) <EOL> args = get_state_args ( ) <EOL> args . handle = handle <EOL> args . write ( self . _oprot ) <EOL> self . _oprot . writeMessageEnd ( ) <EOL> self . _oprot . trans . flush ( ) <EOL> def recv_get_state ( self ) : <EOL> iprot = self . _iprot <EOL> ( fname , mtype , rseqid ) = iprot . readMessageBegin ( ) <EOL> if mtype == TMessageType . EXCEPTION : <EOL> x = TApplicationException ( ) <EOL> x . read ( iprot ) <EOL> iprot . readMessageEnd ( ) <EOL> raise x <EOL> result = get_state_result ( ) <EOL> result . read ( iprot ) <EOL> iprot . readMessageEnd ( ) <EOL> if result . success is not None : <EOL> return result . success <EOL> if result . error is not None : <EOL> raise result . error <EOL> raise TApplicationException ( TApplicationException . MISSING_RESULT , "<STR_LIT>" ) <EOL> def get_results_metadata ( self , handle ) : <EOL> """<STR_LIT>""" <EOL> self . send_get_results_metadata ( handle ) <EOL> return self . recv_get_results_metadata ( ) <EOL> def send_get_results_metadata ( self , handle ) : <EOL> self . _oprot . writeMessageBegin ( '<STR_LIT>' , TMessageType . CALL , self . _seqid ) <EOL> args = get_results_metadata_args ( ) <EOL> args . handle = handle <EOL> args . write ( self . _oprot ) <EOL> self . _oprot . writeMessageEnd ( ) <EOL> self . _oprot . trans . flush ( ) <EOL> def recv_get_results_metadata ( self ) : <EOL> iprot = self . _iprot <EOL> ( fname , mtype , rseqid ) = iprot . readMessageBegin ( ) <EOL> if mtype == TMessageType . EXCEPTION : <EOL> x = TApplicationException ( ) <EOL> x . read ( iprot ) <EOL> iprot . readMessageEnd ( ) <EOL> raise x <EOL> result = get_results_metadata_result ( ) <EOL> result . read ( iprot ) <EOL> iprot . readMessageEnd ( ) <EOL> if result . success is not None : <EOL> return result . success <EOL> if result . error is not None : <EOL> raise result . error <EOL> raise TApplicationException ( TApplicationException . MISSING_RESULT , "<STR_LIT>" ) <EOL> def echo ( self , s ) : <EOL> """<STR_LIT>""" <EOL> self . send_echo ( s ) <EOL> return self . recv_echo ( ) <EOL> def send_echo ( self , s ) : <EOL> self . _oprot . writeMessageBegin ( '<STR_LIT>' , TMessageType . CALL , self . _seqid ) <EOL> args = echo_args ( ) <EOL> args . s = s <EOL> args . write ( self . _oprot ) <EOL> self . _oprot . writeMessageEnd ( ) <EOL> self . _oprot . trans . flush ( ) <EOL> def recv_echo ( self ) : <EOL> iprot = self . _iprot <EOL> ( fname , mtype , rseqid ) = iprot . readMessageBegin ( ) <EOL> if mtype == TMessageType . EXCEPTION : <EOL> x = TApplicationException ( ) <EOL> x . read ( iprot ) <EOL> iprot . readMessageEnd ( ) <EOL> raise x <EOL> result = echo_result ( ) <EOL> result . read ( iprot ) <EOL> iprot . readMessageEnd ( ) <EOL> if result . success is not None : <EOL> return result . success <EOL> raise TApplicationException ( TApplicationException . MISSING_RESULT , "<STR_LIT>" ) <EOL> def dump_config ( self ) : <EOL> """<STR_LIT>""" <EOL> self . send_dump_config ( ) <EOL> return self . recv_dump_config ( ) <EOL> def send_dump_config ( self ) : <EOL> self . _oprot . writeMessageBegin ( '<STR_LIT>' , TMessageType . CALL , self . _seqid ) <EOL> args = dump_config_args ( ) <EOL> args . write ( self . _oprot ) <EOL> self . _oprot . writeMessageEnd ( ) <EOL> self . _oprot . trans . flush ( ) <EOL> def recv_dump_config ( self ) : <EOL> iprot = self . _iprot <EOL> ( fname , mtype , rseqid ) = iprot . readMessageBegin ( ) <EOL> if mtype == TMessageType . EXCEPTION : <EOL> x = TApplicationException ( ) <EOL> x . read ( iprot ) <EOL> iprot . readMessageEnd ( ) <EOL> raise x <EOL> result = dump_config_result ( ) <EOL> result . read ( iprot ) <EOL> iprot . readMessageEnd ( ) <EOL> if result . success is not None : <EOL> return result . success <EOL> raise TApplicationException ( TApplicationException . MISSING_RESULT , "<STR_LIT>" ) <EOL> def get_log ( self , context ) : <EOL> """<STR_LIT>""" <EOL> self . send_get_log ( context ) <EOL> return self . recv_get_log ( ) <EOL> def send_get_log ( self , context ) : <EOL> self . _oprot . writeMessageBegin ( '<STR_LIT>' , TMessageType . CALL , self . _seqid ) <EOL> args = get_log_args ( ) <EOL> args . context = context <EOL> args . write ( self . _oprot ) <EOL> self . _oprot . writeMessageEnd ( ) <EOL> self . _oprot . trans . flush ( ) <EOL> def recv_get_log ( self ) : <EOL> iprot = self . _iprot <EOL> ( fname , mtype , rseqid ) = iprot . readMessageBegin ( ) <EOL> if mtype == TMessageType . EXCEPTION : <EOL> x = TApplicationException ( ) <EOL> x . read ( iprot ) <EOL> iprot . readMessageEnd ( ) <EOL> raise x <EOL> result = get_log_result ( ) <EOL> result . read ( iprot ) <EOL> iprot . readMessageEnd ( ) <EOL> if result . success is not None : <EOL> return result . success <EOL> if result . error is not None : <EOL> raise result . error <EOL> raise TApplicationException ( TApplicationException . MISSING_RESULT , "<STR_LIT>" ) <EOL> def get_default_configuration ( self , include_hadoop ) : <EOL> """<STR_LIT>""" <EOL> self . send_get_default_configuration ( include_hadoop ) <EOL> return self . recv_get_default_configuration ( ) <EOL> def send_get_default_configuration ( self , include_hadoop ) : <EOL> self . _oprot . writeMessageBegin ( '<STR_LIT>' , TMessageType . CALL , self . _seqid ) <EOL> args = get_default_configuration_args ( ) <EOL> args . include_hadoop = include_hadoop <EOL> args . write ( self . _oprot ) <EOL> self . _oprot . writeMessageEnd ( ) <EOL> self . _oprot . trans . flush ( ) <EOL> def recv_get_default_configuration ( self ) : <EOL> iprot = self . _iprot <EOL> ( fname , mtype , rseqid ) = iprot . readMessageBegin ( ) <EOL> if mtype == TMessageType . EXCEPTION : <EOL> x = TApplicationException ( ) <EOL> x . read ( iprot ) <EOL> iprot . readMessageEnd ( ) <EOL> raise x <EOL> result = get_default_configuration_result ( ) <EOL> result . read ( iprot ) <EOL> iprot . readMessageEnd ( ) <EOL> if result . success is not None : <EOL> return result . success <EOL> raise TApplicationException ( TApplicationException . MISSING_RESULT , "<STR_LIT>" ) <EOL> def close ( self , handle ) : <EOL> """<STR_LIT>""" <EOL> self . send_close ( handle ) <EOL> self . recv_close ( ) <EOL> def send_close ( self , handle ) : <EOL> self . _oprot . writeMessageBegin ( '<STR_LIT>' , TMessageType . CALL , self . _seqid ) <EOL> args = close_args ( ) <EOL> args . handle = handle <EOL> args . write ( self . _oprot ) <EOL> self . _oprot . writeMessageEnd ( ) <EOL> self . _oprot . trans . flush ( ) <EOL> def recv_close ( self ) : <EOL> iprot = self . _iprot <EOL> ( fname , mtype , rseqid ) = iprot . readMessageBegin ( ) <EOL> if mtype == TMessageType . EXCEPTION : <EOL> x = TApplicationException ( ) <EOL> x . read ( iprot ) <EOL> iprot . readMessageEnd ( ) <EOL> raise x <EOL> result = close_result ( ) <EOL> result . read ( iprot ) <EOL> iprot . readMessageEnd ( ) <EOL> if result . error is not None : <EOL> raise result . error <EOL> if result . error2 is not None : <EOL> raise result . error2 <EOL> return <EOL> def clean ( self , log_context ) : <EOL> """<STR_LIT>""" <EOL> self . send_clean ( log_context ) <EOL> self . recv_clean ( ) <EOL> def send_clean ( self , log_context ) : <EOL> self . _oprot . writeMessageBegin ( '<STR_LIT>' , TMessageType . CALL , self . _seqid ) <EOL> args = clean_args ( ) <EOL> args . log_context = log_context <EOL> args . write ( self . _oprot ) <EOL> self . _oprot . writeMessageEnd ( ) <EOL> self . _oprot . trans . flush ( ) <EOL> def recv_clean ( self ) : <EOL> iprot = self . _iprot <EOL> ( fname , mtype , rseqid ) = iprot . readMessageBegin ( ) <EOL> if mtype == TMessageType . EXCEPTION : <EOL> x = TApplicationException ( ) <EOL> x . read ( iprot ) <EOL> iprot . readMessageEnd ( ) <EOL> raise x <EOL> result = clean_result ( ) <EOL> result . read ( iprot ) <EOL> iprot . readMessageEnd ( ) <EOL> return <EOL> class Processor ( Iface , TProcessor ) : <EOL> def __init__ ( self , handler ) : <EOL> self . _handler = handler <EOL> self . _processMap = { } <EOL> self . _processMap [ "<STR_LIT>" ] = Processor . process_query <EOL> self . _processMap [ "<STR_LIT>" ] = Processor . process_executeAndWait <EOL> self . _processMap [ "<STR_LIT>" ] = Processor . process_explain <EOL> self . _processMap [ "<STR_LIT>" ] = Processor . process_fetch <EOL> self . _processMap [ "<STR_LIT>" ] = Processor . process_get_state <EOL> self . _processMap [ "<STR_LIT>" ] = Processor . process_get_results_metadata <EOL> self . _processMap [ "<STR_LIT>" ] = Processor . process_echo <EOL> self . _processMap [ "<STR_LIT>" ] = Processor . process_dump_config <EOL> self . _processMap [ "<STR_LIT>" ] = Processor . process_get_log <EOL> self . _processMap [ "<STR_LIT>" ] = Processor . process_get_default_configuration <EOL> self . _processMap [ "<STR_LIT>" ] = Processor . process_close <EOL> self . _processMap [ "<STR_LIT>" ] = Processor . process_clean <EOL> def process ( self , iprot , oprot ) : <EOL> ( name , type , seqid ) = iprot . readMessageBegin ( ) <EOL> if name not in self . _processMap : <EOL> iprot . skip ( TType . STRUCT ) <EOL> iprot . readMessageEnd ( ) <EOL> x = TApplicationException ( TApplicationException . UNKNOWN_METHOD , '<STR_LIT>' % ( name ) ) <EOL> oprot . writeMessageBegin ( name , TMessageType . EXCEPTION , seqid ) <EOL> x . write ( oprot ) <EOL> oprot . writeMessageEnd ( ) <EOL> oprot . trans . flush ( ) <EOL> return <EOL> else : <EOL> self . _processMap [ name ] ( self , seqid , iprot , oprot ) <EOL> return True <EOL> def process_query ( self , seqid , iprot , oprot ) : <EOL> args = query_args ( ) <EOL> args . read ( iprot ) <EOL> iprot . readMessageEnd ( ) <EOL> result = query_result ( ) <EOL> try : <EOL> result . success = self . _handler . query ( args . query ) <EOL> msg_type = TMessageType . REPLY <EOL> except ( TTransport . TTransportException , KeyboardInterrupt , SystemExit ) : <EOL> raise <EOL> except BeeswaxException as error : <EOL> msg_type = TMessageType . REPLY <EOL> result . error = error <EOL> except Exception as ex : <EOL> msg_type = TMessageType . EXCEPTION <EOL> logging . exception ( ex ) <EOL> result = TApplicationException ( TApplicationException . INTERNAL_ERROR , '<STR_LIT>' ) <EOL> oprot . writeMessageBegin ( "<STR_LIT>" , msg_type , seqid ) <EOL> result . write ( oprot ) <EOL> oprot . writeMessageEnd ( ) <EOL> oprot . trans . flush ( ) <EOL> def process_executeAndWait ( self , seqid , iprot , oprot ) : <EOL> args = executeAndWait_args ( ) <EOL> args . read ( iprot ) <EOL> iprot . readMessageEnd ( ) <EOL> result = executeAndWait_result ( ) <EOL> try : <EOL> result . success = self . _handler . executeAndWait ( args . query , args . clientCtx ) <EOL> msg_type = TMessageType . REPLY <EOL> except ( TTransport . TTransportException , KeyboardInterrupt , SystemExit ) : <EOL> raise <EOL> except BeeswaxException as error : <EOL> msg_type = TMessageType . REPLY <EOL> result . error = error <EOL> except Exception as ex : <EOL> msg_type = TMessageType . EXCEPTION <EOL> logging . exception ( ex ) <EOL> result = TApplicationException ( TApplicationException . INTERNAL_ERROR , '<STR_LIT>' ) <EOL> oprot . writeMessageBegin ( "<STR_LIT>" , msg_type , seqid ) <EOL> result . write ( oprot ) <EOL> oprot . writeMessageEnd ( ) <EOL> oprot . trans . flush ( ) <EOL> def process_explain ( self , seqid , iprot , oprot ) : <EOL> args = explain_args ( ) <EOL> args . read ( iprot ) <EOL> iprot . readMessageEnd ( ) <EOL> result = explain_result ( ) <EOL> try : <EOL> result . success = self . _handler . explain ( args . query ) <EOL> msg_type = TMessageType . REPLY <EOL> except ( TTransport . TTransportException , KeyboardInterrupt , SystemExit ) : <EOL> raise <EOL> except BeeswaxException as error : <EOL> msg_type = TMessageType . REPLY <EOL> result . error = error <EOL> except Exception as ex : <EOL> msg_type = TMessageType . EXCEPTION <EOL> logging . exception ( ex ) <EOL> result = TApplicationException ( TApplicationException . INTERNAL_ERROR , '<STR_LIT>' ) <EOL> oprot . writeMessageBegin ( "<STR_LIT>" , msg_type , seqid ) <EOL> result . write ( oprot ) <EOL> oprot . writeMessageEnd ( ) <EOL> oprot . trans . flush ( ) <EOL> def process_fetch ( self , seqid , iprot , oprot ) : <EOL> args = fetch_args ( ) <EOL> args . read ( iprot ) <EOL> iprot . readMessageEnd ( ) <EOL> result = fetch_result ( ) <EOL> try : <EOL> result . success = self . _handler . fetch ( args . query_id , args . start_over , args . fetch_size ) <EOL> msg_type = TMessageType . REPLY <EOL> except ( TTransport . TTransportException , KeyboardInterrupt , SystemExit ) : <EOL> raise <EOL> except QueryNotFoundException as error : <EOL> msg_type = TMessageType . REPLY <EOL> result . error = error <EOL> except BeeswaxException as error2 : <EOL> msg_type = TMessageType . REPLY <EOL> result . error2 = error2 <EOL> except Exception as ex : <EOL> msg_type = TMessageType . EXCEPTION <EOL> logging . exception ( ex ) <EOL> result = TApplicationException ( TApplicationException . INTERNAL_ERROR , '<STR_LIT>' ) <EOL> oprot . writeMessageBegin ( "<STR_LIT>" , msg_type , seqid ) <EOL> result . write ( oprot ) <EOL> oprot . writeMessageEnd ( ) <EOL> oprot . trans . flush ( ) <EOL> def process_get_state ( self , seqid , iprot , oprot ) : <EOL> args = get_state_args ( ) <EOL> args . read ( iprot ) <EOL> iprot . readMessageEnd ( ) <EOL> result = get_state_result ( ) <EOL> try : <EOL> result . success = self . _handler . get_state ( args . handle ) <EOL> msg_type = TMessageType . REPLY <EOL> except ( TTransport . TTransportException , KeyboardInterrupt , SystemExit ) : <EOL> raise <EOL> except QueryNotFoundException as error : <EOL> msg_type = TMessageType . REPLY <EOL> result . error = error <EOL> except Exception as ex : <EOL> msg_type = TMessageType . EXCEPTION <EOL> logging . exception ( ex ) <EOL> result = TApplicationException ( TApplicationException . INTERNAL_ERROR , '<STR_LIT>' ) <EOL> oprot . writeMessageBegin ( "<STR_LIT>" , msg_type , seqid ) <EOL> result . write ( oprot ) <EOL> oprot . writeMessageEnd ( ) <EOL> oprot . trans . flush ( ) <EOL> def process_get_results_metadata ( self , seqid , iprot , oprot ) : <EOL> args = get_results_metadata_args ( ) <EOL> args . read ( iprot ) <EOL> iprot . readMessageEnd ( ) <EOL> result = get_results_metadata_result ( ) <EOL> try : <EOL> result . success = self . _handler . get_results_metadata ( args . handle ) <EOL> msg_type = TMessageType . REPLY <EOL> except ( TTransport . TTransportException , KeyboardInterrupt , SystemExit ) : <EOL> raise <EOL> except QueryNotFoundException as error : <EOL> msg_type = TMessageType . REPLY <EOL> result . error = error <EOL> except Exception as ex : <EOL> msg_type = TMessageType . EXCEPTION <EOL> logging . exception ( ex ) <EOL> result = TApplicationException ( TApplicationException . INTERNAL_ERROR , '<STR_LIT>' ) <EOL> oprot . writeMessageBegin ( "<STR_LIT>" , msg_type , seqid ) <EOL> result . write ( oprot ) <EOL> oprot . writeMessageEnd ( ) <EOL> oprot . trans . flush ( ) <EOL> def process_echo ( self , seqid , iprot , oprot ) : <EOL> args = echo_args ( ) <EOL> args . read ( iprot ) <EOL> iprot . readMessageEnd ( ) <EOL> result = echo_result ( ) <EOL> try : <EOL> result . success = self . _handler . echo ( args . s ) <EOL> msg_type = TMessageType . REPLY <EOL> except ( TTransport . TTransportException , KeyboardInterrupt , SystemExit ) : <EOL> raise <EOL> except Exception as ex : <EOL> msg_type = TMessageType . EXCEPTION <EOL> logging . exception ( ex ) <EOL> result = TApplicationException ( TApplicationException . INTERNAL_ERROR , '<STR_LIT>' ) <EOL> oprot . writeMessageBegin ( "<STR_LIT>" , msg_type , seqid ) <EOL> result . write ( oprot ) <EOL> oprot . writeMessageEnd ( ) <EOL> oprot . trans . flush ( ) <EOL> def process_dump_config ( self , seqid , iprot , oprot ) : <EOL> args = dump_config_args ( ) <EOL> args . read ( iprot ) <EOL> iprot . readMessageEnd ( ) <EOL> result = dump_config_result ( ) <EOL> try : <EOL> result . success = self . _handler . dump_config ( ) <EOL> msg_type = TMessageType . REPLY <EOL> except ( TTransport . TTransportException , KeyboardInterrupt , SystemExit ) : <EOL> raise <EOL> except Exception as ex : <EOL> msg_type = TMessageType . EXCEPTION <EOL> logging . exception ( ex ) <EOL> result = TApplicationException ( TApplicationException . INTERNAL_ERROR , '<STR_LIT>' ) <EOL> oprot . writeMessageBegin ( "<STR_LIT>" , msg_type , seqid ) <EOL> result . write ( oprot ) <EOL> oprot . writeMessageEnd ( ) <EOL> oprot . trans . flush ( ) <EOL> def process_get_log ( self , seqid , iprot , oprot ) : <EOL> args = get_log_args ( ) <EOL> args . read ( iprot ) <EOL> iprot . readMessageEnd ( ) <EOL> result = get_log_result ( ) <EOL> try : <EOL> result . success = self . _handler . get_log ( args . context ) <EOL> msg_type = TMessageType . REPLY <EOL> except ( TTransport . TTransportException , KeyboardInterrupt , SystemExit ) : <EOL> raise <EOL> except QueryNotFoundException as error : <EOL> msg_type = TMessageType . REPLY <EOL> result . error = error <EOL> except Exception as ex : <EOL> msg_type = TMessageType . EXCEPTION <EOL> logging . exception ( ex ) <EOL> result = TApplicationException ( TApplicationException . INTERNAL_ERROR , '<STR_LIT>' ) <EOL> oprot . writeMessageBegin ( "<STR_LIT>" , msg_type , seqid ) <EOL> result . write ( oprot ) <EOL> oprot . writeMessageEnd ( ) <EOL> oprot . trans . flush ( ) <EOL> def process_get_default_configuration ( self , seqid , iprot , oprot ) : <EOL> args = get_default_configuration_args ( ) <EOL> args . read ( iprot ) <EOL> iprot . readMessageEnd ( ) <EOL> result = get_default_configuration_result ( ) <EOL> try : <EOL> result . success = self . _handler . get_default_configuration ( args . include_hadoop ) <EOL> msg_type = TMessageType . REPLY <EOL> except ( TTransport . TTransportException , KeyboardInterrupt , SystemExit ) : <EOL> raise <EOL> except Exception as ex : <EOL> msg_type = TMessageType . EXCEPTION <EOL> logging . exception ( ex ) <EOL> result = TApplicationException ( TApplicationException . INTERNAL_ERROR , '<STR_LIT>' ) <EOL> oprot . writeMessageBegin ( "<STR_LIT>" , msg_type , seqid ) <EOL> result . write ( oprot ) <EOL> oprot . writeMessageEnd ( ) <EOL> oprot . trans . flush ( ) <EOL> def process_close ( self , seqid , iprot , oprot ) : <EOL> args = close_args ( ) <EOL> args . read ( iprot ) <EOL> iprot . readMessageEnd ( ) <EOL> result = close_result ( ) <EOL> try : <EOL> self . _handler . close ( args . handle ) <EOL> msg_type = TMessageType . REPLY <EOL> except ( TTransport . TTransportException , KeyboardInterrupt , SystemExit ) : <EOL> raise <EOL> except QueryNotFoundException as error : <EOL> msg_type = TMessageType . REPLY <EOL> result . error = error <EOL> except BeeswaxException as error2 : <EOL> msg_type = TMessageType . REPLY <EOL> result . error2 = error2 <EOL> except Exception as ex : <EOL> msg_type = TMessageType . EXCEPTION <EOL> logging . exception ( ex ) <EOL> result = TApplicationException ( TApplicationException . INTERNAL_ERROR , '<STR_LIT>' ) <EOL> oprot . writeMessageBegin ( "<STR_LIT>" , msg_type , seqid ) <EOL> result . write ( oprot ) <EOL> oprot . writeMessageEnd ( ) <EOL> oprot . trans . flush ( ) <EOL> def process_clean ( self , seqid , iprot , oprot ) : <EOL> args = clean_args ( ) <EOL> args . read ( iprot ) <EOL> iprot . readMessageEnd ( ) <EOL> result = clean_result ( ) <EOL> try : <EOL> self . _handler . clean ( args . log_context ) <EOL> msg_type = TMessageType . REPLY <EOL> except ( TTransport . TTransportException , KeyboardInterrupt , SystemExit ) : <EOL> raise <EOL> except Exception as ex : <EOL> msg_type = TMessageType . EXCEPTION <EOL> logging . exception ( ex ) <EOL> result = TApplicationException ( TApplicationException . INTERNAL_ERROR , '<STR_LIT>' ) <EOL> oprot . writeMessageBegin ( "<STR_LIT>" , msg_type , seqid ) <EOL> result . write ( oprot ) <EOL> oprot . writeMessageEnd ( ) <EOL> oprot . trans . flush ( ) <EOL> class query_args ( object ) : <EOL> """<STR_LIT>""" <EOL> thrift_spec = ( <EOL> None , <EOL> ( <NUM_LIT:1> , TType . STRUCT , '<STR_LIT>' , ( Query , Query . thrift_spec ) , None , ) , <EOL> ) <EOL> def __init__ ( self , query = None , ) : <EOL> self . query = query <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 . query = Query ( ) <EOL> self . query . 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 . query is not None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . STRUCT , <NUM_LIT:1> ) <EOL> self . query . 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 . query ) <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 query_result ( object ) : <EOL> """<STR_LIT>""" <EOL> thrift_spec = ( <EOL> ( <NUM_LIT:0> , TType . STRUCT , '<STR_LIT:success>' , ( QueryHandle , QueryHandle . thrift_spec ) , None , ) , <EOL> ( <NUM_LIT:1> , TType . STRUCT , '<STR_LIT:error>' , ( BeeswaxException , BeeswaxException . thrift_spec ) , None , ) , <EOL> ) <EOL> def __init__ ( self , success = None , error = None , ) : <EOL> self . success = success <EOL> self . error = error <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:0> : <EOL> if ftype == TType . STRUCT : <EOL> self . success = QueryHandle ( ) <EOL> self . success . read ( iprot ) <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> elif fid == <NUM_LIT:1> : <EOL> if ftype == TType . STRUCT : <EOL> self . error = BeeswaxException ( ) <EOL> self . error . 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 . success is not None : <EOL> oprot . writeFieldBegin ( '<STR_LIT:success>' , TType . STRUCT , <NUM_LIT:0> ) <EOL> self . success . write ( oprot ) <EOL> oprot . writeFieldEnd ( ) <EOL> if self . error is not None : <EOL> oprot . writeFieldBegin ( '<STR_LIT:error>' , TType . STRUCT , <NUM_LIT:1> ) <EOL> self . error . 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 . success ) <EOL> value = ( value * <NUM_LIT> ) ^ hash ( self . error ) <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 executeAndWait_args ( object ) : <EOL> """<STR_LIT>""" <EOL> thrift_spec = ( <EOL> None , <EOL> ( <NUM_LIT:1> , TType . STRUCT , '<STR_LIT>' , ( Query , Query . thrift_spec ) , None , ) , <EOL> ( <NUM_LIT:2> , TType . STRING , '<STR_LIT>' , None , None , ) , <EOL> ) <EOL> def __init__ ( self , query = None , clientCtx = None , ) : <EOL> self . query = query <EOL> self . clientCtx = clientCtx <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 . query = Query ( ) <EOL> self . query . read ( iprot ) <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> elif fid == <NUM_LIT:2> : <EOL> if ftype == TType . STRING : <EOL> self . clientCtx = 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 . query is not None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . STRUCT , <NUM_LIT:1> ) <EOL> self . query . write ( oprot ) <EOL> oprot . writeFieldEnd ( ) <EOL> if self . clientCtx is not None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . STRING , <NUM_LIT:2> ) <EOL> oprot . writeString ( self . clientCtx ) <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 . query ) <EOL> value = ( value * <NUM_LIT> ) ^ hash ( self . clientCtx ) <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 executeAndWait_result ( object ) : <EOL> """<STR_LIT>""" <EOL> thrift_spec = ( <EOL> ( <NUM_LIT:0> , TType . STRUCT , '<STR_LIT:success>' , ( QueryHandle , QueryHandle . thrift_spec ) , None , ) , <EOL> ( <NUM_LIT:1> , TType . STRUCT , '<STR_LIT:error>' , ( BeeswaxException , BeeswaxException . thrift_spec ) , None , ) , <EOL> ) <EOL> def __init__ ( self , success = None , error = None , ) : <EOL> self . success = success <EOL> self . error = error <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:0> : <EOL> if ftype == TType . STRUCT : <EOL> self . success = QueryHandle ( ) <EOL> self . success . read ( iprot ) <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> elif fid == <NUM_LIT:1> : <EOL> if ftype == TType . STRUCT : <EOL> self . error = BeeswaxException ( ) <EOL> self . error . 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 . success is not None : <EOL> oprot . writeFieldBegin ( '<STR_LIT:success>' , TType . STRUCT , <NUM_LIT:0> ) <EOL> self . success . write ( oprot ) <EOL> oprot . writeFieldEnd ( ) <EOL> if self . error is not None : <EOL> oprot . writeFieldBegin ( '<STR_LIT:error>' , TType . STRUCT , <NUM_LIT:1> ) <EOL> self . error . 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 . success ) <EOL> value = ( value * <NUM_LIT> ) ^ hash ( self . error ) <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 explain_args ( object ) : <EOL> """<STR_LIT>""" <EOL> thrift_spec = ( <EOL> None , <EOL> ( <NUM_LIT:1> , TType . STRUCT , '<STR_LIT>' , ( Query , Query . thrift_spec ) , None , ) , <EOL> ) <EOL> def __init__ ( self , query = None , ) : <EOL> self . query = query <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 . query = Query ( ) <EOL> self . query . 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 . query is not None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . STRUCT , <NUM_LIT:1> ) <EOL> self . query . 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 . query ) <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 explain_result ( object ) : <EOL> """<STR_LIT>""" <EOL> thrift_spec = ( <EOL> ( <NUM_LIT:0> , TType . STRUCT , '<STR_LIT:success>' , ( QueryExplanation , QueryExplanation . thrift_spec ) , None , ) , <EOL> ( <NUM_LIT:1> , TType . STRUCT , '<STR_LIT:error>' , ( BeeswaxException , BeeswaxException . thrift_spec ) , None , ) , <EOL> ) <EOL> def __init__ ( self , success = None , error = None , ) : <EOL> self . success = success <EOL> self . error = error <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:0> : <EOL> if ftype == TType . STRUCT : <EOL> self . success = QueryExplanation ( ) <EOL> self . success . read ( iprot ) <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> elif fid == <NUM_LIT:1> : <EOL> if ftype == TType . STRUCT : <EOL> self . error = BeeswaxException ( ) <EOL> self . error . 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 . success is not None : <EOL> oprot . writeFieldBegin ( '<STR_LIT:success>' , TType . STRUCT , <NUM_LIT:0> ) <EOL> self . success . write ( oprot ) <EOL> oprot . writeFieldEnd ( ) <EOL> if self . error is not None : <EOL> oprot . writeFieldBegin ( '<STR_LIT:error>' , TType . STRUCT , <NUM_LIT:1> ) <EOL> self . error . 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 . success ) <EOL> value = ( value * <NUM_LIT> ) ^ hash ( self . error ) <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 fetch_args ( object ) : <EOL> """<STR_LIT>""" <EOL> thrift_spec = ( <EOL> None , <EOL> ( <NUM_LIT:1> , TType . STRUCT , '<STR_LIT>' , ( QueryHandle , QueryHandle . thrift_spec ) , None , ) , <EOL> ( <NUM_LIT:2> , TType . BOOL , '<STR_LIT>' , None , None , ) , <EOL> ( <NUM_LIT:3> , TType . I32 , '<STR_LIT>' , None , - <NUM_LIT:1> , ) , <EOL> ) <EOL> def __init__ ( self , query_id = None , start_over = None , fetch_size = thrift_spec [ <NUM_LIT:3> ] [ <NUM_LIT:4> ] , ) : <EOL> self . query_id = query_id <EOL> self . start_over = start_over <EOL> self . fetch_size = fetch_size <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 . query_id = QueryHandle ( ) <EOL> self . query_id . read ( iprot ) <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> elif fid == <NUM_LIT:2> : <EOL> if ftype == TType . BOOL : <EOL> self . start_over = iprot . readBool ( ) <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> elif fid == <NUM_LIT:3> : <EOL> if ftype == TType . I32 : <EOL> self . fetch_size = iprot . readI32 ( ) <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 . query_id is not None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . STRUCT , <NUM_LIT:1> ) <EOL> self . query_id . write ( oprot ) <EOL> oprot . writeFieldEnd ( ) <EOL> if self . start_over is not None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . BOOL , <NUM_LIT:2> ) <EOL> oprot . writeBool ( self . start_over ) <EOL> oprot . writeFieldEnd ( ) <EOL> if self . fetch_size is not None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . I32 , <NUM_LIT:3> ) <EOL> oprot . writeI32 ( self . fetch_size ) <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 . query_id ) <EOL> value = ( value * <NUM_LIT> ) ^ hash ( self . start_over ) <EOL> value = ( value * <NUM_LIT> ) ^ hash ( self . fetch_size ) <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 fetch_result ( object ) : <EOL> """<STR_LIT>""" <EOL> thrift_spec = ( <EOL> ( <NUM_LIT:0> , TType . STRUCT , '<STR_LIT:success>' , ( Results , Results . thrift_spec ) , None , ) , <EOL> ( <NUM_LIT:1> , TType . STRUCT , '<STR_LIT:error>' , ( QueryNotFoundException , QueryNotFoundException . thrift_spec ) , None , ) , <EOL> ( <NUM_LIT:2> , TType . STRUCT , '<STR_LIT>' , ( BeeswaxException , BeeswaxException . thrift_spec ) , None , ) , <EOL> ) <EOL> def __init__ ( self , success = None , error = None , error2 = None , ) : <EOL> self . success = success <EOL> self . error = error <EOL> self . error2 = error2 <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:0> : <EOL> if ftype == TType . STRUCT : <EOL> self . success = Results ( ) <EOL> self . success . read ( iprot ) <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> elif fid == <NUM_LIT:1> : <EOL> if ftype == TType . STRUCT : <EOL> self . error = QueryNotFoundException ( ) <EOL> self . error . read ( iprot ) <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> elif fid == <NUM_LIT:2> : <EOL> if ftype == TType . STRUCT : <EOL> self . error2 = BeeswaxException ( ) <EOL> self . error2 . 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 . success is not None : <EOL> oprot . writeFieldBegin ( '<STR_LIT:success>' , TType . STRUCT , <NUM_LIT:0> ) <EOL> self . success . write ( oprot ) <EOL> oprot . writeFieldEnd ( ) <EOL> if self . error is not None : <EOL> oprot . writeFieldBegin ( '<STR_LIT:error>' , TType . STRUCT , <NUM_LIT:1> ) <EOL> self . error . write ( oprot ) <EOL> oprot . writeFieldEnd ( ) <EOL> if self . error2 is not None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . STRUCT , <NUM_LIT:2> ) <EOL> self . error2 . 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 . success ) <EOL> value = ( value * <NUM_LIT> ) ^ hash ( self . error ) <EOL> value = ( value * <NUM_LIT> ) ^ hash ( self . error2 ) <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 get_state_args ( object ) : <EOL> """<STR_LIT>""" <EOL> thrift_spec = ( <EOL> None , <EOL> ( <NUM_LIT:1> , TType . STRUCT , '<STR_LIT>' , ( QueryHandle , QueryHandle . thrift_spec ) , None , ) , <EOL> ) <EOL> def __init__ ( self , handle = None , ) : <EOL> self . handle = handle <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 . handle = QueryHandle ( ) <EOL> self . handle . 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 . handle is not None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . STRUCT , <NUM_LIT:1> ) <EOL> self . handle . 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 . handle ) <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 get_state_result ( object ) : <EOL> """<STR_LIT>""" <EOL> thrift_spec = ( <EOL> ( <NUM_LIT:0> , TType . I32 , '<STR_LIT:success>' , None , None , ) , <EOL> ( <NUM_LIT:1> , TType . STRUCT , '<STR_LIT:error>' , ( QueryNotFoundException , QueryNotFoundException . thrift_spec ) , None , ) , <EOL> ) <EOL> def __init__ ( self , success = None , error = None , ) : <EOL> self . success = success <EOL> self . error = error <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:0> : <EOL> if ftype == TType . I32 : <EOL> self . success = iprot . readI32 ( ) <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> elif fid == <NUM_LIT:1> : <EOL> if ftype == TType . STRUCT : <EOL> self . error = QueryNotFoundException ( ) <EOL> self . error . 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 . success is not None : <EOL> oprot . writeFieldBegin ( '<STR_LIT:success>' , TType . I32 , <NUM_LIT:0> ) <EOL> oprot . writeI32 ( self . success ) <EOL> oprot . writeFieldEnd ( ) <EOL> if self . error is not None : <EOL> oprot . writeFieldBegin ( '<STR_LIT:error>' , TType . STRUCT , <NUM_LIT:1> ) <EOL> self . error . 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 . success ) <EOL> value = ( value * <NUM_LIT> ) ^ hash ( self . error ) <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 get_results_metadata_args ( object ) : <EOL> """<STR_LIT>""" <EOL> thrift_spec = ( <EOL> None , <EOL> ( <NUM_LIT:1> , TType . STRUCT , '<STR_LIT>' , ( QueryHandle , QueryHandle . thrift_spec ) , None , ) , <EOL> ) <EOL> def __init__ ( self , handle = None , ) : <EOL> self . handle = handle <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 . handle = QueryHandle ( ) <EOL> self . handle . 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 . handle is not None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . STRUCT , <NUM_LIT:1> ) <EOL> self . handle . 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 . handle ) <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 get_results_metadata_result ( object ) : <EOL> """<STR_LIT>""" <EOL> thrift_spec = ( <EOL> ( <NUM_LIT:0> , TType . STRUCT , '<STR_LIT:success>' , ( ResultsMetadata , ResultsMetadata . thrift_spec ) , None , ) , <EOL> ( <NUM_LIT:1> , TType . STRUCT , '<STR_LIT:error>' , ( QueryNotFoundException , QueryNotFoundException . thrift_spec ) , None , ) , <EOL> ) <EOL> def __init__ ( self , success = None , error = None , ) : <EOL> self . success = success <EOL> self . error = error <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:0> : <EOL> if ftype == TType . STRUCT : <EOL> self . success = ResultsMetadata ( ) <EOL> self . success . read ( iprot ) <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> elif fid == <NUM_LIT:1> : <EOL> if ftype == TType . STRUCT : <EOL> self . error = QueryNotFoundException ( ) <EOL> self . error . 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 . success is not None : <EOL> oprot . writeFieldBegin ( '<STR_LIT:success>' , TType . STRUCT , <NUM_LIT:0> ) <EOL> self . success . write ( oprot ) <EOL> oprot . writeFieldEnd ( ) <EOL> if self . error is not None : <EOL> oprot . writeFieldBegin ( '<STR_LIT:error>' , TType . STRUCT , <NUM_LIT:1> ) <EOL> self . error . 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 . success ) <EOL> value = ( value * <NUM_LIT> ) ^ hash ( self . error ) <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 echo_args ( object ) : <EOL> """<STR_LIT>""" <EOL> thrift_spec = ( <EOL> None , <EOL> ( <NUM_LIT:1> , TType . STRING , '<STR_LIT:s>' , None , None , ) , <EOL> ) <EOL> def __init__ ( self , s = None , ) : <EOL> self . s = s <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 . s = 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 . s is not None : <EOL> oprot . writeFieldBegin ( '<STR_LIT:s>' , TType . STRING , <NUM_LIT:1> ) <EOL> oprot . writeString ( self . s ) <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 . s ) <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 echo_result ( object ) : <EOL> """<STR_LIT>""" <EOL> thrift_spec = ( <EOL> ( <NUM_LIT:0> , TType . STRING , '<STR_LIT:success>' , None , None , ) , <EOL> ) <EOL> def __init__ ( self , success = None , ) : <EOL> self . success = success <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:0> : <EOL> if ftype == TType . STRING : <EOL> self . success = 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 . success is not None : <EOL> oprot . writeFieldBegin ( '<STR_LIT:success>' , TType . STRING , <NUM_LIT:0> ) <EOL> oprot . writeString ( self . success ) <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 . success ) <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 dump_config_args ( object ) : <EOL> thrift_spec = ( <EOL> ) <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> 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> oprot . writeFieldStop ( ) <EOL> oprot . writeStructEnd ( ) <EOL> def validate ( self ) : <EOL> return <EOL> def __hash__ ( self ) : <EOL> value = <NUM_LIT> <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 dump_config_result ( object ) : <EOL> """<STR_LIT>""" <EOL> thrift_spec = ( <EOL> ( <NUM_LIT:0> , TType . STRING , '<STR_LIT:success>' , None , None , ) , <EOL> ) <EOL> def __init__ ( self , success = None , ) : <EOL> self . success = success <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:0> : <EOL> if ftype == TType . STRING : <EOL> self . success = 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 . success is not None : <EOL> oprot . writeFieldBegin ( '<STR_LIT:success>' , TType . STRING , <NUM_LIT:0> ) <EOL> oprot . writeString ( self . success ) <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 . success ) <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 get_log_args ( object ) : <EOL> """<STR_LIT>""" <EOL> thrift_spec = ( <EOL> None , <EOL> ( <NUM_LIT:1> , TType . STRING , '<STR_LIT>' , None , None , ) , <EOL> ) <EOL> def __init__ ( self , context = None , ) : <EOL> self . context = context <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 . context = 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 . context is not None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . STRING , <NUM_LIT:1> ) <EOL> oprot . writeString ( self . context ) <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 . context ) <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 get_log_result ( object ) : <EOL> """<STR_LIT>""" <EOL> thrift_spec = ( <EOL> ( <NUM_LIT:0> , TType . STRING , '<STR_LIT:success>' , None , None , ) , <EOL> ( <NUM_LIT:1> , TType . STRUCT , '<STR_LIT:error>' , ( QueryNotFoundException , QueryNotFoundException . thrift_spec ) , None , ) , <EOL> ) <EOL> def __init__ ( self , success = None , error = None , ) : <EOL> self . success = success <EOL> self . error = error <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:0> : <EOL> if ftype == TType . STRING : <EOL> self . success = iprot . readString ( ) <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> elif fid == <NUM_LIT:1> : <EOL> if ftype == TType . STRUCT : <EOL> self . error = QueryNotFoundException ( ) <EOL> self . error . 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 . success is not None : <EOL> oprot . writeFieldBegin ( '<STR_LIT:success>' , TType . STRING , <NUM_LIT:0> ) <EOL> oprot . writeString ( self . success ) <EOL> oprot . writeFieldEnd ( ) <EOL> if self . error is not None : <EOL> oprot . writeFieldBegin ( '<STR_LIT:error>' , TType . STRUCT , <NUM_LIT:1> ) <EOL> self . error . 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 . success ) <EOL> value = ( value * <NUM_LIT> ) ^ hash ( self . error ) <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 get_default_configuration_args ( object ) : <EOL> """<STR_LIT>""" <EOL> thrift_spec = ( <EOL> None , <EOL> ( <NUM_LIT:1> , TType . BOOL , '<STR_LIT>' , None , None , ) , <EOL> ) <EOL> def __init__ ( self , include_hadoop = None , ) : <EOL> self . include_hadoop = include_hadoop <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 . BOOL : <EOL> self . include_hadoop = iprot . readBool ( ) <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 . include_hadoop is not None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . BOOL , <NUM_LIT:1> ) <EOL> oprot . writeBool ( self . include_hadoop ) <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 . include_hadoop ) <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 get_default_configuration_result ( object ) : <EOL> """<STR_LIT>""" <EOL> thrift_spec = ( <EOL> ( <NUM_LIT:0> , TType . LIST , '<STR_LIT:success>' , ( TType . STRUCT , ( ConfigVariable , ConfigVariable . thrift_spec ) ) , None , ) , <EOL> ) <EOL> def __init__ ( self , success = None , ) : <EOL> self . success = success <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:0> : <EOL> if ftype == TType . LIST : <EOL> self . success = [ ] <EOL> ( _etype24 , _size21 ) = iprot . readListBegin ( ) <EOL> for _i25 in xrange ( _size21 ) : <EOL> _elem26 = ConfigVariable ( ) <EOL> _elem26 . read ( iprot ) <EOL> self . success . append ( _elem26 ) <EOL> iprot . readListEnd ( ) <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 . success is not None : <EOL> oprot . writeFieldBegin ( '<STR_LIT:success>' , TType . LIST , <NUM_LIT:0> ) <EOL> oprot . writeListBegin ( TType . STRUCT , len ( self . success ) ) <EOL> for iter27 in self . success : <EOL> iter27 . write ( oprot ) <EOL> oprot . writeListEnd ( ) <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 . success ) <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 close_args ( object ) : <EOL> """<STR_LIT>""" <EOL> thrift_spec = ( <EOL> None , <EOL> ( <NUM_LIT:1> , TType . STRUCT , '<STR_LIT>' , ( QueryHandle , QueryHandle . thrift_spec ) , None , ) , <EOL> ) <EOL> def __init__ ( self , handle = None , ) : <EOL> self . handle = handle <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 . handle = QueryHandle ( ) <EOL> self . handle . 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 . handle is not None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . STRUCT , <NUM_LIT:1> ) <EOL> self . handle . 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 . handle ) <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 close_result ( object ) : <EOL> """<STR_LIT>""" <EOL> thrift_spec = ( <EOL> None , <EOL> ( <NUM_LIT:1> , TType . STRUCT , '<STR_LIT:error>' , ( QueryNotFoundException , QueryNotFoundException . thrift_spec ) , None , ) , <EOL> ( <NUM_LIT:2> , TType . STRUCT , '<STR_LIT>' , ( BeeswaxException , BeeswaxException . thrift_spec ) , None , ) , <EOL> ) <EOL> def __init__ ( self , error = None , error2 = None , ) : <EOL> self . error = error <EOL> self . error2 = error2 <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 . error = QueryNotFoundException ( ) <EOL> self . error . read ( iprot ) <EOL> else : <EOL> iprot . skip ( ftype ) <EOL> elif fid == <NUM_LIT:2> : <EOL> if ftype == TType . STRUCT : <EOL> self . error2 = BeeswaxException ( ) <EOL> self . error2 . 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 . error is not None : <EOL> oprot . writeFieldBegin ( '<STR_LIT:error>' , TType . STRUCT , <NUM_LIT:1> ) <EOL> self . error . write ( oprot ) <EOL> oprot . writeFieldEnd ( ) <EOL> if self . error2 is not None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . STRUCT , <NUM_LIT:2> ) <EOL> self . error2 . 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 . error ) <EOL> value = ( value * <NUM_LIT> ) ^ hash ( self . error2 ) <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 clean_args ( object ) : <EOL> """<STR_LIT>""" <EOL> thrift_spec = ( <EOL> None , <EOL> ( <NUM_LIT:1> , TType . STRING , '<STR_LIT>' , None , None , ) , <EOL> ) <EOL> def __init__ ( self , log_context = None , ) : <EOL> self . log_context = log_context <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 . log_context = 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 . log_context is not None : <EOL> oprot . writeFieldBegin ( '<STR_LIT>' , TType . STRING , <NUM_LIT:1> ) <EOL> oprot . writeString ( self . log_context ) <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 . log_context ) <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 clean_result ( object ) : <EOL> thrift_spec = ( <EOL> ) <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> 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> oprot . writeFieldStop ( ) <EOL> oprot . writeStructEnd ( ) <EOL> def validate ( self ) : <EOL> return <EOL> def __hash__ ( self ) : <EOL> value = <NUM_LIT> <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>
