Class: Hypertable::ThriftGen::ClientService::Processor

Inherits:
Object
  • Object
show all
Includes:
Thrift::Processor
Defined in:
lib/hypertable/gen-rb/client_service.rb

Direct Known Subclasses

HqlService::Processor

Instance Method Summary collapse

Instance Method Details

#process_close_mutator(seqid, iprot, oprot) ⇒ Object 



523
524
525
526
527
528
529
530
531
532
 
# File 'lib/hypertable/gen-rb/client_service.rb', line 523

def process_close_mutator(seqid, iprot, oprot)
  args = read_args(iprot, Close_mutator_args)
  result = Close_mutator_result.new()
  begin
    @handler.close_mutator(args.mutator, args.flush)
  rescue Hypertable::ThriftGen::ClientException => e
    result.e = e
  end
  write_result(result, oprot, 'close_mutator', seqid)
end

#process_close_scanner(seqid, iprot, oprot) ⇒ Object 



402
403
404
405
406
407
408
409
410
411
 
# File 'lib/hypertable/gen-rb/client_service.rb', line 402

def process_close_scanner(seqid, iprot, oprot)
  args = read_args(iprot, Close_scanner_args)
  result = Close_scanner_result.new()
  begin
    @handler.close_scanner(args.scanner)
  rescue Hypertable::ThriftGen::ClientException => e
    result.e = e
  end
  write_result(result, oprot, 'close_scanner', seqid)
end

#process_create_table(seqid, iprot, oprot) ⇒ Object 



380
381
382
383
384
385
386
387
388
389
 
# File 'lib/hypertable/gen-rb/client_service.rb', line 380

def process_create_table(seqid, iprot, oprot)
  args = read_args(iprot, Create_table_args)
  result = Create_table_result.new()
  begin
    @handler.create_table(args.name, args.schema)
  rescue Hypertable::ThriftGen::ClientException => e
    result.e = e
  end
  write_result(result, oprot, 'create_table', seqid)
end

#process_drop_table(seqid, iprot, oprot) ⇒ Object 



622
623
624
625
626
627
628
629
630
631
 
# File 'lib/hypertable/gen-rb/client_service.rb', line 622

def process_drop_table(seqid, iprot, oprot)
  args = read_args(iprot, Drop_table_args)
  result = Drop_table_result.new()
  begin
    @handler.drop_table(args.name, args.if_exists)
  rescue Hypertable::ThriftGen::ClientException => e
    result.e = e
  end
  write_result(result, oprot, 'drop_table', seqid)
end

#process_flush_mutator(seqid, iprot, oprot) ⇒ Object 



578
579
580
581
582
583
584
585
586
587
 
# File 'lib/hypertable/gen-rb/client_service.rb', line 578

def process_flush_mutator(seqid, iprot, oprot)
  args = read_args(iprot, Flush_mutator_args)
  result = Flush_mutator_result.new()
  begin
    @handler.flush_mutator(args.mutator)
  rescue Hypertable::ThriftGen::ClientException => e
    result.e = e
  end
  write_result(result, oprot, 'flush_mutator', seqid)
end

#process_get_cell(seqid, iprot, oprot) ⇒ Object 



479
480
481
482
483
484
485
486
487
488
 
# File 'lib/hypertable/gen-rb/client_service.rb', line 479

def process_get_cell(seqid, iprot, oprot)
  args = read_args(iprot, Get_cell_args)
  result = Get_cell_result.new()
  begin
    result.success = @handler.get_cell(args.name, args.row, args.column)
  rescue Hypertable::ThriftGen::ClientException => e
    result.e = e
  end
  write_result(result, oprot, 'get_cell', seqid)
end

#process_get_cells(seqid, iprot, oprot) ⇒ Object 



490
491
492
493
494
495
496
497
498
499
 
# File 'lib/hypertable/gen-rb/client_service.rb', line 490

def process_get_cells(seqid, iprot, oprot)
  args = read_args(iprot, Get_cells_args)
  result = Get_cells_result.new()
  begin
    result.success = @handler.get_cells(args.name, args.scan_spec)
  rescue Hypertable::ThriftGen::ClientException => e
    result.e = e
  end
  write_result(result, oprot, 'get_cells', seqid)
end

#process_get_cells_as_arrays(seqid, iprot, oprot) ⇒ Object 



501
502
503
504
505
506
507
508
509
510
 
# File 'lib/hypertable/gen-rb/client_service.rb', line 501

