class Impala::Protocol::Beeswax::BeeswaxService::Client

Public Instance Methods

clean(log_context) click to toggle source
    # File lib/impala/protocol/beeswax_service.rb
191 def clean(log_context)
192   send_clean(log_context)
193   recv_clean()
194 end
close(handle) click to toggle source
    # File lib/impala/protocol/beeswax_service.rb
175 def close(handle)
176   send_close(handle)
177   recv_close()
178 end
dump_config() click to toggle source
    # File lib/impala/protocol/beeswax_service.rb
129 def dump_config()
130   send_dump_config()
131   return recv_dump_config()
132 end
echo(s) click to toggle source
    # File lib/impala/protocol/beeswax_service.rb
114 def echo(s)
115   send_echo(s)
116   return recv_echo()
117 end
executeAndWait(query, clientCtx) click to toggle source
   # File lib/impala/protocol/beeswax_service.rb
33 def executeAndWait(query, clientCtx)
34   send_executeAndWait(query, clientCtx)
35   return recv_executeAndWait()
36 end
explain(query) click to toggle source
   # File lib/impala/protocol/beeswax_service.rb
49 def explain(query)
50   send_explain(query)
51   return recv_explain()
52 end
fetch(query_id, start_over, fetch_size) click to toggle source
   # File lib/impala/protocol/beeswax_service.rb
65 def fetch(query_id, start_over, fetch_size)
66   send_fetch(query_id, start_over, fetch_size)
67   return recv_fetch()
68 end
get_default_configuration(include_hadoop) click to toggle source
    # File lib/impala/protocol/beeswax_service.rb
160 def get_default_configuration(include_hadoop)
161   send_get_default_configuration(include_hadoop)
162   return recv_get_default_configuration()
163 end
get_log(context) click to toggle source
    # File lib/impala/protocol/beeswax_service.rb
144 def get_log(context)
145   send_get_log(context)
146   return recv_get_log()
147 end
get_results_metadata(handle) click to toggle source
    # File lib/impala/protocol/beeswax_service.rb
 98 def get_results_metadata(handle)
 99   send_get_results_metadata(handle)
100   return recv_get_results_metadata()
101 end
get_state(handle) click to toggle source
   # File lib/impala/protocol/beeswax_service.rb
82 def get_state(handle)
83   send_get_state(handle)
84   return recv_get_state()
85 end
query(query) click to toggle source
   # File lib/impala/protocol/beeswax_service.rb
17 def query(query)
18   send_query(query)
19   return recv_query()
20 end
recv_clean() click to toggle source
    # File lib/impala/protocol/beeswax_service.rb
200 def recv_clean()
201   result = receive_message(Clean_result)
202   return
203 end
recv_close() click to toggle source
    # File lib/impala/protocol/beeswax_service.rb
184 def recv_close()
185   result = receive_message(Close_result)
186   raise result.error unless result.error.nil?
187   raise result.error2 unless result.error2.nil?
188   return
189 end
recv_dump_config() click to toggle source
    # File lib/impala/protocol/beeswax_service.rb
138 def recv_dump_config()
139   result = receive_message(Dump_config_result)
140   return result.success unless result.success.nil?
141   raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'dump_config failed: unknown result')
142 end
recv_echo() click to toggle source
    # File lib/impala/protocol/beeswax_service.rb
123 def recv_echo()
124   result = receive_message(Echo_result)
125   return result.success unless result.success.nil?
126   raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'echo failed: unknown result')
127 end
recv_executeAndWait() click to toggle source
   # File lib/impala/protocol/beeswax_service.rb
42 def recv_executeAndWait()
43   result = receive_message(ExecuteAndWait_result)
44   return result.success unless result.success.nil?
45   raise result.error unless result.error.nil?
46   raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'executeAndWait failed: unknown result')
47 end
recv_explain() click to toggle source
   # File lib/impala/protocol/beeswax_service.rb
58 def recv_explain()
59   result = receive_message(Explain_result)
60   return result.success unless result.success.nil?
61   raise result.error unless result.error.nil?
62   raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'explain failed: unknown result')
63 end
recv_fetch() click to toggle source
   # File lib/impala/protocol/beeswax_service.rb
