Class: Impala::Protocol::ImpalaService::Processor
Instance Method Summary
collapse
#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
84
85
86
87
88
89
90
91
92
93
|
# File 'lib/impala/protocol/impala_service.rb', line 84
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_PingImpalaService(seqid, iprot, oprot) ⇒ Object
115
116
117
118
119
120
|
# File 'lib/impala/protocol/impala_service.rb', line 115
def process_PingImpalaService(seqid, iprot, oprot)
args = read_args(iprot, PingImpalaService_args)
result = PingImpalaService_result.new()
@handler.PingImpalaService()
write_result(result, oprot, 'PingImpalaService', seqid)
end
|
#process_ResetCatalog(seqid, iprot, oprot) ⇒ Object
95
96
97
98
99
100
|
# File 'lib/impala/protocol/impala_service.rb', line 95
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
|