Class: Impala::Protocol::ImpalaInternalService::Client
- Inherits:
-
Object
- Object
- Impala::Protocol::ImpalaInternalService::Client
- Includes:
- Thrift::Client
- Defined in:
- lib/impala/protocol/impala_internal_service.rb
Instance Method Summary collapse
- #CancelPlanFragment(params) ⇒ Object
- #ExecPlanFragment(params) ⇒ Object
- #recv_CancelPlanFragment ⇒ Object
- #recv_ExecPlanFragment ⇒ Object
- #recv_ReportExecStatus ⇒ Object
- #recv_TransmitData ⇒ Object
- #ReportExecStatus(params) ⇒ Object
- #send_CancelPlanFragment(params) ⇒ Object
- #send_ExecPlanFragment(params) ⇒ Object
- #send_ReportExecStatus(params) ⇒ Object
- #send_TransmitData(params) ⇒ Object
- #TransmitData(params) ⇒ Object
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
55 56 57 58 59 |
# File 'lib/impala/protocol/impala_internal_service.rb', line 55 def recv_CancelPlanFragment() result = (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
25 26 27 28 29 |
# File 'lib/impala/protocol/impala_internal_service.rb', line 25 def recv_ExecPlanFragment() result = (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
40 41 42 43 44 |
# File 'lib/impala/protocol/impala_internal_service.rb', line 40 def recv_ReportExecStatus() result = (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
70 71 72 73 74 |
# File 'lib/impala/protocol/impala_internal_service.rb', line 70 def recv_TransmitData() result = (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) ('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) ('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) ('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) ('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 |