class Swcdb::Thrift::Gen::Service::Processor
Public Instance Methods
process_compact_columns(seqid, iprot, oprot)
click to toggle source
# File lib/swcdb/thrift/gen/service.rb, line 544 def process_compact_columns(seqid, iprot, oprot) args = read_args(iprot, Compact_columns_args) result = Compact_columns_result.new() begin result.success = @handler.compact_columns(args.spec) rescue ::Swcdb::Thrift::Gen::Exception => e result.e = e end write_result(result, oprot, 'compact_columns', seqid) end
process_exec_sql(seqid, iprot, oprot)
click to toggle source
# File lib/swcdb/thrift/gen/service.rb, line 467 def process_exec_sql(seqid, iprot, oprot) args = read_args(iprot, Exec_sql_args) result = Exec_sql_result.new() begin result.success = @handler.exec_sql(args.sql) rescue ::Swcdb::Thrift::Gen::Exception => e result.e = e end write_result(result, oprot, 'exec_sql', seqid) end
process_list_columns(seqid, iprot, oprot)
click to toggle source
# File lib/swcdb/thrift/gen/service.rb, line 533 def process_list_columns(seqid, iprot, oprot) args = read_args(iprot, List_columns_args) result = List_columns_result.new() begin result.success = @handler.list_columns(args.spec) rescue ::Swcdb::Thrift::Gen::Exception => e result.e = e end write_result(result, oprot, 'list_columns', seqid) end
process_mng_column(seqid, iprot, oprot)
click to toggle source
# File lib/swcdb/thrift/gen/service.rb, line 522 def process_mng_column(seqid, iprot, oprot) args = read_args(iprot, Mng_column_args) result = Mng_column_result.new() begin @handler.mng_column(args.func, args.schema) rescue ::Swcdb::Thrift::Gen::Exception => e result.e = e end write_result(result, oprot, 'mng_column', seqid) end
process_scan(seqid, iprot, oprot)
click to toggle source
# File lib/swcdb/thrift/gen/service.rb, line 555 def process_scan(seqid, iprot, oprot) args = read_args(iprot, Scan_args) result = Scan_result.new() begin result.success = @handler.scan(args.spec) rescue ::Swcdb::Thrift::Gen::Exception => e result.e = e end write_result(result, oprot, 'scan', seqid) end
process_scan_rslt_on(seqid, iprot, oprot)
click to toggle source
# File lib/swcdb/thrift/gen/service.rb, line 599 def process_scan_rslt_on(seqid, iprot, oprot) args = read_args(iprot, Scan_rslt_on_args) result = Scan_rslt_on_result.new() begin result.success = @handler.scan_rslt_on(args.spec, args.rslt) rescue ::Swcdb::Thrift::Gen::Exception => e result.e = e end write_result(result, oprot, 'scan_rslt_on', seqid) end
process_scan_rslt_on_column(seqid, iprot, oprot)
click to toggle source
# File lib/swcdb/thrift/gen/service.rb, line 566 def process_scan_rslt_on_column(seqid, iprot, oprot) args = read_args(iprot, Scan_rslt_on_column_args) result = Scan_rslt_on_column_result.new() begin result.success = @handler.scan_rslt_on_column(args.spec) rescue ::Swcdb::Thrift::Gen::Exception => e result.e = e end write_result(result, oprot, 'scan_rslt_on_column', seqid) end
process_scan_rslt_on_fraction(seqid, iprot, oprot)
click to toggle source
# File lib/swcdb/thrift/gen/service.rb, line 588 def process_scan_rslt_on_fraction(seqid, iprot, oprot) args = read_args(iprot, Scan_rslt_on_fraction_args) result = Scan_rslt_on_fraction_result.new() begin result.success = @handler.scan_rslt_on_fraction(args.spec) rescue ::Swcdb::Thrift::Gen::Exception => e result.e = e end write_result(result, oprot, 'scan_rslt_on_fraction', seqid) end
process_scan_rslt_on_key(seqid, iprot, oprot)
click to toggle source
# File lib/swcdb/thrift/gen/service.rb, line 577 def process_scan_rslt_on_key(seqid, iprot, oprot) args = read_args(iprot, Scan_rslt_on_key_args) result = Scan_rslt_on_key_result.new() begin result.success = @handler.scan_rslt_on_key(args.spec) rescue ::Swcdb::Thrift::Gen::Exception => e result.e = e end write_result(result, oprot, 'scan_rslt_on_key', seqid) end
process_sql_compact_columns(seqid, iprot, oprot)
click to toggle source
# File lib/swcdb/thrift/gen/service.rb, line 390 def process_sql_compact_columns(seqid, iprot, oprot) args = read_args(iprot, Sql_compact_columns_args) result = Sql_compact_columns_result.new() begin result.success = @handler.sql_compact_columns(args.sql) rescue ::Swcdb::Thrift::Gen::Exception => e result.e = e end write_result(result, oprot, 'sql_compact_columns', seqid) end
process_sql_list_columns(seqid, iprot, oprot)
click to toggle source
# File lib/swcdb/thrift/gen/service.rb, line 379 def process_sql_list_columns(seqid, iprot, oprot) args = read_args(iprot, Sql_list_columns_args) result = Sql_list_columns_result.new() begin result.success = @handler.sql_list_columns(args.sql) rescue ::Swcdb::Thrift::Gen::Exception => e result.e = e end write_result(result, oprot, 'sql_list_columns', seqid) end
process_sql_mng_column(seqid, iprot, oprot)
click to toggle source
# File lib/swcdb/thrift/gen/service.rb, line 368 def process_sql_mng_column(seqid, iprot, oprot) args = read_args(iprot, Sql_mng_column_args) result = Sql_mng_column_result.new() begin @handler.sql_mng_column(args.sql) rescue ::Swcdb::Thrift::Gen::Exception => e result.e = e end write_result(result, oprot, 'sql_mng_column', seqid) end
process_sql_query(seqid, iprot, oprot)
click to toggle source
# File lib/swcdb/thrift/gen/service.rb, line 445 def process_sql_query(seqid, iprot, oprot) args = read_args(iprot, Sql_query_args) result = Sql_query_result.new() begin result.success = @handler.sql_query(args.sql, args.rslt) rescue ::Swcdb::Thrift::Gen::Exception => e result.e = e end write_result(result, oprot, 'sql_query', seqid) end
process_sql_select(seqid, iprot, oprot)
click to toggle source
# File lib/swcdb/thrift/gen/service.rb, line 401 def process_sql_select(seqid, iprot, oprot) args = read_args(iprot, Sql_select_args) result = Sql_select_result.new() begin result.success = @handler.sql_select(args.sql) rescue ::Swcdb::Thrift::Gen::Exception => e result.e = e end write_result(result, oprot, 'sql_select', seqid) end
process_sql_select_rslt_on_column(seqid, iprot, oprot)
click to toggle source
# File lib/swcdb/thrift/gen/service.rb, line 412 def process_sql_select_rslt_on_column(seqid, iprot, oprot) args = read_args(iprot, Sql_select_rslt_on_column_args) result = Sql_select_rslt_on_column_result.new() begin result.success = @handler.sql_select_rslt_on_column(args.sql) rescue ::Swcdb::Thrift::Gen::Exception => e result.e = e end write_result(result, oprot, 'sql_select_rslt_on_column', seqid) end
process_sql_select_rslt_on_fraction(seqid, iprot, oprot)
click to toggle source
# File lib/swcdb/thrift/gen/service.rb, line 434 def process_sql_select_rslt_on_fraction(seqid, iprot, oprot) args = read_args(iprot, Sql_select_rslt_on_fraction_args) result = Sql_select_rslt_on_fraction_result.new() begin result.success = @handler.sql_select_rslt_on_fraction(args.sql) rescue ::Swcdb::Thrift::Gen::Exception => e result.e = e end write_result(result, oprot, 'sql_select_rslt_on_fraction', seqid) end
process_sql_select_rslt_on_key(seqid, iprot, oprot)
click to toggle source
# File lib/swcdb/thrift/gen/service.rb, line 423 def process_sql_select_rslt_on_key(seqid, iprot, oprot) args = read_args(iprot, Sql_select_rslt_on_key_args) result = Sql_select_rslt_on_key_result.new() begin result.success = @handler.sql_select_rslt_on_key(args.sql) rescue ::Swcdb::Thrift::Gen::Exception => e result.e = e end write_result(result, oprot, 'sql_select_rslt_on_key', seqid) end
process_sql_update(seqid, iprot, oprot)
click to toggle source
# File lib/swcdb/thrift/gen/service.rb, line 456 def process_sql_update(seqid, iprot, oprot) args = read_args(iprot, Sql_update_args) result = Sql_update_result.new() begin @handler.sql_update(args.sql, args.updater_id) rescue ::Swcdb::Thrift::Gen::Exception => e result.e = e end write_result(result, oprot, 'sql_update', seqid) end
process_update(seqid, iprot, oprot)
click to toggle source
# File lib/swcdb/thrift/gen/service.rb, line 500 def process_update(seqid, iprot, oprot) args = read_args(iprot, Update_args) result = Update_result.new() begin @handler.update(args.cells, args.updater_id) rescue ::Swcdb::Thrift::Gen::Exception => e result.e = e end write_result(result, oprot, 'update', seqid) end
process_update_serial(seqid, iprot, oprot)
click to toggle source
# File lib/swcdb/thrift/gen/service.rb, line 511 def process_update_serial(seqid, iprot, oprot) args = read_args(iprot, Update_serial_args) result = Update_serial_result.new() begin @handler.update_serial(args.cells, args.updater_id) rescue ::Swcdb::Thrift::Gen::Exception => e result.e = e end write_result(result, oprot, 'update_serial', seqid) end
process_updater_close(seqid, iprot, oprot)
click to toggle source
# File lib/swcdb/thrift/gen/service.rb, line 489 def process_updater_close(seqid, iprot, oprot) args = read_args(iprot, Updater_close_args) result = Updater_close_result.new() begin @handler.updater_close(args.id) rescue ::Swcdb::Thrift::Gen::Exception => e result.e = e end write_result(result, oprot, 'updater_close', seqid) end
process_updater_create(seqid, iprot, oprot)
click to toggle source
# File lib/swcdb/thrift/gen/service.rb, line 478 def process_updater_create(seqid, iprot, oprot) args = read_args(iprot, Updater_create_args) result = Updater_create_result.new() begin result.success = @handler.updater_create(args.buffer_size) rescue ::Swcdb::Thrift::Gen::Exception => e result.e = e end write_result(result, oprot, 'updater_create', seqid) end