74 def recv_fetch()
75   result = receive_message(Fetch_result)
76   return result.success unless result.success.nil?
77   raise result.error unless result.error.nil?
78   raise result.error2 unless result.error2.nil?
79   raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'fetch failed: unknown result')
80 end
recv_get_default_configuration() click to toggle source
    # File lib/impala/protocol/beeswax_service.rb
169 def recv_get_default_configuration()
170   result = receive_message(Get_default_configuration_result)
171   return result.success unless result.success.nil?
172   raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'get_default_configuration failed: unknown result')
173 end
recv_get_log() click to toggle source
    # File lib/impala/protocol/beeswax_service.rb
153 def recv_get_log()
154   result = receive_message(Get_log_result)
155   return result.success unless result.success.nil?
156   raise result.error unless result.error.nil?
157   raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'get_log failed: unknown result')
158 end
recv_get_results_metadata() click to toggle source
    # File lib/impala/protocol/beeswax_service.rb
107 def recv_get_results_metadata()
108   result = receive_message(Get_results_metadata_result)
109   return result.success unless result.success.nil?
110   raise result.error unless result.error.nil?
111   raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'get_results_metadata failed: unknown result')
112 end
recv_get_state() click to toggle source
   # File lib/impala/protocol/beeswax_service.rb
91 def recv_get_state()
92   result = receive_message(Get_state_result)
93   return result.success unless result.success.nil?
94   raise result.error unless result.error.nil?
95   raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'get_state failed: unknown result')
96 end
recv_query() click to toggle source
   # File lib/impala/protocol/beeswax_service.rb
26 def recv_query()
27   result = receive_message(Query_result)
28   return result.success unless result.success.nil?
29   raise result.error unless result.error.nil?
30   raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'query failed: unknown result')
31 end
send_clean(log_context) click to toggle source
    # File lib/impala/protocol/beeswax_service.rb
196 def send_clean(log_context)
197   send_message('clean', Clean_args, :log_context => log_context)
198 end
send_close(handle) click to toggle source
    # File lib/impala/protocol/beeswax_service.rb
180 def send_close(handle)
181   send_message('close', Close_args, :handle => handle)
182 end
send_dump_config() click to toggle source
    # File lib/impala/protocol/beeswax_service.rb
134 def send_dump_config()
135   send_message('dump_config', Dump_config_args)
136 end
send_echo(s) click to toggle source
    # File lib/impala/protocol/beeswax_service.rb
119 def send_echo(s)
120   send_message('echo', Echo_args, :s => s)
121 end
send_executeAndWait(query, clientCtx) click to toggle source
   # File lib/impala/protocol/beeswax_service.rb
38 def send_executeAndWait(query, clientCtx)
39   send_message('executeAndWait', ExecuteAndWait_args, :query => query, :clientCtx => clientCtx)
40 end
send_explain(query) click to toggle source
   # File lib/impala/protocol/beeswax_service.rb
54 def send_explain(query)
55   send_message('explain', Explain_args, :query => query)
56 end
send_fetch(query_id, start_over, fetch_size) click to toggle source
   # File lib/impala/protocol/beeswax_service.rb
70 def send_fetch(query_id, start_over, fetch_size)
71   send_message('fetch', Fetch_args, :query_id => query_id, :start_over => start_over, :fetch_size => fetch_size)
72 end
send_get_default_configuration(include_hadoop) click to toggle source
    # File lib/impala/protocol/beeswax_service.rb
165 def send_get_default_configuration(include_hadoop)
166   send_message('get_default_configuration', Get_default_configuration_args, :include_hadoop => include_hadoop)
167 end
send_get_log(context) click to toggle source
    # File lib/impala/protocol/beeswax_service.rb
149 def send_get_log(context)
150   send_message('get_log', Get_log_args, :context => context)
151 end
send_get_results_metadata(handle) click to toggle source
    # File lib/impala/protocol/beeswax_service.rb
103 def send_get_results_metadata(handle)
104   send_message('get_results_metadata', Get_results_metadata_args, :handle => handle)
105 end
send_get_state(handle) click to toggle source
   # File lib/impala/protocol/beeswax_service.rb
87 def send_get_state(handle)
88   send_message('get_state', Get_state_args, :handle => handle)
89 end
send_query(query) click to toggle source
   # File lib/impala/protocol/beeswax_service.rb
22 def send_query(query)
23   send_message('query', Query_args, :query => query)
24 end