Class: Impala::Protocol::ImpalaPlanService::Processor

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

Instance Method Summary collapse

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