Class: Impala::Protocol::Beeswax::BeeswaxService::Client

Inherits:
Object
  • Object
show all
Includes:
Thrift::Client
Defined in:
lib/impala/protocol/beeswax_service.rb

Direct Known Subclasses

ImpalaService::Client

Instance Method Summary collapse

Instance Method Details

#clean(log_context) ⇒ Object 



191
192
193
194
 
# File 'lib/impala/protocol/beeswax_service.rb', line 191

def clean(log_context)
  send_clean(log_context)
  recv_clean()
end

#close(handle) ⇒ Object 



175
176
177
178
 
# File 'lib/impala/protocol/beeswax_service.rb', line 175

def close(handle)
  send_close(handle)
  recv_close()
end

#dump_config ⇒ Object 



129
130
131
132
 
# File 'lib/impala/protocol/beeswax_service.rb', line 129

def dump_config()
  send_dump_config()
  return recv_dump_config()
end

#echo(s) ⇒ Object 



114
115
116
117
 
# File 'lib/impala/protocol/beeswax_service.rb', line 114

def echo(s)
  send_echo(s)
  return recv_echo()
end

#executeAndWait(query, clientCtx) ⇒ Object 



33
34
35
36
 
# File 'lib/impala/protocol/beeswax_service.rb', line 33

def executeAndWait(query, clientCtx)
  send_executeAndWait(query, clientCtx)
  return recv_executeAndWait()
end

#explain(query) ⇒ Object 



49
50
51
52
 
# File 'lib/impala/protocol/beeswax_service.rb', line 49

def explain(query)
  send_explain(query)
  return recv_explain()
end

#fetch(query_id, start_over, fetch_size) ⇒ Object 



65
66
67
68
 
# File 'lib/impala/protocol/beeswax_service.rb', line 65

def fetch(query_id, start_over, fetch_size)
  send_fetch(query_id, start_over, fetch_size)
  return recv_fetch()
end

#get_default_configuration(include_hadoop) ⇒ Object 



160
161
162
163
 
# File 'lib/impala/protocol/beeswax_service.rb', line 160

def get_default_configuration(include_hadoop)
  send_get_default_configuration(include_hadoop)
  return recv_get_default_configuration()
end

#get_log(context) ⇒ Object 



144
145
146
147
 
# File 'lib/impala/protocol/beeswax_service.rb', line 144

def get_log(context)
  send_get_log(context)
  return recv_get_log()
end

#get_results_metadata(handle) ⇒ Object 



98
99
100
101
 
# File 'lib/impala/protocol/beeswax_service.rb', line 98

def get_results_metadata(handle)
  send_get_results_metadata(handle)
  return recv_get_results_metadata()
end

#get_state(handle) ⇒ Object 



82
83
84
85
 
# File 'lib/impala/protocol/beeswax_service.rb', line 82

def get_state(handle)
  send_get_state(handle)
  return recv_get_state()
end

#query(query) ⇒ Object 



17
18
19
20
 
# File 'lib/impala/protocol/beeswax_service.rb', line 17

def query(query)
  send_query(query)
  return recv_query()
end

#recv_clean ⇒ Object 



200
201
202
203
 
# File 'lib/impala/protocol/beeswax_service.rb', line 200

def recv_clean()
  result = receive_message(Clean_result)
  return
end

#recv_close ⇒ Object 



184
185
186
187
188
189
 
# File 'lib/impala/protocol/beeswax_service.rb', line 184

def recv_close()
  result = receive_message(Close_result)
  raise result.error unless result.error.nil?
  raise result.error2 unless result.error2.nil?
  return
end

#recv_dump_config ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


138
139
140
141
142
 
# File 'lib/impala/protocol/beeswax_service.rb', line 138

def recv_dump_config()
  result = receive_message(Dump_config_result)
  return result.success unless result.success.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'dump_config failed: unknown result')
end

#recv_echo ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


123
124
125
126
127
 
# File 'lib/impala/protocol/beeswax_service.rb', line 123

def recv_echo()
  result = receive_message(Echo_result)
  return result.success unless result.success.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'echo failed: unknown result')
end

#recv_executeAndWait ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


42
43
44
45
46
47
 
# File 'lib/impala/protocol/beeswax_service.rb', line 42

def recv_executeAndWait()
  result = receive_message(ExecuteAndWait_result)
  return result.success unless result.success.nil?
  raise result.error unless result.error.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'executeAndWait failed: unknown result')
end

#recv_explain ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


58
59
60
61
62
63
 
# File 'lib/impala/protocol/beeswax_service.rb', line 58

def recv_explain()
  result = receive_message(Explain_result)
  return result.success unless result.success.nil?
  raise result.error unless result.error.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'explain failed: unknown result')
end

#recv_fetch ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


74
75
76
77
78
79
80
 
