Class: Impala::Protocol::ImpalaService::Client
Instance Method Summary
collapse
#clean, #close, #dump_config, #echo, #executeAndWait, #explain, #fetch, #get_default_configuration, #get_log, #get_results_metadata, #get_state, #query, #recv_clean, #recv_close, #recv_dump_config, #recv_echo, #recv_executeAndWait, #recv_explain, #recv_fetch, #recv_get_default_configuration, #recv_get_log, #recv_get_results_metadata, #recv_get_state, #recv_query, #send_clean, #send_close, #send_dump_config, #send_echo, #send_executeAndWait, #send_explain, #send_fetch, #send_get_default_configuration, #send_get_log, #send_get_results_metadata, #send_get_state, #send_query
Instance Method Details
#Cancel(query_id) ⇒ Object
17
18
19
20
|
# File 'lib/impala/protocol/impala_service.rb', line 17
def Cancel(query_id)
send_Cancel(query_id)
return recv_Cancel()
end
|
#CloseInsert(handle) ⇒ Object
48
49
50
51
|
# File 'lib/impala/protocol/impala_service.rb', line 48
def CloseInsert(handle)
send_CloseInsert(handle)
return recv_CloseInsert()
end
|
#PingImpalaService ⇒ Object
65
66
67
68
|
# File 'lib/impala/protocol/impala_service.rb', line 65
def PingImpalaService()
send_PingImpalaService()
recv_PingImpalaService()
end
|
#recv_Cancel ⇒ Object
26
27
28
29
30
31
|
# File 'lib/impala/protocol/impala_service.rb', line 26
def recv_Cancel()
result = receive_message(Cancel_result)
return result.success unless result.success.nil?
raise result.error unless result.error.nil?
raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'Cancel failed: unknown result')
end
|
#recv_CloseInsert ⇒ Object
57
58
59
60
61
62
63
|
# File 'lib/impala/protocol/impala_service.rb', line 57
def recv_CloseInsert()
result = receive_message(CloseInsert_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, 'CloseInsert failed: unknown result')
end
|
#recv_PingImpalaService ⇒ Object
74
75
76
77
|
# File 'lib/impala/protocol/impala_service.rb', line 74
def recv_PingImpalaService()
result = receive_message(PingImpalaService_result)
return
end
|
#recv_ResetCatalog ⇒ Object
42
43
44
45
46
|
# File 'lib/impala/protocol/impala_service.rb', line 42
def recv_ResetCatalog()
result = receive_message(ResetCatalog_result)
return result.success unless result.success.nil?
raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'ResetCatalog failed: unknown result')
end
|
#ResetCatalog ⇒ Object
33
34
35
36
|
# File 'lib/impala/protocol/impala_service.rb', line 33
def ResetCatalog()
send_ResetCatalog()
return recv_ResetCatalog()
end
|
#send_Cancel(query_id) ⇒ Object
22
23
24
|
# File 'lib/impala/protocol/impala_service.rb', line 22
def send_Cancel(query_id)
send_message('Cancel', Cancel_args, :query_id => query_id)
end
|
#send_CloseInsert(handle) ⇒ Object
53
54
55
|
# File 'lib/impala/protocol/impala_service.rb', line 53
def send_CloseInsert(handle)
send_message('CloseInsert', CloseInsert_args, :handle => handle)
end
|
#send_PingImpalaService ⇒ Object
70
71
72
|
# File 'lib/impala/protocol/impala_service.rb', line 70
def send_PingImpalaService()
send_message('PingImpalaService', PingImpalaService_args)
end
|
#send_ResetCatalog ⇒ Object
38
39
40
|
# File 'lib/impala/protocol/impala_service.rb', line 38
def send_ResetCatalog()
send_message('ResetCatalog', ResetCatalog_args)
end
|