Class: Impala::Protocol::ImpalaService::Client

Inherits:
Beeswax::BeeswaxService::Client show all
Includes:
Thrift::Client
Defined in:
lib/impala/protocol/impala_service.rb

Instance Method Summary collapse

Methods inherited from Beeswax::BeeswaxService::Client

#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

Raises:

  • (::Thrift::ApplicationException) 


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

Raises:

  • (::Thrift::ApplicationException) 


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

Raises:

  • (::Thrift::ApplicationException) 


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