def process_get_cells_as_arrays(seqid, iprot, oprot)
  args = read_args(iprot, Get_cells_as_arrays_args)
  result = Get_cells_as_arrays_result.new()
  begin
    result.success = @handler.get_cells_as_arrays(args.name, args.scan_spec)
  rescue Hypertable::ThriftGen::ClientException => e
    result.e = e
  end
  write_result(result, oprot, 'get_cells_as_arrays', seqid)
end

#process_get_row(seqid, iprot, oprot) ⇒ Object 



457
458
459
460
461
462
463
464
465
466
 
# File 'lib/hypertable/gen-rb/client_service.rb', line 457

def process_get_row(seqid, iprot, oprot)
  args = read_args(iprot, Get_row_args)
  result = Get_row_result.new()
  begin
    result.success = @handler.get_row(args.name, args.row)
  rescue Hypertable::ThriftGen::ClientException => e
    result.e = e
  end
  write_result(result, oprot, 'get_row', seqid)
end

#process_get_row_as_arrays(seqid, iprot, oprot) ⇒ Object 



468
469
470
471
472
473
474
475
476
477
 
# File 'lib/hypertable/gen-rb/client_service.rb', line 468

def process_get_row_as_arrays(seqid, iprot, oprot)
  args = read_args(iprot, Get_row_as_arrays_args)
  result = Get_row_as_arrays_result.new()
  begin
    result.success = @handler.get_row_as_arrays(args.name, args.row)
  rescue Hypertable::ThriftGen::ClientException => e
    result.e = e
  end
  write_result(result, oprot, 'get_row_as_arrays', seqid)
end

#process_get_schema(seqid, iprot, oprot) ⇒ Object 



600
601
602
603
604
605
606
607
608
609
 
# File 'lib/hypertable/gen-rb/client_service.rb', line 600

def process_get_schema(seqid, iprot, oprot)
  args = read_args(iprot, Get_schema_args)
  result = Get_schema_result.new()
  begin
    result.success = @handler.get_schema(args.name)
  rescue Hypertable::ThriftGen::ClientException => e
    result.e = e
  end
  write_result(result, oprot, 'get_schema', seqid)
end

#process_get_table_id(seqid, iprot, oprot) ⇒ Object 



589
590
591
592
593
594
595
596
597
598
 
# File 'lib/hypertable/gen-rb/client_service.rb', line 589

def process_get_table_id(seqid, iprot, oprot)
  args = read_args(iprot, Get_table_id_args)
  result = Get_table_id_result.new()
  begin
    result.success = @handler.get_table_id(args.name)
  rescue Hypertable::ThriftGen::ClientException => e
    result.e = e
  end
  write_result(result, oprot, 'get_table_id', seqid)
end

#process_get_tables(seqid, iprot, oprot) ⇒ Object 



611
612
613
614
615
616
617
618
619
620
 
# File 'lib/hypertable/gen-rb/client_service.rb', line 611

def process_get_tables(seqid, iprot, oprot)
  args = read_args(iprot, Get_tables_args)
  result = Get_tables_result.new()
  begin
    result.success = @handler.get_tables()
  rescue Hypertable::ThriftGen::ClientException => e
    result.e = e
  end
  write_result(result, oprot, 'get_tables', seqid)
end

#process_next_cells(seqid, iprot, oprot) ⇒ Object 



413
414
415
416
417
418
419
420
421
422
 
# File 'lib/hypertable/gen-rb/client_service.rb', line 413

def process_next_cells(seqid, iprot, oprot)
  args = read_args(iprot, Next_cells_args)
  result = Next_cells_result.new()
  begin
    result.success = @handler.next_cells(args.scanner)
  rescue Hypertable::ThriftGen::ClientException => e
    result.e = e
  end
  write_result(result, oprot, 'next_cells', seqid)
end

#process_next_cells_as_arrays(seqid, iprot, oprot) ⇒ Object 



424
425
426
427
428
429
430
431
432
433
 
# File 'lib/hypertable/gen-rb/client_service.rb', line 424

def process_next_cells_as_arrays(seqid, iprot, oprot)
  args = read_args(iprot, Next_cells_as_arrays_args)
  result = Next_cells_as_arrays_result.new()
  begin
    result.success = @handler.next_cells_as_arrays(args.scanner)
  rescue Hypertable::ThriftGen::ClientException => e
    result.e = e
  end
  write_result(result, oprot, 'next_cells_as_arrays', seqid)
end

#process_next_row(seqid, iprot, oprot) ⇒ Object 



435
436
437
438
439
440
441
442
443
444
 
# File 'lib/hypertable/gen-rb/client_service.rb', line 435

