Class: Hypertable::ThriftGen::HqlService::Processor
Instance Method Summary
collapse
#process_close_mutator, #process_close_namespace, #process_close_scanner, #process_create_namespace, #process_create_table, #process_drop_namespace, #process_drop_table, #process_exists_namespace, #process_exists_table, #process_flush_mutator, #process_get_cell, #process_get_cells, #process_get_cells_as_arrays, #process_get_cells_serialized, #process_get_listing, #process_get_row, #process_get_row_as_arrays, #process_get_row_serialized, #process_get_schema, #process_get_schema_str, #process_get_table_id, #process_get_table_splits, #process_get_tables, #process_next_cells, #process_next_cells_as_arrays, #process_next_cells_serialized, #process_next_row, #process_next_row_as_arrays, #process_next_row_serialized, #process_offer_cell, #process_offer_cell_as_array, #process_offer_cells, #process_offer_cells_as_arrays, #process_open_mutator, #process_open_namespace, #process_open_scanner, #process_refresh_shared_mutator, #process_rename_table, #process_set_cell, #process_set_cell_as_array, #process_set_cells, #process_set_cells_as_arrays, #process_set_cells_serialized
Instance Method Details
#process_hql_exec(seqid, iprot, oprot) ⇒ Object
86
87
88
89
90
91
92
93
94
95
|
# File 'lib/hypertable/gen-rb/hql_service.rb', line 86
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.ns, 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_exec2(seqid, iprot, oprot) ⇒ Object
108
109
110
111
112
113
114
115
116
117
|
# File 'lib/hypertable/gen-rb/hql_service.rb', line 108
def process_hql_exec2(seqid, iprot, oprot)
args = read_args(iprot, Hql_exec2_args)
result = Hql_exec2_result.new()
begin
result.success = @handler.hql_exec2(args.ns, args.command, args.noflush, args.unbuffered)
rescue Hypertable::ThriftGen::ClientException => e
result.e = e
end
write_result(result, oprot, 'hql_exec2', seqid)
end
|
#process_hql_query(seqid, iprot, oprot) ⇒ Object
97
98
99
100
101
102
103
104
105
106
|
# File 'lib/hypertable/gen-rb/hql_service.rb', line 97
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.ns, args.command)
rescue Hypertable::ThriftGen::ClientException => e
result.e = e
end
write_result(result, oprot, 'hql_query', seqid)
end
|
#process_hql_query2(seqid, iprot, oprot) ⇒ Object
119
120
121
122
123
124
125
126
127
128
|
# File 'lib/hypertable/gen-rb/hql_service.rb', line 119
def process_hql_query2(seqid, iprot, oprot)
args = read_args(iprot, Hql_query2_args)
result = Hql_query2_result.new()
begin
result.success = @handler.hql_query2(args.ns, args.command)
rescue Hypertable::ThriftGen::ClientException => e
result.e = e
end
write_result(result, oprot, 'hql_query2', seqid)
end
|