Class: Hypertable::ThriftGen::HqlService::Processor
Instance Method Summary
collapse
#process_close_mutator, #process_close_scanner, #process_create_table, #process_drop_table, #process_flush_mutator, #process_get_cell, #process_get_cells, #process_get_cells_as_arrays, #process_get_row, #process_get_row_as_arrays, #process_get_schema, #process_get_table_id, #process_get_tables, #process_next_cells, #process_next_cells_as_arrays, #process_next_row, #process_next_row_as_arrays, #process_open_mutator, #process_open_scanner, #process_set_cell, #process_set_cell_as_array, #process_set_cells, #process_set_cells_as_arrays
Instance Method Details
#process_hql_exec(seqid, iprot, oprot) ⇒ Object
54
55
56
57
58
59
60
61
62
63
|
# File 'lib/hypertable/gen-rb/hql_service.rb', line 54
def process_hql_exec(seqid, iprot, oprot)
args = read_args(iprot, Hql_exec_args)
result = Hql_exec_result.new()
begin
result.success = @handler.hql_exec(args.command, args.noflush, args.unbuffered)
rescue Hypertable::ThriftGen::ClientException => e
result.e = e
end
write_result(result, oprot, 'hql_exec', seqid)
end
|
#process_hql_query(seqid, iprot, oprot) ⇒ Object
65
66
67
68
69
70
71
72
73
74
|
# File 'lib/hypertable/gen-rb/hql_service.rb', line 65
def process_hql_query(seqid, iprot, oprot)
args = read_args(iprot, Hql_query_args)
result = Hql_query_result.new()
begin
result.success = @handler.hql_query(args.command)
rescue Hypertable::ThriftGen::ClientException => e
result.e = e
end
write_result(result, oprot, 'hql_query', seqid)
end
|