Class: Impala::Protocol::ImpalaPlanService::Processor
- Inherits:
-
Object
- Object
- Impala::Protocol::ImpalaPlanService::Processor
- Includes:
- Thrift::Processor
- Defined in:
- lib/impala/protocol/impala_plan_service.rb
Instance Method Summary collapse
- #process_CreateExecRequest(seqid, iprot, oprot) ⇒ Object
- #process_GetExplainString(seqid, iprot, oprot) ⇒ Object
- #process_RefreshMetadata(seqid, iprot, oprot) ⇒ Object
- #process_ShutdownServer(seqid, iprot, oprot) ⇒ Object
- #process_UpdateMetastore(seqid, iprot, oprot) ⇒ Object
Instance Method Details
#process_CreateExecRequest(seqid, iprot, oprot) ⇒ Object
96 97 98 99 100 101 102 103 104 105 |
# File 'lib/impala/protocol/impala_plan_service.rb', line 96 def process_CreateExecRequest(seqid, iprot, oprot) args = read_args(iprot, CreateExecRequest_args) result = CreateExecRequest_result.new() begin result.success = @handler.CreateExecRequest(args.clientRequest) rescue Impala::Protocol::TImpalaPlanServiceException => e result.e = e end write_result(result, oprot, 'CreateExecRequest', seqid) end |
#process_GetExplainString(seqid, iprot, oprot) ⇒ Object
114 115 116 117 118 119 120 121 122 123 |
# File 'lib/impala/protocol/impala_plan_service.rb', line 114 def process_GetExplainString(seqid, iprot, oprot) args = read_args(iprot, GetExplainString_args) result = GetExplainString_result.new() begin result.success = @handler.GetExplainString(args.queryRequest) rescue Impala::Protocol::TImpalaPlanServiceException => e result.e = e end write_result(result, oprot, 'GetExplainString', seqid) end |
#process_RefreshMetadata(seqid, iprot, oprot) ⇒ Object
107 108 109 110 111 112 |
# File 'lib/impala/protocol/impala_plan_service.rb', line 107 def process_RefreshMetadata(seqid, iprot, oprot) args = read_args(iprot, RefreshMetadata_args) result = RefreshMetadata_result.new() @handler.RefreshMetadata() write_result(result, oprot, 'RefreshMetadata', seqid) end |
#process_ShutdownServer(seqid, iprot, oprot) ⇒ Object
136 137 138 139 140 141 |
# File 'lib/impala/protocol/impala_plan_service.rb', line 136 def process_ShutdownServer(seqid, iprot, oprot) args = read_args(iprot, ShutdownServer_args) result = ShutdownServer_result.new() @handler.ShutdownServer() write_result(result, oprot, 'ShutdownServer', seqid) end |
#process_UpdateMetastore(seqid, iprot, oprot) ⇒ Object
125 126 127 128 129 130 131 132 133 134 |
# File 'lib/impala/protocol/impala_plan_service.rb', line 125 def process_UpdateMetastore(seqid, iprot, oprot) args = read_args(iprot, UpdateMetastore_args) result = UpdateMetastore_result.new() begin @handler.UpdateMetastore(args.update) rescue Impala::Protocol::TImpalaPlanServiceException => e result.e = e end write_result(result, oprot, 'UpdateMetastore', seqid) end |