Class: Impala::Protocol::ImpalaService::Processor
Instance Method Summary
collapse
-
#process_Cancel(seqid, iprot, oprot) ⇒ Object
-
#process_CloseInsert(seqid, iprot, oprot) ⇒ Object
-
#process_GetRuntimeProfile(seqid, iprot, oprot) ⇒ Object
-
#process_PingImpalaService(seqid, iprot, oprot) ⇒ Object
-
#process_ResetCatalog(seqid, iprot, oprot) ⇒ Object
-
#process_ResetTable(seqid, iprot, oprot) ⇒ Object
#process_clean, #process_close, #process_dump_config, #process_echo, #process_executeAndWait, #process_explain, #process_fetch, #process_get_default_configuration, #process_get_log, #process_get_results_metadata, #process_get_state, #process_query
Instance Method Details
#process_Cancel(seqid, iprot, oprot) ⇒ Object
116
117
118
119
120
121
122
123
124
125
|
# File 'lib/impala/protocol/impala_service.rb', line 116
def process_Cancel(seqid, iprot, oprot)
args = read_args(iprot, Cancel_args)
result = Cancel_result.new()
begin
result.success = @handler.Cancel(args.query_id)
rescue ::Impala::Protocol::Beeswax::BeeswaxException => error
result.error = error
end
write_result(result, oprot, 'Cancel', seqid)
end
|
#process_CloseInsert(seqid, iprot, oprot) ⇒ Object
#process_GetRuntimeProfile(seqid, iprot, oprot) ⇒ Object
141
142
143
144
145
146
147
148
149
150
|
# File 'lib/impala/protocol/impala_service.rb', line 141
def process_GetRuntimeProfile(seqid, iprot, oprot)
args = read_args(iprot, GetRuntimeProfile_args)
result = GetRuntimeProfile_result.new()
begin
result.success = @handler.GetRuntimeProfile(args.query_id)
rescue ::Impala::Protocol::Beeswax::BeeswaxException => error
result.error = error
end
write_result(result, oprot, 'GetRuntimeProfile', seqid)
end
|
#process_PingImpalaService(seqid, iprot, oprot) ⇒ Object
165
166
167
168
169
170
|
# File 'lib/impala/protocol/impala_service.rb', line 165
def process_PingImpalaService(seqid, iprot, oprot)
args = read_args(iprot, PingImpalaService_args)
result = PingImpalaService_result.new()
result.success = @handler.PingImpalaService()
write_result(result, oprot, 'PingImpalaService', seqid)
end
|
#process_ResetCatalog(seqid, iprot, oprot) ⇒ Object
127
128
129
130
131
132
|
# File 'lib/impala/protocol/impala_service.rb', line 127
def process_ResetCatalog(seqid, iprot, oprot)
args = read_args(iprot, ResetCatalog_args)
result = ResetCatalog_result.new()
result.success = @handler.ResetCatalog()
write_result(result, oprot, 'ResetCatalog', seqid)
end
|
#process_ResetTable(seqid, iprot, oprot) ⇒ Object
134
135
136
137
138
139
|
# File 'lib/impala/protocol/impala_service.rb', line 134
def process_ResetTable(seqid, iprot, oprot)
args = read_args(iprot, ResetTable_args)
result = ResetTable_result.new()
result.success = @handler.ResetTable(args.request)
write_result(result, oprot, 'ResetTable', seqid)
end
|