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
79
80
81
82
|
# File 'lib/impala/protocol/impala_service.rb', line 79
def CloseInsert(handle)
send_CloseInsert(handle)
return recv_CloseInsert()
end
|
#GetRuntimeProfile(query_id) ⇒ Object
63
64
65
66
|
# File 'lib/impala/protocol/impala_service.rb', line 63
def GetRuntimeProfile(query_id)
send_GetRuntimeProfile(query_id)
return recv_GetRuntimeProfile()
end
|
#PingImpalaService ⇒ Object
96
97
98
99
|
# File 'lib/impala/protocol/impala_service.rb', line 96
def PingImpalaService()
send_PingImpalaService()
return 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
88
89
90
91
92
93
94
|
# File 'lib/impala/protocol/impala_service.rb', line 88
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_GetRuntimeProfile ⇒ Object
72
73
74
75
76
77
|
# File 'lib/impala/protocol/impala_service.rb', line 72
def recv_GetRuntimeProfile()
result = receive_message(GetRuntimeProfile_result)
return result.success unless result.success.nil?
raise result.error unless result.error.nil?
raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'GetRuntimeProfile failed: unknown result')
end
|
#recv_PingImpalaService ⇒ Object
105
106
107
108
109
|
# File 'lib/impala/protocol/impala_service.rb', line 105
def recv_PingImpalaService()
result = receive_message(PingImpalaService_result)
return result.success unless result.success.nil?
raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'PingImpalaService failed: unknown result')
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
|
#recv_ResetTable ⇒ Object
57
58
59
60
61
|
# File 'lib/impala/protocol/impala_service.rb', line 57
def recv_ResetTable()
result = receive_message(ResetTable_result)
return result.success unless result.success.nil?
raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'ResetTable 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
|
#ResetTable(request) ⇒ Object
48
49
50
51
|
# File 'lib/impala/protocol/impala_service.rb', line 48
def ResetTable(request)
send_ResetTable(request)
return recv_ResetTable()
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
84
85
86
|
# File 'lib/impala/protocol/impala_service.rb', line 84
def send_CloseInsert(handle)
send_message('CloseInsert', CloseInsert_args, :handle => handle)
end
|
#send_GetRuntimeProfile(query_id) ⇒ Object
68
69
70
|
# File 'lib/impala/protocol/impala_service.rb', line 68
def send_GetRuntimeProfile(query_id)
send_message('GetRuntimeProfile', GetRuntimeProfile_args, :query_id => query_id)
end
|
#send_PingImpalaService ⇒ Object
101
102
103
|
# File 'lib/impala/protocol/impala_service.rb', line 101
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
|
#send_ResetTable(request) ⇒ Object
53
54
55
|
# File 'lib/impala/protocol/impala_service.rb', line 53
def send_ResetTable(request)
send_message('ResetTable', ResetTable_args, :request => request)
end
|