Class: Impala::Protocol::ImpalaInternalService::Client

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

Instance Method Summary collapse

Instance Method Details

#CancelPlanFragment(params) ⇒ Object 



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

def CancelPlanFragment(params)
  send_CancelPlanFragment(params)
  return recv_CancelPlanFragment()
end

#ExecPlanFragment(params) ⇒ Object 



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

def ExecPlanFragment(params)
  send_ExecPlanFragment(params)
  return recv_ExecPlanFragment()
end

#recv_CancelPlanFragment ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


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

def recv_CancelPlanFragment()
  result = receive_message(CancelPlanFragment_result)
  return result.success unless result.success.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'CancelPlanFragment failed: unknown result')
end

#recv_ExecPlanFragment ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


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

def recv_ExecPlanFragment()
  result = receive_message(ExecPlanFragment_result)
  return result.success unless result.success.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'ExecPlanFragment failed: unknown result')
end

#recv_ReportExecStatus ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


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

def recv_ReportExecStatus()
  result = receive_message(ReportExecStatus_result)
  return result.success unless result.success.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'ReportExecStatus failed: unknown result')
end

#recv_TransmitData ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


70
71
72
73
74
 
# File 'lib/impala/protocol/impala_internal_service.rb', line 70

def recv_TransmitData()
  result = receive_message(TransmitData_result)
  return result.success unless result.success.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'TransmitData failed: unknown result')
end

#ReportExecStatus(params) ⇒ Object 



31
32
33
34
 
# File 'lib/impala/protocol/impala_internal_service.rb', line 31

def ReportExecStatus(params)
  send_ReportExecStatus(params)
  return recv_ReportExecStatus()
end

#send_CancelPlanFragment(params) ⇒ Object 



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

def send_CancelPlanFragment(params)
  send_message('CancelPlanFragment', CancelPlanFragment_args, :params => params)
end

#send_ExecPlanFragment(params) ⇒ Object 



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

def send_ExecPlanFragment(params)
  send_message('ExecPlanFragment', ExecPlanFragment_args, :params => params)
end

#send_ReportExecStatus(params) ⇒ Object 



36
37
38
 
# File 'lib/impala/protocol/impala_internal_service.rb', line 36

def send_ReportExecStatus(params)
  send_message('ReportExecStatus', ReportExecStatus_args, :params => params)
end

#send_TransmitData(params) ⇒ Object 



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

def send_TransmitData(params)
  send_message('TransmitData', TransmitData_args, :params => params)
end

#TransmitData(params) ⇒ Object 



61
62
63
64
 
# File 'lib/impala/protocol/impala_internal_service.rb', line 61

def TransmitData(params)
  send_TransmitData(params)
  return recv_TransmitData()
end