def process_next_row(seqid, iprot, oprot)
  args = read_args(iprot, Next_row_args)
  result = Next_row_result.new()
  begin
    result.success = @handler.next_row(args.scanner)
  rescue Hypertable::ThriftGen::ClientException => e
    result.e = e
  end
  write_result(result, oprot, 'next_row', seqid)
end

#process_next_row_as_arrays(seqid, iprot, oprot) ⇒ Object 



446
447
448
449
450
451
452
453
454
455
 
# File 'lib/hypertable/gen-rb/client_service.rb', line 446

def process_next_row_as_arrays(seqid, iprot, oprot)
  args = read_args(iprot, Next_row_as_arrays_args)
  result = Next_row_as_arrays_result.new()
  begin
    result.success = @handler.next_row_as_arrays(args.scanner)
  rescue Hypertable::ThriftGen::ClientException => e
    result.e = e
  end
  write_result(result, oprot, 'next_row_as_arrays', seqid)
end

#process_open_mutator(seqid, iprot, oprot) ⇒ Object 



512
513
514
515
516
517
518
519
520
521
 
# File 'lib/hypertable/gen-rb/client_service.rb', line 512

def process_open_mutator(seqid, iprot, oprot)
  args = read_args(iprot, Open_mutator_args)
  result = Open_mutator_result.new()
  begin
    result.success = @handler.open_mutator(args.name)
  rescue Hypertable::ThriftGen::ClientException => e
    result.e = e
  end
  write_result(result, oprot, 'open_mutator', seqid)
end

#process_open_scanner(seqid, iprot, oprot) ⇒ Object 



391
392
393
394
395
396
397
398
399
400
 
# File 'lib/hypertable/gen-rb/client_service.rb', line 391

def process_open_scanner(seqid, iprot, oprot)
  args = read_args(iprot, Open_scanner_args)
  result = Open_scanner_result.new()
  begin
    result.success = @handler.open_scanner(args.name, args.scan_spec, args.retry_table_not_found)
  rescue Hypertable::ThriftGen::ClientException => e
    result.e = e
  end
  write_result(result, oprot, 'open_scanner', seqid)
end

#process_set_cell(seqid, iprot, oprot) ⇒ Object 



534
535
536
537
538
539
540
541
542
543
 
# File 'lib/hypertable/gen-rb/client_service.rb', line 534

def process_set_cell(seqid, iprot, oprot)
  args = read_args(iprot, Set_cell_args)
  result = Set_cell_result.new()
  begin
    @handler.set_cell(args.mutator, args.cell)
  rescue Hypertable::ThriftGen::ClientException => e
    result.e = e
  end
  write_result(result, oprot, 'set_cell', seqid)
end

#process_set_cell_as_array(seqid, iprot, oprot) ⇒ Object 



545
546
547
548
549
550
551
552
553
554
 
# File 'lib/hypertable/gen-rb/client_service.rb', line 545

def process_set_cell_as_array(seqid, iprot, oprot)
  args = read_args(iprot, Set_cell_as_array_args)
  result = Set_cell_as_array_result.new()
  begin
    @handler.set_cell_as_array(args.mutator, args.cell)
  rescue Hypertable::ThriftGen::ClientException => e
    result.e = e
  end
  write_result(result, oprot, 'set_cell_as_array', seqid)
end

#process_set_cells(seqid, iprot, oprot) ⇒ Object 



556
557
558
559
560
561
562
563
564
565
 
# File 'lib/hypertable/gen-rb/client_service.rb', line 556

def process_set_cells(seqid, iprot, oprot)
  args = read_args(iprot, Set_cells_args)
  result = Set_cells_result.new()
  begin
    @handler.set_cells(args.mutator, args.cells)
  rescue Hypertable::ThriftGen::ClientException => e
    result.e = e
  end
  write_result(result, oprot, 'set_cells', seqid)
end

#process_set_cells_as_arrays(seqid, iprot, oprot) ⇒ Object 



567
568
569
570
571
572
573
574
575
576
 
# File 'lib/hypertable/gen-rb/client_service.rb', line 567

def process_set_cells_as_arrays(seqid, iprot, oprot)
  args = read_args(iprot, Set_cells_as_arrays_args)
  result = Set_cells_as_arrays_result.new()
  begin
    @handler.set_cells_as_arrays(args.mutator, args.cells)
  rescue Hypertable::ThriftGen::ClientException => e
    result.e = e
  end
  write_result(result, oprot, 'set_cells_as_arrays', seqid)
end