Class: Impala::Protocol::ImpalaPlanService::Client

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

Instance Method Summary collapse

Instance Method Details

#CreateExecRequest(clientRequest) ⇒ Object 



16
17
18
19
 
# File 'lib/impala/protocol/impala_plan_service.rb', line 16

def CreateExecRequest(clientRequest)
  send_CreateExecRequest(clientRequest)
  return recv_CreateExecRequest()
end

#GetExplainString(queryRequest) ⇒ Object 



46
47
48
49
 
# File 'lib/impala/protocol/impala_plan_service.rb', line 46

def GetExplainString(queryRequest)
  send_GetExplainString(queryRequest)
  return recv_GetExplainString()
end

#recv_CreateExecRequest ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


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

def recv_CreateExecRequest()
  result = receive_message(CreateExecRequest_result)
  return result.success unless result.success.nil?
  raise result.e unless result.e.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'CreateExecRequest failed: unknown result')
end

#recv_GetExplainString ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


55
56
57
58
59
60
 
# File 'lib/impala/protocol/impala_plan_service.rb', line 55

def recv_GetExplainString()
  result = receive_message(GetExplainString_result)
  return result.success unless result.success.nil?
  raise result.e unless result.e.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'GetExplainString failed: unknown result')
end

#recv_RefreshMetadata ⇒ Object 



41
42
43
44
 
# File 'lib/impala/protocol/impala_plan_service.rb', line 41

def recv_RefreshMetadata()
  result = receive_message(RefreshMetadata_result)
  return
end

#recv_ShutdownServer ⇒ Object 



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

def recv_ShutdownServer()
  result = receive_message(ShutdownServer_result)
  return
end

#recv_UpdateMetastore ⇒ Object 



71
72
73
74
75
 
# File 'lib/impala/protocol/impala_plan_service.rb', line 71

def recv_UpdateMetastore()
  result = receive_message(UpdateMetastore_result)
  raise result.e unless result.e.nil?
  return
end

#RefreshMetadata ⇒ Object 



32
33
34
35
 
# File 'lib/impala/protocol/impala_plan_service.rb', line 32

def RefreshMetadata()
  send_RefreshMetadata()
  recv_RefreshMetadata()
end

#send_CreateExecRequest(clientRequest) ⇒ Object 



21
22
23
 
# File 'lib/impala/protocol/impala_plan_service.rb', line 21

def send_CreateExecRequest(clientRequest)
  send_message('CreateExecRequest', CreateExecRequest_args, :clientRequest => clientRequest)
end

#send_GetExplainString(queryRequest) ⇒ Object 



51
52
53
 
# File 'lib/impala/protocol/impala_plan_service.rb', line 51

def send_GetExplainString(queryRequest)
  send_message('GetExplainString', GetExplainString_args, :queryRequest => queryRequest)
end

#send_RefreshMetadata ⇒ Object 



37
38
39
 
# File 'lib/impala/protocol/impala_plan_service.rb', line 37

def send_RefreshMetadata()
  send_message('RefreshMetadata', RefreshMetadata_args)
end

#send_ShutdownServer ⇒ Object 



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

def send_ShutdownServer()
  send_message('ShutdownServer', ShutdownServer_args)
end

#send_UpdateMetastore(update) ⇒ Object 



67
68
69
 
# File 'lib/impala/protocol/impala_plan_service.rb', line 67

def send_UpdateMetastore(update)
  send_message('UpdateMetastore', UpdateMetastore_args, :update => update)
end

#ShutdownServer ⇒ Object 



77
78
79
80
 
# File 'lib/impala/protocol/impala_plan_service.rb', line 77

def ShutdownServer()
  send_ShutdownServer()
  recv_ShutdownServer()
end

#UpdateMetastore(update) ⇒ Object 



62
63
64
65
 
# File 'lib/impala/protocol/impala_plan_service.rb', line 62

def UpdateMetastore(update)
  send_UpdateMetastore(update)
  recv_UpdateMetastore()
end