# File 'lib/impala/protocol/beeswax_service.rb', line 74

def recv_fetch()
  result = receive_message(Fetch_result)
  return result.success unless result.success.nil?
  raise result.error unless result.error.nil?
  raise result.error2 unless result.error2.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'fetch failed: unknown result')
end

#recv_get_default_configuration ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


169
170
171
172
173
 
# File 'lib/impala/protocol/beeswax_service.rb', line 169

def recv_get_default_configuration()
  result = receive_message(Get_default_configuration_result)
  return result.success unless result.success.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'get_default_configuration failed: unknown result')
end

#recv_get_log ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


153
154
155
156
157
158
 
# File 'lib/impala/protocol/beeswax_service.rb', line 153

def recv_get_log()
  result = receive_message(Get_log_result)
  return result.success unless result.success.nil?
  raise result.error unless result.error.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'get_log failed: unknown result')
end

#recv_get_results_metadata ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


107
108
109
110
111
112
 
# File 'lib/impala/protocol/beeswax_service.rb', line 107

def recv_get_results_metadata()
  result = receive_message(Get_results_metadata_result)
  return result.success unless result.success.nil?
  raise result.error unless result.error.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'get_results_metadata failed: unknown result')
end

#recv_get_state ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


91
92
93
94
95
96
 
# File 'lib/impala/protocol/beeswax_service.rb', line 91

def recv_get_state()
  result = receive_message(Get_state_result)
  return result.success unless result.success.nil?
  raise result.error unless result.error.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'get_state failed: unknown result')
end

#recv_query ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


26
27
28
29
30
31
 
# File 'lib/impala/protocol/beeswax_service.rb', line 26

def recv_query()
  result = receive_message(Query_result)
  return result.success unless result.success.nil?
  raise result.error unless result.error.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'query failed: unknown result')
end

#send_clean(log_context) ⇒ Object 



196
197
198
 
# File 'lib/impala/protocol/beeswax_service.rb', line 196

def send_clean(log_context)
  send_message('clean', Clean_args, :log_context => log_context)
end

#send_close(handle) ⇒ Object 



180
181
182
 
# File 'lib/impala/protocol/beeswax_service.rb', line 180

def send_close(handle)
  send_message('close', Close_args, :handle => handle)
end

#send_dump_config ⇒ Object 



134
135
136
 
# File 'lib/impala/protocol/beeswax_service.rb', line 134

def send_dump_config()
  send_message('dump_config', Dump_config_args)
end

#send_echo(s) ⇒ Object 



119
120
121
 
# File 'lib/impala/protocol/beeswax_service.rb', line 119

def send_echo(s)
  send_message('echo', Echo_args, :s => s)
end

#send_executeAndWait(query, clientCtx) ⇒ Object 



38
39
40
 
# File 'lib/impala/protocol/beeswax_service.rb', line 38

def send_executeAndWait(query, clientCtx)
  send_message('executeAndWait', ExecuteAndWait_args, :query => query, :clientCtx => clientCtx)
end

#send_explain(query) ⇒ Object 



54
55
56
 
# File 'lib/impala/protocol/beeswax_service.rb', line 54

def send_explain(query)
  send_message('explain', Explain_args, :query => query)
end

#send_fetch(query_id, start_over, fetch_size) ⇒ Object 



70
71
72
 
# File 'lib/impala/protocol/beeswax_service.rb', line 70

def send_fetch(query_id, start_over, fetch_size)
  send_message('fetch', Fetch_args, :query_id => query_id, :start_over => start_over, :fetch_size => fetch_size)
end

#send_get_default_configuration(include_hadoop) ⇒ Object 



165
166
167
 
# File 'lib/impala/protocol/beeswax_service.rb', line 165

def send_get_default_configuration(include_hadoop)
  send_message('get_default_configuration', Get_default_configuration_args, :include_hadoop => include_hadoop)
end

#send_get_log(context) ⇒ Object 



149
150
151
 
# File 'lib/impala/protocol/beeswax_service.rb', line 149

def send_get_log(context)
  send_message('get_log', Get_log_args, :context => context)
end

#send_get_results_metadata(handle) ⇒ Object 



103
104
105
 
# File 'lib/impala/protocol/beeswax_service.rb', line 103

def send_get_results_metadata(handle)
  send_message('get_results_metadata', Get_results_metadata_args, :handle => handle)
end

#send_get_state(handle) ⇒ Object 



87
88
89
 
# File 'lib/impala/protocol/beeswax_service.rb', line 87

def send_get_state(handle)
  send_message('get_state', Get_state_args, :handle => handle)
end

#send_query(query) ⇒ Object 



22
23
24
 
# File 'lib/impala/protocol/beeswax_service.rb', line 22

def send_query(query)
  send_message('query', Query_args, :query => query)
end