1
2
3
4
5
6
7 package org.apache.hadoop.hbase.thrift.generated;
8
9 import org.apache.thrift.scheme.IScheme;
10 import org.apache.thrift.scheme.SchemeFactory;
11 import org.apache.thrift.scheme.StandardScheme;
12
13 import org.apache.thrift.scheme.TupleScheme;
14 import org.apache.thrift.protocol.TTupleProtocol;
15 import org.apache.thrift.protocol.TProtocolException;
16 import org.apache.thrift.EncodingUtils;
17 import org.apache.thrift.TException;
18 import java.util.List;
19 import java.util.ArrayList;
20 import java.util.Map;
21 import java.util.HashMap;
22 import java.util.EnumMap;
23 import java.util.Set;
24 import java.util.HashSet;
25 import java.util.EnumSet;
26 import java.util.Collections;
27 import java.util.BitSet;
28 import java.nio.ByteBuffer;
29 import java.util.Arrays;
30 import org.slf4j.Logger;
31 import org.slf4j.LoggerFactory;
32
33 public class Hbase {
34
35 public interface Iface {
36
37
38
39
40
41
42 public void enableTable(ByteBuffer tableName) throws IOError, org.apache.thrift.TException;
43
44
45
46
47
48
49
50 public void disableTable(ByteBuffer tableName) throws IOError, org.apache.thrift.TException;
51
52
53
54
55
56
57 public boolean isTableEnabled(ByteBuffer tableName) throws IOError, org.apache.thrift.TException;
58
59 public void compact(ByteBuffer tableNameOrRegionName) throws IOError, org.apache.thrift.TException;
60
61 public void majorCompact(ByteBuffer tableNameOrRegionName) throws IOError, org.apache.thrift.TException;
62
63
64
65
66
67
68 public List<ByteBuffer> getTableNames() throws IOError, org.apache.thrift.TException;
69
70
71
72
73
74
75
76
77 public Map<ByteBuffer,ColumnDescriptor> getColumnDescriptors(ByteBuffer tableName) throws IOError, org.apache.thrift.TException;
78
79
80
81
82
83
84
85
86 public List<TRegionInfo> getTableRegions(ByteBuffer tableName) throws IOError, org.apache.thrift.TException;
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102 public void createTable(ByteBuffer tableName, List<ColumnDescriptor> columnFamilies) throws IOError, IllegalArgument, AlreadyExists, org.apache.thrift.TException;
103
104
105
106
107
108
109
110
111
112 public void deleteTable(ByteBuffer tableName) throws IOError, org.apache.thrift.TException;
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128 public List<TCell> get(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException;
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146 public List<TCell> getVer(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, int numVersions, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException;
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167 public List<TCell> getVerTs(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, long timestamp, int numVersions, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException;
168
169
170
171
172
173
174
175
176
177
178
179
180
181 public List<TRowResult> getRow(ByteBuffer tableName, ByteBuffer row, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException;
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197 public List<TRowResult> getRowWithColumns(ByteBuffer tableName, ByteBuffer row, List<ByteBuffer> columns, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException;
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213 public List<TRowResult> getRowTs(ByteBuffer tableName, ByteBuffer row, long timestamp, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException;
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230 public List<TRowResult> getRowWithColumnsTs(ByteBuffer tableName, ByteBuffer row, List<ByteBuffer> columns, long timestamp, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException;
231
232
233
234
235
236
237
238
239
240
241
242
243
244 public List<TRowResult> getRows(ByteBuffer tableName, List<ByteBuffer> rows, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException;
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260 public List<TRowResult> getRowsWithColumns(ByteBuffer tableName, List<ByteBuffer> rows, List<ByteBuffer> columns, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException;
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276 public List<TRowResult> getRowsTs(ByteBuffer tableName, List<ByteBuffer> rows, long timestamp, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException;
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293 public List<TRowResult> getRowsWithColumnsTs(ByteBuffer tableName, List<ByteBuffer> rows, List<ByteBuffer> columns, long timestamp, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException;
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309 public void mutateRow(ByteBuffer tableName, ByteBuffer row, List<Mutation> mutations, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, IllegalArgument, org.apache.thrift.TException;
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327 public void mutateRowTs(ByteBuffer tableName, ByteBuffer row, List<Mutation> mutations, long timestamp, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, IllegalArgument, org.apache.thrift.TException;
328
329
330
331
332
333
334
335
336
337
338
339
340
341 public void mutateRows(ByteBuffer tableName, List<BatchMutation> rowBatches, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, IllegalArgument, org.apache.thrift.TException;
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357 public void mutateRowsTs(ByteBuffer tableName, List<BatchMutation> rowBatches, long timestamp, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, IllegalArgument, org.apache.thrift.TException;
358
359
360
361
362
363
364
365
366
367
368
369
370 public long atomicIncrement(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, long value) throws IOError, IllegalArgument, org.apache.thrift.TException;
371
372
373
374
375
376
377
378
379
380
381
382
383 public void deleteAll(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException;
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399 public void deleteAllTs(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, long timestamp, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException;
400
401
402
403
404
405
406
407
408
409
410 public void deleteAllRow(ByteBuffer tableName, ByteBuffer row, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException;
411
412
413
414
415
416
417
418
419
420 public void increment(TIncrement increment) throws IOError, org.apache.thrift.TException;
421
422 public void incrementRows(List<TIncrement> increments) throws IOError, org.apache.thrift.TException;
423
424
425
426
427
428
429
430
431
432
433
434
435
436 public void deleteAllRowTs(ByteBuffer tableName, ByteBuffer row, long timestamp, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException;
437
438
439
440
441
442
443
444
445
446
447
448 public int scannerOpenWithScan(ByteBuffer tableName, TScan scan, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException;
449
450
451
452
453
454
455
456
457
458
459
460
461
462
463
464
465
466
467 public int scannerOpen(ByteBuffer tableName, ByteBuffer startRow, List<ByteBuffer> columns, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException;
468
469
470
471
472
473
474
475
476
477
478
479
480
481
482
483
484
485
486
487
488
489
490 public int scannerOpenWithStop(ByteBuffer tableName, ByteBuffer startRow, ByteBuffer stopRow, List<ByteBuffer> columns, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException;
491
492
493
494
495
496
497
498
499
500
501
502
503
504
505
506 public int scannerOpenWithPrefix(ByteBuffer tableName, ByteBuffer startAndPrefix, List<ByteBuffer> columns, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException;
507
508
509
510
511
512
513
514
515
516
517
518
519
520
521
522
523
524
525
526
527
528 public int scannerOpenTs(ByteBuffer tableName, ByteBuffer startRow, List<ByteBuffer> columns, long timestamp, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException;
529
530
531
532
533
534
535
536
537
538
539
540
541
542
543
544
545
546
547
548
549
550
551
552
553
554 public int scannerOpenWithStopTs(ByteBuffer tableName, ByteBuffer startRow, ByteBuffer stopRow, List<ByteBuffer> columns, long timestamp, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException;
555
556
557
558
559
560
561
562
563
564
565
566
567
568
569
570 public List<TRowResult> scannerGet(int id) throws IOError, IllegalArgument, org.apache.thrift.TException;
571
572
573
574
575
576
577
578
579
580
581
582
583
584
585
586
587
588 public List<TRowResult> scannerGetList(int id, int nbRows) throws IOError, IllegalArgument, org.apache.thrift.TException;
589
590
591
592
593
594
595
596
597 public void scannerClose(int id) throws IOError, IllegalArgument, org.apache.thrift.TException;
598
599
600
601
602
603
604
605
606
607
608
609
610 public List<TCell> getRowOrBefore(ByteBuffer tableName, ByteBuffer row, ByteBuffer family) throws IOError, org.apache.thrift.TException;
611
612
613
614
615
616
617
618
619
620 public TRegionInfo getRegionInfo(ByteBuffer row) throws IOError, org.apache.thrift.TException;
621
622 }
623
624 public interface AsyncIface {
625
626 public void enableTable(ByteBuffer tableName, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.enableTable_call> resultHandler) throws org.apache.thrift.TException;
627
628 public void disableTable(ByteBuffer tableName, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.disableTable_call> resultHandler) throws org.apache.thrift.TException;
629
630 public void isTableEnabled(ByteBuffer tableName, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.isTableEnabled_call> resultHandler) throws org.apache.thrift.TException;
631
632 public void compact(ByteBuffer tableNameOrRegionName, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.compact_call> resultHandler) throws org.apache.thrift.TException;
633
634 public void majorCompact(ByteBuffer tableNameOrRegionName, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.majorCompact_call> resultHandler) throws org.apache.thrift.TException;
635
636 public void getTableNames(org.apache.thrift.async.AsyncMethodCallback<AsyncClient.getTableNames_call> resultHandler) throws org.apache.thrift.TException;
637
638 public void getColumnDescriptors(ByteBuffer tableName, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.getColumnDescriptors_call> resultHandler) throws org.apache.thrift.TException;
639
640 public void getTableRegions(ByteBuffer tableName, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.getTableRegions_call> resultHandler) throws org.apache.thrift.TException;
641
642 public void createTable(ByteBuffer tableName, List<ColumnDescriptor> columnFamilies, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.createTable_call> resultHandler) throws org.apache.thrift.TException;
643
644 public void deleteTable(ByteBuffer tableName, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.deleteTable_call> resultHandler) throws org.apache.thrift.TException;
645
646 public void get(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.get_call> resultHandler) throws org.apache.thrift.TException;
647
648 public void getVer(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, int numVersions, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.getVer_call> resultHandler) throws org.apache.thrift.TException;
649
650 public void getVerTs(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, long timestamp, int numVersions, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.getVerTs_call> resultHandler) throws org.apache.thrift.TException;
651
652 public void getRow(ByteBuffer tableName, ByteBuffer row, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.getRow_call> resultHandler) throws org.apache.thrift.TException;
653
654 public void getRowWithColumns(ByteBuffer tableName, ByteBuffer row, List<ByteBuffer> columns, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.getRowWithColumns_call> resultHandler) throws org.apache.thrift.TException;
655
656 public void getRowTs(ByteBuffer tableName, ByteBuffer row, long timestamp, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.getRowTs_call> resultHandler) throws org.apache.thrift.TException;
657
658 public void getRowWithColumnsTs(ByteBuffer tableName, ByteBuffer row, List<ByteBuffer> columns, long timestamp, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.getRowWithColumnsTs_call> resultHandler) throws org.apache.thrift.TException;
659
660 public void getRows(ByteBuffer tableName, List<ByteBuffer> rows, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.getRows_call> resultHandler) throws org.apache.thrift.TException;
661
662 public void getRowsWithColumns(ByteBuffer tableName, List<ByteBuffer> rows, List<ByteBuffer> columns, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.getRowsWithColumns_call> resultHandler) throws org.apache.thrift.TException;
663
664 public void getRowsTs(ByteBuffer tableName, List<ByteBuffer> rows, long timestamp, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.getRowsTs_call> resultHandler) throws org.apache.thrift.TException;
665
666 public void getRowsWithColumnsTs(ByteBuffer tableName, List<ByteBuffer> rows, List<ByteBuffer> columns, long timestamp, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.getRowsWithColumnsTs_call> resultHandler) throws org.apache.thrift.TException;
667
668 public void mutateRow(ByteBuffer tableName, ByteBuffer row, List<Mutation> mutations, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.mutateRow_call> resultHandler) throws org.apache.thrift.TException;
669
670 public void mutateRowTs(ByteBuffer tableName, ByteBuffer row, List<Mutation> mutations, long timestamp, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.mutateRowTs_call> resultHandler) throws org.apache.thrift.TException;
671
672 public void mutateRows(ByteBuffer tableName, List<BatchMutation> rowBatches, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.mutateRows_call> resultHandler) throws org.apache.thrift.TException;
673
674 public void mutateRowsTs(ByteBuffer tableName, List<BatchMutation> rowBatches, long timestamp, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.mutateRowsTs_call> resultHandler) throws org.apache.thrift.TException;
675
676 public void atomicIncrement(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, long value, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.atomicIncrement_call> resultHandler) throws org.apache.thrift.TException;
677
678 public void deleteAll(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.deleteAll_call> resultHandler) throws org.apache.thrift.TException;
679
680 public void deleteAllTs(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, long timestamp, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.deleteAllTs_call> resultHandler) throws org.apache.thrift.TException;
681
682 public void deleteAllRow(ByteBuffer tableName, ByteBuffer row, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.deleteAllRow_call> resultHandler) throws org.apache.thrift.TException;
683
684 public void increment(TIncrement increment, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.increment_call> resultHandler) throws org.apache.thrift.TException;
685
686 public void incrementRows(List<TIncrement> increments, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.incrementRows_call> resultHandler) throws org.apache.thrift.TException;
687
688 public void deleteAllRowTs(ByteBuffer tableName, ByteBuffer row, long timestamp, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.deleteAllRowTs_call> resultHandler) throws org.apache.thrift.TException;
689
690 public void scannerOpenWithScan(ByteBuffer tableName, TScan scan, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.scannerOpenWithScan_call> resultHandler) throws org.apache.thrift.TException;
691
692 public void scannerOpen(ByteBuffer tableName, ByteBuffer startRow, List<ByteBuffer> columns, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.scannerOpen_call> resultHandler) throws org.apache.thrift.TException;
693
694 public void scannerOpenWithStop(ByteBuffer tableName, ByteBuffer startRow, ByteBuffer stopRow, List<ByteBuffer> columns, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.scannerOpenWithStop_call> resultHandler) throws org.apache.thrift.TException;
695
696 public void scannerOpenWithPrefix(ByteBuffer tableName, ByteBuffer startAndPrefix, List<ByteBuffer> columns, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.scannerOpenWithPrefix_call> resultHandler) throws org.apache.thrift.TException;
697
698 public void scannerOpenTs(ByteBuffer tableName, ByteBuffer startRow, List<ByteBuffer> columns, long timestamp, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.scannerOpenTs_call> resultHandler) throws org.apache.thrift.TException;
699
700 public void scannerOpenWithStopTs(ByteBuffer tableName, ByteBuffer startRow, ByteBuffer stopRow, List<ByteBuffer> columns, long timestamp, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.scannerOpenWithStopTs_call> resultHandler) throws org.apache.thrift.TException;
701
702 public void scannerGet(int id, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.scannerGet_call> resultHandler) throws org.apache.thrift.TException;
703
704 public void scannerGetList(int id, int nbRows, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.scannerGetList_call> resultHandler) throws org.apache.thrift.TException;
705
706 public void scannerClose(int id, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.scannerClose_call> resultHandler) throws org.apache.thrift.TException;
707
708 public void getRowOrBefore(ByteBuffer tableName, ByteBuffer row, ByteBuffer family, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.getRowOrBefore_call> resultHandler) throws org.apache.thrift.TException;
709
710 public void getRegionInfo(ByteBuffer row, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.getRegionInfo_call> resultHandler) throws org.apache.thrift.TException;
711
712 }
713
714 public static class Client extends org.apache.thrift.TServiceClient implements Iface {
715 public static class Factory implements org.apache.thrift.TServiceClientFactory<Client> {
716 public Factory() {}
717 public Client getClient(org.apache.thrift.protocol.TProtocol prot) {
718 return new Client(prot);
719 }
720 public Client getClient(org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) {
721 return new Client(iprot, oprot);
722 }
723 }
724
725 public Client(org.apache.thrift.protocol.TProtocol prot)
726 {
727 super(prot, prot);
728 }
729
730 public Client(org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) {
731 super(iprot, oprot);
732 }
733
734 public void enableTable(ByteBuffer tableName) throws IOError, org.apache.thrift.TException
735 {
736 send_enableTable(tableName);
737 recv_enableTable();
738 }
739
740 public void send_enableTable(ByteBuffer tableName) throws org.apache.thrift.TException
741 {
742 enableTable_args args = new enableTable_args();
743 args.setTableName(tableName);
744 sendBase("enableTable", args);
745 }
746
747 public void recv_enableTable() throws IOError, org.apache.thrift.TException
748 {
749 enableTable_result result = new enableTable_result();
750 receiveBase(result, "enableTable");
751 if (result.io != null) {
752 throw result.io;
753 }
754 return;
755 }
756
757 public void disableTable(ByteBuffer tableName) throws IOError, org.apache.thrift.TException
758 {
759 send_disableTable(tableName);
760 recv_disableTable();
761 }
762
763 public void send_disableTable(ByteBuffer tableName) throws org.apache.thrift.TException
764 {
765 disableTable_args args = new disableTable_args();
766 args.setTableName(tableName);
767 sendBase("disableTable", args);
768 }
769
770 public void recv_disableTable() throws IOError, org.apache.thrift.TException
771 {
772 disableTable_result result = new disableTable_result();
773 receiveBase(result, "disableTable");
774 if (result.io != null) {
775 throw result.io;
776 }
777 return;
778 }
779
780 public boolean isTableEnabled(ByteBuffer tableName) throws IOError, org.apache.thrift.TException
781 {
782 send_isTableEnabled(tableName);
783 return recv_isTableEnabled();
784 }
785
786 public void send_isTableEnabled(ByteBuffer tableName) throws org.apache.thrift.TException
787 {
788 isTableEnabled_args args = new isTableEnabled_args();
789 args.setTableName(tableName);
790 sendBase("isTableEnabled", args);
791 }
792
793 public boolean recv_isTableEnabled() throws IOError, org.apache.thrift.TException
794 {
795 isTableEnabled_result result = new isTableEnabled_result();
796 receiveBase(result, "isTableEnabled");
797 if (result.isSetSuccess()) {
798 return result.success;
799 }
800 if (result.io != null) {
801 throw result.io;
802 }
803 throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "isTableEnabled failed: unknown result");
804 }
805
806 public void compact(ByteBuffer tableNameOrRegionName) throws IOError, org.apache.thrift.TException
807 {
808 send_compact(tableNameOrRegionName);
809 recv_compact();
810 }
811
812 public void send_compact(ByteBuffer tableNameOrRegionName) throws org.apache.thrift.TException
813 {
814 compact_args args = new compact_args();
815 args.setTableNameOrRegionName(tableNameOrRegionName);
816 sendBase("compact", args);
817 }
818
819 public void recv_compact() throws IOError, org.apache.thrift.TException
820 {
821 compact_result result = new compact_result();
822 receiveBase(result, "compact");
823 if (result.io != null) {
824 throw result.io;
825 }
826 return;
827 }
828
829 public void majorCompact(ByteBuffer tableNameOrRegionName) throws IOError, org.apache.thrift.TException
830 {
831 send_majorCompact(tableNameOrRegionName);
832 recv_majorCompact();
833 }
834
835 public void send_majorCompact(ByteBuffer tableNameOrRegionName) throws org.apache.thrift.TException
836 {
837 majorCompact_args args = new majorCompact_args();
838 args.setTableNameOrRegionName(tableNameOrRegionName);
839 sendBase("majorCompact", args);
840 }
841
842 public void recv_majorCompact() throws IOError, org.apache.thrift.TException
843 {
844 majorCompact_result result = new majorCompact_result();
845 receiveBase(result, "majorCompact");
846 if (result.io != null) {
847 throw result.io;
848 }
849 return;
850 }
851
852 public List<ByteBuffer> getTableNames() throws IOError, org.apache.thrift.TException
853 {
854 send_getTableNames();
855 return recv_getTableNames();
856 }
857
858 public void send_getTableNames() throws org.apache.thrift.TException
859 {
860 getTableNames_args args = new getTableNames_args();
861 sendBase("getTableNames", args);
862 }
863
864 public List<ByteBuffer> recv_getTableNames() throws IOError, org.apache.thrift.TException
865 {
866 getTableNames_result result = new getTableNames_result();
867 receiveBase(result, "getTableNames");
868 if (result.isSetSuccess()) {
869 return result.success;
870 }
871 if (result.io != null) {
872 throw result.io;
873 }
874 throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getTableNames failed: unknown result");
875 }
876
877 public Map<ByteBuffer,ColumnDescriptor> getColumnDescriptors(ByteBuffer tableName) throws IOError, org.apache.thrift.TException
878 {
879 send_getColumnDescriptors(tableName);
880 return recv_getColumnDescriptors();
881 }
882
883 public void send_getColumnDescriptors(ByteBuffer tableName) throws org.apache.thrift.TException
884 {
885 getColumnDescriptors_args args = new getColumnDescriptors_args();
886 args.setTableName(tableName);
887 sendBase("getColumnDescriptors", args);
888 }
889
890 public Map<ByteBuffer,ColumnDescriptor> recv_getColumnDescriptors() throws IOError, org.apache.thrift.TException
891 {
892 getColumnDescriptors_result result = new getColumnDescriptors_result();
893 receiveBase(result, "getColumnDescriptors");
894 if (result.isSetSuccess()) {
895 return result.success;
896 }
897 if (result.io != null) {
898 throw result.io;
899 }
900 throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getColumnDescriptors failed: unknown result");
901 }
902
903 public List<TRegionInfo> getTableRegions(ByteBuffer tableName) throws IOError, org.apache.thrift.TException
904 {
905 send_getTableRegions(tableName);
906 return recv_getTableRegions();
907 }
908
909 public void send_getTableRegions(ByteBuffer tableName) throws org.apache.thrift.TException
910 {
911 getTableRegions_args args = new getTableRegions_args();
912 args.setTableName(tableName);
913 sendBase("getTableRegions", args);
914 }
915
916 public List<TRegionInfo> recv_getTableRegions() throws IOError, org.apache.thrift.TException
917 {
918 getTableRegions_result result = new getTableRegions_result();
919 receiveBase(result, "getTableRegions");
920 if (result.isSetSuccess()) {
921 return result.success;
922 }
923 if (result.io != null) {
924 throw result.io;
925 }
926 throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getTableRegions failed: unknown result");
927 }
928
929 public void createTable(ByteBuffer tableName, List<ColumnDescriptor> columnFamilies) throws IOError, IllegalArgument, AlreadyExists, org.apache.thrift.TException
930 {
931 send_createTable(tableName, columnFamilies);
932 recv_createTable();
933 }
934
935 public void send_createTable(ByteBuffer tableName, List<ColumnDescriptor> columnFamilies) throws org.apache.thrift.TException
936 {
937 createTable_args args = new createTable_args();
938 args.setTableName(tableName);
939 args.setColumnFamilies(columnFamilies);
940 sendBase("createTable", args);
941 }
942
943 public void recv_createTable() throws IOError, IllegalArgument, AlreadyExists, org.apache.thrift.TException
944 {
945 createTable_result result = new createTable_result();
946 receiveBase(result, "createTable");
947 if (result.io != null) {
948 throw result.io;
949 }
950 if (result.ia != null) {
951 throw result.ia;
952 }
953 if (result.exist != null) {
954 throw result.exist;
955 }
956 return;
957 }
958
959 public void deleteTable(ByteBuffer tableName) throws IOError, org.apache.thrift.TException
960 {
961 send_deleteTable(tableName);
962 recv_deleteTable();
963 }
964
965 public void send_deleteTable(ByteBuffer tableName) throws org.apache.thrift.TException
966 {
967 deleteTable_args args = new deleteTable_args();
968 args.setTableName(tableName);
969 sendBase("deleteTable", args);
970 }
971
972 public void recv_deleteTable() throws IOError, org.apache.thrift.TException
973 {
974 deleteTable_result result = new deleteTable_result();
975 receiveBase(result, "deleteTable");
976 if (result.io != null) {
977 throw result.io;
978 }
979 return;
980 }
981
982 public List<TCell> get(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException
983 {
984 send_get(tableName, row, column, attributes);
985 return recv_get();
986 }
987
988 public void send_get(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, Map<ByteBuffer,ByteBuffer> attributes) throws org.apache.thrift.TException
989 {
990 get_args args = new get_args();
991 args.setTableName(tableName);
992 args.setRow(row);
993 args.setColumn(column);
994 args.setAttributes(attributes);
995 sendBase("get", args);
996 }
997
998 public List<TCell> recv_get() throws IOError, org.apache.thrift.TException
999 {
1000 get_result result = new get_result();
1001 receiveBase(result, "get");
1002 if (result.isSetSuccess()) {
1003 return result.success;
1004 }
1005 if (result.io != null) {
1006 throw result.io;
1007 }
1008 throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "get failed: unknown result");
1009 }
1010
1011 public List<TCell> getVer(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, int numVersions, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException
1012 {
1013 send_getVer(tableName, row, column, numVersions, attributes);
1014 return recv_getVer();
1015 }
1016
1017 public void send_getVer(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, int numVersions, Map<ByteBuffer,ByteBuffer> attributes) throws org.apache.thrift.TException
1018 {
1019 getVer_args args = new getVer_args();
1020 args.setTableName(tableName);
1021 args.setRow(row);
1022 args.setColumn(column);
1023 args.setNumVersions(numVersions);
1024 args.setAttributes(attributes);
1025 sendBase("getVer", args);
1026 }
1027
1028 public List<TCell> recv_getVer() throws IOError, org.apache.thrift.TException
1029 {
1030 getVer_result result = new getVer_result();
1031 receiveBase(result, "getVer");
1032 if (result.isSetSuccess()) {
1033 return result.success;
1034 }
1035 if (result.io != null) {
1036 throw result.io;
1037 }
1038 throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getVer failed: unknown result");
1039 }
1040
1041 public List<TCell> getVerTs(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, long timestamp, int numVersions, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException
1042 {
1043 send_getVerTs(tableName, row, column, timestamp, numVersions, attributes);
1044 return recv_getVerTs();
1045 }
1046
1047 public void send_getVerTs(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, long timestamp, int numVersions, Map<ByteBuffer,ByteBuffer> attributes) throws org.apache.thrift.TException
1048 {
1049 getVerTs_args args = new getVerTs_args();
1050 args.setTableName(tableName);
1051 args.setRow(row);
1052 args.setColumn(column);
1053 args.setTimestamp(timestamp);
1054 args.setNumVersions(numVersions);
1055 args.setAttributes(attributes);
1056 sendBase("getVerTs", args);
1057 }
1058
1059 public List<TCell> recv_getVerTs() throws IOError, org.apache.thrift.TException
1060 {
1061 getVerTs_result result = new getVerTs_result();
1062 receiveBase(result, "getVerTs");
1063 if (result.isSetSuccess()) {
1064 return result.success;
1065 }
1066 if (result.io != null) {
1067 throw result.io;
1068 }
1069 throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getVerTs failed: unknown result");
1070 }
1071
1072 public List<TRowResult> getRow(ByteBuffer tableName, ByteBuffer row, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException
1073 {
1074 send_getRow(tableName, row, attributes);
1075 return recv_getRow();
1076 }
1077
1078 public void send_getRow(ByteBuffer tableName, ByteBuffer row, Map<ByteBuffer,ByteBuffer> attributes) throws org.apache.thrift.TException
1079 {
1080 getRow_args args = new getRow_args();
1081 args.setTableName(tableName);
1082 args.setRow(row);
1083 args.setAttributes(attributes);
1084 sendBase("getRow", args);
1085 }
1086
1087 public List<TRowResult> recv_getRow() throws IOError, org.apache.thrift.TException
1088 {
1089 getRow_result result = new getRow_result();
1090 receiveBase(result, "getRow");
1091 if (result.isSetSuccess()) {
1092 return result.success;
1093 }
1094 if (result.io != null) {
1095 throw result.io;
1096 }
1097 throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getRow failed: unknown result");
1098 }
1099
1100 public List<TRowResult> getRowWithColumns(ByteBuffer tableName, ByteBuffer row, List<ByteBuffer> columns, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException
1101 {
1102 send_getRowWithColumns(tableName, row, columns, attributes);
1103 return recv_getRowWithColumns();
1104 }
1105
1106 public void send_getRowWithColumns(ByteBuffer tableName, ByteBuffer row, List<ByteBuffer> columns, Map<ByteBuffer,ByteBuffer> attributes) throws org.apache.thrift.TException
1107 {
1108 getRowWithColumns_args args = new getRowWithColumns_args();
1109 args.setTableName(tableName);
1110 args.setRow(row);
1111 args.setColumns(columns);
1112 args.setAttributes(attributes);
1113 sendBase("getRowWithColumns", args);
1114 }
1115
1116 public List<TRowResult> recv_getRowWithColumns() throws IOError, org.apache.thrift.TException
1117 {
1118 getRowWithColumns_result result = new getRowWithColumns_result();
1119 receiveBase(result, "getRowWithColumns");
1120 if (result.isSetSuccess()) {
1121 return result.success;
1122 }
1123 if (result.io != null) {
1124 throw result.io;
1125 }
1126 throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getRowWithColumns failed: unknown result");
1127 }
1128
1129 public List<TRowResult> getRowTs(ByteBuffer tableName, ByteBuffer row, long timestamp, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException
1130 {
1131 send_getRowTs(tableName, row, timestamp, attributes);
1132 return recv_getRowTs();
1133 }
1134
1135 public void send_getRowTs(ByteBuffer tableName, ByteBuffer row, long timestamp, Map<ByteBuffer,ByteBuffer> attributes) throws org.apache.thrift.TException
1136 {
1137 getRowTs_args args = new getRowTs_args();
1138 args.setTableName(tableName);
1139 args.setRow(row);
1140 args.setTimestamp(timestamp);
1141 args.setAttributes(attributes);
1142 sendBase("getRowTs", args);
1143 }
1144
1145 public List<TRowResult> recv_getRowTs() throws IOError, org.apache.thrift.TException
1146 {
1147 getRowTs_result result = new getRowTs_result();
1148 receiveBase(result, "getRowTs");
1149 if (result.isSetSuccess()) {
1150 return result.success;
1151 }
1152 if (result.io != null) {
1153 throw result.io;
1154 }
1155 throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getRowTs failed: unknown result");
1156 }
1157
1158 public List<TRowResult> getRowWithColumnsTs(ByteBuffer tableName, ByteBuffer row, List<ByteBuffer> columns, long timestamp, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException
1159 {
1160 send_getRowWithColumnsTs(tableName, row, columns, timestamp, attributes);
1161 return recv_getRowWithColumnsTs();
1162 }
1163
1164 public void send_getRowWithColumnsTs(ByteBuffer tableName, ByteBuffer row, List<ByteBuffer> columns, long timestamp, Map<ByteBuffer,ByteBuffer> attributes) throws org.apache.thrift.TException
1165 {
1166 getRowWithColumnsTs_args args = new getRowWithColumnsTs_args();
1167 args.setTableName(tableName);
1168 args.setRow(row);
1169 args.setColumns(columns);
1170 args.setTimestamp(timestamp);
1171 args.setAttributes(attributes);
1172 sendBase("getRowWithColumnsTs", args);
1173 }
1174
1175 public List<TRowResult> recv_getRowWithColumnsTs() throws IOError, org.apache.thrift.TException
1176 {
1177 getRowWithColumnsTs_result result = new getRowWithColumnsTs_result();
1178 receiveBase(result, "getRowWithColumnsTs");
1179 if (result.isSetSuccess()) {
1180 return result.success;
1181 }
1182 if (result.io != null) {
1183 throw result.io;
1184 }
1185 throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getRowWithColumnsTs failed: unknown result");
1186 }
1187
1188 public List<TRowResult> getRows(ByteBuffer tableName, List<ByteBuffer> rows, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException
1189 {
1190 send_getRows(tableName, rows, attributes);
1191 return recv_getRows();
1192 }
1193
1194 public void send_getRows(ByteBuffer tableName, List<ByteBuffer> rows, Map<ByteBuffer,ByteBuffer> attributes) throws org.apache.thrift.TException
1195 {
1196 getRows_args args = new getRows_args();
1197 args.setTableName(tableName);
1198 args.setRows(rows);
1199 args.setAttributes(attributes);
1200 sendBase("getRows", args);
1201 }
1202
1203 public List<TRowResult> recv_getRows() throws IOError, org.apache.thrift.TException
1204 {
1205 getRows_result result = new getRows_result();
1206 receiveBase(result, "getRows");
1207 if (result.isSetSuccess()) {
1208 return result.success;
1209 }
1210 if (result.io != null) {
1211 throw result.io;
1212 }
1213 throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getRows failed: unknown result");
1214 }
1215
1216 public List<TRowResult> getRowsWithColumns(ByteBuffer tableName, List<ByteBuffer> rows, List<ByteBuffer> columns, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException
1217 {
1218 send_getRowsWithColumns(tableName, rows, columns, attributes);
1219 return recv_getRowsWithColumns();
1220 }
1221
1222 public void send_getRowsWithColumns(ByteBuffer tableName, List<ByteBuffer> rows, List<ByteBuffer> columns, Map<ByteBuffer,ByteBuffer> attributes) throws org.apache.thrift.TException
1223 {
1224 getRowsWithColumns_args args = new getRowsWithColumns_args();
1225 args.setTableName(tableName);
1226 args.setRows(rows);
1227 args.setColumns(columns);
1228 args.setAttributes(attributes);
1229 sendBase("getRowsWithColumns", args);
1230 }
1231
1232 public List<TRowResult> recv_getRowsWithColumns() throws IOError, org.apache.thrift.TException
1233 {
1234 getRowsWithColumns_result result = new getRowsWithColumns_result();
1235 receiveBase(result, "getRowsWithColumns");
1236 if (result.isSetSuccess()) {
1237 return result.success;
1238 }
1239 if (result.io != null) {
1240 throw result.io;
1241 }
1242 throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getRowsWithColumns failed: unknown result");
1243 }
1244
1245 public List<TRowResult> getRowsTs(ByteBuffer tableName, List<ByteBuffer> rows, long timestamp, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException
1246 {
1247 send_getRowsTs(tableName, rows, timestamp, attributes);
1248 return recv_getRowsTs();
1249 }
1250
1251 public void send_getRowsTs(ByteBuffer tableName, List<ByteBuffer> rows, long timestamp, Map<ByteBuffer,ByteBuffer> attributes) throws org.apache.thrift.TException
1252 {
1253 getRowsTs_args args = new getRowsTs_args();
1254 args.setTableName(tableName);
1255 args.setRows(rows);
1256 args.setTimestamp(timestamp);
1257 args.setAttributes(attributes);
1258 sendBase("getRowsTs", args);
1259 }
1260
1261 public List<TRowResult> recv_getRowsTs() throws IOError, org.apache.thrift.TException
1262 {
1263 getRowsTs_result result = new getRowsTs_result();
1264 receiveBase(result, "getRowsTs");
1265 if (result.isSetSuccess()) {
1266 return result.success;
1267 }
1268 if (result.io != null) {
1269 throw result.io;
1270 }
1271 throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getRowsTs failed: unknown result");
1272 }
1273
1274 public List<TRowResult> getRowsWithColumnsTs(ByteBuffer tableName, List<ByteBuffer> rows, List<ByteBuffer> columns, long timestamp, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException
1275 {
1276 send_getRowsWithColumnsTs(tableName, rows, columns, timestamp, attributes);
1277 return recv_getRowsWithColumnsTs();
1278 }
1279
1280 public void send_getRowsWithColumnsTs(ByteBuffer tableName, List<ByteBuffer> rows, List<ByteBuffer> columns, long timestamp, Map<ByteBuffer,ByteBuffer> attributes) throws org.apache.thrift.TException
1281 {
1282 getRowsWithColumnsTs_args args = new getRowsWithColumnsTs_args();
1283 args.setTableName(tableName);
1284 args.setRows(rows);
1285 args.setColumns(columns);
1286 args.setTimestamp(timestamp);
1287 args.setAttributes(attributes);
1288 sendBase("getRowsWithColumnsTs", args);
1289 }
1290
1291 public List<TRowResult> recv_getRowsWithColumnsTs() throws IOError, org.apache.thrift.TException
1292 {
1293 getRowsWithColumnsTs_result result = new getRowsWithColumnsTs_result();
1294 receiveBase(result, "getRowsWithColumnsTs");
1295 if (result.isSetSuccess()) {
1296 return result.success;
1297 }
1298 if (result.io != null) {
1299 throw result.io;
1300 }
1301 throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getRowsWithColumnsTs failed: unknown result");
1302 }
1303
1304 public void mutateRow(ByteBuffer tableName, ByteBuffer row, List<Mutation> mutations, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, IllegalArgument, org.apache.thrift.TException
1305 {
1306 send_mutateRow(tableName, row, mutations, attributes);
1307 recv_mutateRow();
1308 }
1309
1310 public void send_mutateRow(ByteBuffer tableName, ByteBuffer row, List<Mutation> mutations, Map<ByteBuffer,ByteBuffer> attributes) throws org.apache.thrift.TException
1311 {
1312 mutateRow_args args = new mutateRow_args();
1313 args.setTableName(tableName);
1314 args.setRow(row);
1315 args.setMutations(mutations);
1316 args.setAttributes(attributes);
1317 sendBase("mutateRow", args);
1318 }
1319
1320 public void recv_mutateRow() throws IOError, IllegalArgument, org.apache.thrift.TException
1321 {
1322 mutateRow_result result = new mutateRow_result();
1323 receiveBase(result, "mutateRow");
1324 if (result.io != null) {
1325 throw result.io;
1326 }
1327 if (result.ia != null) {
1328 throw result.ia;
1329 }
1330 return;
1331 }
1332
1333 public void mutateRowTs(ByteBuffer tableName, ByteBuffer row, List<Mutation> mutations, long timestamp, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, IllegalArgument, org.apache.thrift.TException
1334 {
1335 send_mutateRowTs(tableName, row, mutations, timestamp, attributes);
1336 recv_mutateRowTs();
1337 }
1338
1339 public void send_mutateRowTs(ByteBuffer tableName, ByteBuffer row, List<Mutation> mutations, long timestamp, Map<ByteBuffer,ByteBuffer> attributes) throws org.apache.thrift.TException
1340 {
1341 mutateRowTs_args args = new mutateRowTs_args();
1342 args.setTableName(tableName);
1343 args.setRow(row);
1344 args.setMutations(mutations);
1345 args.setTimestamp(timestamp);
1346 args.setAttributes(attributes);
1347 sendBase("mutateRowTs", args);
1348 }
1349
1350 public void recv_mutateRowTs() throws IOError, IllegalArgument, org.apache.thrift.TException
1351 {
1352 mutateRowTs_result result = new mutateRowTs_result();
1353 receiveBase(result, "mutateRowTs");
1354 if (result.io != null) {
1355 throw result.io;
1356 }
1357 if (result.ia != null) {
1358 throw result.ia;
1359 }
1360 return;
1361 }
1362
1363 public void mutateRows(ByteBuffer tableName, List<BatchMutation> rowBatches, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, IllegalArgument, org.apache.thrift.TException
1364 {
1365 send_mutateRows(tableName, rowBatches, attributes);
1366 recv_mutateRows();
1367 }
1368
1369 public void send_mutateRows(ByteBuffer tableName, List<BatchMutation> rowBatches, Map<ByteBuffer,ByteBuffer> attributes) throws org.apache.thrift.TException
1370 {
1371 mutateRows_args args = new mutateRows_args();
1372 args.setTableName(tableName);
1373 args.setRowBatches(rowBatches);
1374 args.setAttributes(attributes);
1375 sendBase("mutateRows", args);
1376 }
1377
1378 public void recv_mutateRows() throws IOError, IllegalArgument, org.apache.thrift.TException
1379 {
1380 mutateRows_result result = new mutateRows_result();
1381 receiveBase(result, "mutateRows");
1382 if (result.io != null) {
1383 throw result.io;
1384 }
1385 if (result.ia != null) {
1386 throw result.ia;
1387 }
1388 return;
1389 }
1390
1391 public void mutateRowsTs(ByteBuffer tableName, List<BatchMutation> rowBatches, long timestamp, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, IllegalArgument, org.apache.thrift.TException
1392 {
1393 send_mutateRowsTs(tableName, rowBatches, timestamp, attributes);
1394 recv_mutateRowsTs();
1395 }
1396
1397 public void send_mutateRowsTs(ByteBuffer tableName, List<BatchMutation> rowBatches, long timestamp, Map<ByteBuffer,ByteBuffer> attributes) throws org.apache.thrift.TException
1398 {
1399 mutateRowsTs_args args = new mutateRowsTs_args();
1400 args.setTableName(tableName);
1401 args.setRowBatches(rowBatches);
1402 args.setTimestamp(timestamp);
1403 args.setAttributes(attributes);
1404 sendBase("mutateRowsTs", args);
1405 }
1406
1407 public void recv_mutateRowsTs() throws IOError, IllegalArgument, org.apache.thrift.TException
1408 {
1409 mutateRowsTs_result result = new mutateRowsTs_result();
1410 receiveBase(result, "mutateRowsTs");
1411 if (result.io != null) {
1412 throw result.io;
1413 }
1414 if (result.ia != null) {
1415 throw result.ia;
1416 }
1417 return;
1418 }
1419
1420 public long atomicIncrement(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, long value) throws IOError, IllegalArgument, org.apache.thrift.TException
1421 {
1422 send_atomicIncrement(tableName, row, column, value);
1423 return recv_atomicIncrement();
1424 }
1425
1426 public void send_atomicIncrement(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, long value) throws org.apache.thrift.TException
1427 {
1428 atomicIncrement_args args = new atomicIncrement_args();
1429 args.setTableName(tableName);
1430 args.setRow(row);
1431 args.setColumn(column);
1432 args.setValue(value);
1433 sendBase("atomicIncrement", args);
1434 }
1435
1436 public long recv_atomicIncrement() throws IOError, IllegalArgument, org.apache.thrift.TException
1437 {
1438 atomicIncrement_result result = new atomicIncrement_result();
1439 receiveBase(result, "atomicIncrement");
1440 if (result.isSetSuccess()) {
1441 return result.success;
1442 }
1443 if (result.io != null) {
1444 throw result.io;
1445 }
1446 if (result.ia != null) {
1447 throw result.ia;
1448 }
1449 throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "atomicIncrement failed: unknown result");
1450 }
1451
1452 public void deleteAll(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException
1453 {
1454 send_deleteAll(tableName, row, column, attributes);
1455 recv_deleteAll();
1456 }
1457
1458 public void send_deleteAll(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, Map<ByteBuffer,ByteBuffer> attributes) throws org.apache.thrift.TException
1459 {
1460 deleteAll_args args = new deleteAll_args();
1461 args.setTableName(tableName);
1462 args.setRow(row);
1463 args.setColumn(column);
1464 args.setAttributes(attributes);
1465 sendBase("deleteAll", args);
1466 }
1467
1468 public void recv_deleteAll() throws IOError, org.apache.thrift.TException
1469 {
1470 deleteAll_result result = new deleteAll_result();
1471 receiveBase(result, "deleteAll");
1472 if (result.io != null) {
1473 throw result.io;
1474 }
1475 return;
1476 }
1477
1478 public void deleteAllTs(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, long timestamp, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException
1479 {
1480 send_deleteAllTs(tableName, row, column, timestamp, attributes);
1481 recv_deleteAllTs();
1482 }
1483
1484 public void send_deleteAllTs(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, long timestamp, Map<ByteBuffer,ByteBuffer> attributes) throws org.apache.thrift.TException
1485 {
1486 deleteAllTs_args args = new deleteAllTs_args();
1487 args.setTableName(tableName);
1488 args.setRow(row);
1489 args.setColumn(column);
1490 args.setTimestamp(timestamp);
1491 args.setAttributes(attributes);
1492 sendBase("deleteAllTs", args);
1493 }
1494
1495 public void recv_deleteAllTs() throws IOError, org.apache.thrift.TException
1496 {
1497 deleteAllTs_result result = new deleteAllTs_result();
1498 receiveBase(result, "deleteAllTs");
1499 if (result.io != null) {
1500 throw result.io;
1501 }
1502 return;
1503 }
1504
1505 public void deleteAllRow(ByteBuffer tableName, ByteBuffer row, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException
1506 {
1507 send_deleteAllRow(tableName, row, attributes);
1508 recv_deleteAllRow();
1509 }
1510
1511 public void send_deleteAllRow(ByteBuffer tableName, ByteBuffer row, Map<ByteBuffer,ByteBuffer> attributes) throws org.apache.thrift.TException
1512 {
1513 deleteAllRow_args args = new deleteAllRow_args();
1514 args.setTableName(tableName);
1515 args.setRow(row);
1516 args.setAttributes(attributes);
1517 sendBase("deleteAllRow", args);
1518 }
1519
1520 public void recv_deleteAllRow() throws IOError, org.apache.thrift.TException
1521 {
1522 deleteAllRow_result result = new deleteAllRow_result();
1523 receiveBase(result, "deleteAllRow");
1524 if (result.io != null) {
1525 throw result.io;
1526 }
1527 return;
1528 }
1529
1530 public void increment(TIncrement increment) throws IOError, org.apache.thrift.TException
1531 {
1532 send_increment(increment);
1533 recv_increment();
1534 }
1535
1536 public void send_increment(TIncrement increment) throws org.apache.thrift.TException
1537 {
1538 increment_args args = new increment_args();
1539 args.setIncrement(increment);
1540 sendBase("increment", args);
1541 }
1542
1543 public void recv_increment() throws IOError, org.apache.thrift.TException
1544 {
1545 increment_result result = new increment_result();
1546 receiveBase(result, "increment");
1547 if (result.io != null) {
1548 throw result.io;
1549 }
1550 return;
1551 }
1552
1553 public void incrementRows(List<TIncrement> increments) throws IOError, org.apache.thrift.TException
1554 {
1555 send_incrementRows(increments);
1556 recv_incrementRows();
1557 }
1558
1559 public void send_incrementRows(List<TIncrement> increments) throws org.apache.thrift.TException
1560 {
1561 incrementRows_args args = new incrementRows_args();
1562 args.setIncrements(increments);
1563 sendBase("incrementRows", args);
1564 }
1565
1566 public void recv_incrementRows() throws IOError, org.apache.thrift.TException
1567 {
1568 incrementRows_result result = new incrementRows_result();
1569 receiveBase(result, "incrementRows");
1570 if (result.io != null) {
1571 throw result.io;
1572 }
1573 return;
1574 }
1575
1576 public void deleteAllRowTs(ByteBuffer tableName, ByteBuffer row, long timestamp, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException
1577 {
1578 send_deleteAllRowTs(tableName, row, timestamp, attributes);
1579 recv_deleteAllRowTs();
1580 }
1581
1582 public void send_deleteAllRowTs(ByteBuffer tableName, ByteBuffer row, long timestamp, Map<ByteBuffer,ByteBuffer> attributes) throws org.apache.thrift.TException
1583 {
1584 deleteAllRowTs_args args = new deleteAllRowTs_args();
1585 args.setTableName(tableName);
1586 args.setRow(row);
1587 args.setTimestamp(timestamp);
1588 args.setAttributes(attributes);
1589 sendBase("deleteAllRowTs", args);
1590 }
1591
1592 public void recv_deleteAllRowTs() throws IOError, org.apache.thrift.TException
1593 {
1594 deleteAllRowTs_result result = new deleteAllRowTs_result();
1595 receiveBase(result, "deleteAllRowTs");
1596 if (result.io != null) {
1597 throw result.io;
1598 }
1599 return;
1600 }
1601
1602 public int scannerOpenWithScan(ByteBuffer tableName, TScan scan, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException
1603 {
1604 send_scannerOpenWithScan(tableName, scan, attributes);
1605 return recv_scannerOpenWithScan();
1606 }
1607
1608 public void send_scannerOpenWithScan(ByteBuffer tableName, TScan scan, Map<ByteBuffer,ByteBuffer> attributes) throws org.apache.thrift.TException
1609 {
1610 scannerOpenWithScan_args args = new scannerOpenWithScan_args();
1611 args.setTableName(tableName);
1612 args.setScan(scan);
1613 args.setAttributes(attributes);
1614 sendBase("scannerOpenWithScan", args);
1615 }
1616
1617 public int recv_scannerOpenWithScan() throws IOError, org.apache.thrift.TException
1618 {
1619 scannerOpenWithScan_result result = new scannerOpenWithScan_result();
1620 receiveBase(result, "scannerOpenWithScan");
1621 if (result.isSetSuccess()) {
1622 return result.success;
1623 }
1624 if (result.io != null) {
1625 throw result.io;
1626 }
1627 throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "scannerOpenWithScan failed: unknown result");
1628 }
1629
1630 public int scannerOpen(ByteBuffer tableName, ByteBuffer startRow, List<ByteBuffer> columns, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException
1631 {
1632 send_scannerOpen(tableName, startRow, columns, attributes);
1633 return recv_scannerOpen();
1634 }
1635
1636 public void send_scannerOpen(ByteBuffer tableName, ByteBuffer startRow, List<ByteBuffer> columns, Map<ByteBuffer,ByteBuffer> attributes) throws org.apache.thrift.TException
1637 {
1638 scannerOpen_args args = new scannerOpen_args();
1639 args.setTableName(tableName);
1640 args.setStartRow(startRow);
1641 args.setColumns(columns);
1642 args.setAttributes(attributes);
1643 sendBase("scannerOpen", args);
1644 }
1645
1646 public int recv_scannerOpen() throws IOError, org.apache.thrift.TException
1647 {
1648 scannerOpen_result result = new scannerOpen_result();
1649 receiveBase(result, "scannerOpen");
1650 if (result.isSetSuccess()) {
1651 return result.success;
1652 }
1653 if (result.io != null) {
1654 throw result.io;
1655 }
1656 throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "scannerOpen failed: unknown result");
1657 }
1658
1659 public int scannerOpenWithStop(ByteBuffer tableName, ByteBuffer startRow, ByteBuffer stopRow, List<ByteBuffer> columns, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException
1660 {
1661 send_scannerOpenWithStop(tableName, startRow, stopRow, columns, attributes);
1662 return recv_scannerOpenWithStop();
1663 }
1664
1665 public void send_scannerOpenWithStop(ByteBuffer tableName, ByteBuffer startRow, ByteBuffer stopRow, List<ByteBuffer> columns, Map<ByteBuffer,ByteBuffer> attributes) throws org.apache.thrift.TException
1666 {
1667 scannerOpenWithStop_args args = new scannerOpenWithStop_args();
1668 args.setTableName(tableName);
1669 args.setStartRow(startRow);
1670 args.setStopRow(stopRow);
1671 args.setColumns(columns);
1672 args.setAttributes(attributes);
1673 sendBase("scannerOpenWithStop", args);
1674 }
1675
1676 public int recv_scannerOpenWithStop() throws IOError, org.apache.thrift.TException
1677 {
1678 scannerOpenWithStop_result result = new scannerOpenWithStop_result();
1679 receiveBase(result, "scannerOpenWithStop");
1680 if (result.isSetSuccess()) {
1681 return result.success;
1682 }
1683 if (result.io != null) {
1684 throw result.io;
1685 }
1686 throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "scannerOpenWithStop failed: unknown result");
1687 }
1688
1689 public int scannerOpenWithPrefix(ByteBuffer tableName, ByteBuffer startAndPrefix, List<ByteBuffer> columns, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException
1690 {
1691 send_scannerOpenWithPrefix(tableName, startAndPrefix, columns, attributes);
1692 return recv_scannerOpenWithPrefix();
1693 }
1694
1695 public void send_scannerOpenWithPrefix(ByteBuffer tableName, ByteBuffer startAndPrefix, List<ByteBuffer> columns, Map<ByteBuffer,ByteBuffer> attributes) throws org.apache.thrift.TException
1696 {
1697 scannerOpenWithPrefix_args args = new scannerOpenWithPrefix_args();
1698 args.setTableName(tableName);
1699 args.setStartAndPrefix(startAndPrefix);
1700 args.setColumns(columns);
1701 args.setAttributes(attributes);
1702 sendBase("scannerOpenWithPrefix", args);
1703 }
1704
1705 public int recv_scannerOpenWithPrefix() throws IOError, org.apache.thrift.TException
1706 {
1707 scannerOpenWithPrefix_result result = new scannerOpenWithPrefix_result();
1708 receiveBase(result, "scannerOpenWithPrefix");
1709 if (result.isSetSuccess()) {
1710 return result.success;
1711 }
1712 if (result.io != null) {
1713 throw result.io;
1714 }
1715 throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "scannerOpenWithPrefix failed: unknown result");
1716 }
1717
1718 public int scannerOpenTs(ByteBuffer tableName, ByteBuffer startRow, List<ByteBuffer> columns, long timestamp, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException
1719 {
1720 send_scannerOpenTs(tableName, startRow, columns, timestamp, attributes);
1721 return recv_scannerOpenTs();
1722 }
1723
1724 public void send_scannerOpenTs(ByteBuffer tableName, ByteBuffer startRow, List<ByteBuffer> columns, long timestamp, Map<ByteBuffer,ByteBuffer> attributes) throws org.apache.thrift.TException
1725 {
1726 scannerOpenTs_args args = new scannerOpenTs_args();
1727 args.setTableName(tableName);
1728 args.setStartRow(startRow);
1729 args.setColumns(columns);
1730 args.setTimestamp(timestamp);
1731 args.setAttributes(attributes);
1732 sendBase("scannerOpenTs", args);
1733 }
1734
1735 public int recv_scannerOpenTs() throws IOError, org.apache.thrift.TException
1736 {
1737 scannerOpenTs_result result = new scannerOpenTs_result();
1738 receiveBase(result, "scannerOpenTs");
1739 if (result.isSetSuccess()) {
1740 return result.success;
1741 }
1742 if (result.io != null) {
1743 throw result.io;
1744 }
1745 throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "scannerOpenTs failed: unknown result");
1746 }
1747
1748 public int scannerOpenWithStopTs(ByteBuffer tableName, ByteBuffer startRow, ByteBuffer stopRow, List<ByteBuffer> columns, long timestamp, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException
1749 {
1750 send_scannerOpenWithStopTs(tableName, startRow, stopRow, columns, timestamp, attributes);
1751 return recv_scannerOpenWithStopTs();
1752 }
1753
1754 public void send_scannerOpenWithStopTs(ByteBuffer tableName, ByteBuffer startRow, ByteBuffer stopRow, List<ByteBuffer> columns, long timestamp, Map<ByteBuffer,ByteBuffer> attributes) throws org.apache.thrift.TException
1755 {
1756 scannerOpenWithStopTs_args args = new scannerOpenWithStopTs_args();
1757 args.setTableName(tableName);
1758 args.setStartRow(startRow);
1759 args.setStopRow(stopRow);
1760 args.setColumns(columns);
1761 args.setTimestamp(timestamp);
1762 args.setAttributes(attributes);
1763 sendBase("scannerOpenWithStopTs", args);
1764 }
1765
1766 public int recv_scannerOpenWithStopTs() throws IOError, org.apache.thrift.TException
1767 {
1768 scannerOpenWithStopTs_result result = new scannerOpenWithStopTs_result();
1769 receiveBase(result, "scannerOpenWithStopTs");
1770 if (result.isSetSuccess()) {
1771 return result.success;
1772 }
1773 if (result.io != null) {
1774 throw result.io;
1775 }
1776 throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "scannerOpenWithStopTs failed: unknown result");
1777 }
1778
1779 public List<TRowResult> scannerGet(int id) throws IOError, IllegalArgument, org.apache.thrift.TException
1780 {
1781 send_scannerGet(id);
1782 return recv_scannerGet();
1783 }
1784
1785 public void send_scannerGet(int id) throws org.apache.thrift.TException
1786 {
1787 scannerGet_args args = new scannerGet_args();
1788 args.setId(id);
1789 sendBase("scannerGet", args);
1790 }
1791
1792 public List<TRowResult> recv_scannerGet() throws IOError, IllegalArgument, org.apache.thrift.TException
1793 {
1794 scannerGet_result result = new scannerGet_result();
1795 receiveBase(result, "scannerGet");
1796 if (result.isSetSuccess()) {
1797 return result.success;
1798 }
1799 if (result.io != null) {
1800 throw result.io;
1801 }
1802 if (result.ia != null) {
1803 throw result.ia;
1804 }
1805 throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "scannerGet failed: unknown result");
1806 }
1807
1808 public List<TRowResult> scannerGetList(int id, int nbRows) throws IOError, IllegalArgument, org.apache.thrift.TException
1809 {
1810 send_scannerGetList(id, nbRows);
1811 return recv_scannerGetList();
1812 }
1813
1814 public void send_scannerGetList(int id, int nbRows) throws org.apache.thrift.TException
1815 {
1816 scannerGetList_args args = new scannerGetList_args();
1817 args.setId(id);
1818 args.setNbRows(nbRows);
1819 sendBase("scannerGetList", args);
1820 }
1821
1822 public List<TRowResult> recv_scannerGetList() throws IOError, IllegalArgument, org.apache.thrift.TException
1823 {
1824 scannerGetList_result result = new scannerGetList_result();
1825 receiveBase(result, "scannerGetList");
1826 if (result.isSetSuccess()) {
1827 return result.success;
1828 }
1829 if (result.io != null) {
1830 throw result.io;
1831 }
1832 if (result.ia != null) {
1833 throw result.ia;
1834 }
1835 throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "scannerGetList failed: unknown result");
1836 }
1837
1838 public void scannerClose(int id) throws IOError, IllegalArgument, org.apache.thrift.TException
1839 {
1840 send_scannerClose(id);
1841 recv_scannerClose();
1842 }
1843
1844 public void send_scannerClose(int id) throws org.apache.thrift.TException
1845 {
1846 scannerClose_args args = new scannerClose_args();
1847 args.setId(id);
1848 sendBase("scannerClose", args);
1849 }
1850
1851 public void recv_scannerClose() throws IOError, IllegalArgument, org.apache.thrift.TException
1852 {
1853 scannerClose_result result = new scannerClose_result();
1854 receiveBase(result, "scannerClose");
1855 if (result.io != null) {
1856 throw result.io;
1857 }
1858 if (result.ia != null) {
1859 throw result.ia;
1860 }
1861 return;
1862 }
1863
1864 public List<TCell> getRowOrBefore(ByteBuffer tableName, ByteBuffer row, ByteBuffer family) throws IOError, org.apache.thrift.TException
1865 {
1866 send_getRowOrBefore(tableName, row, family);
1867 return recv_getRowOrBefore();
1868 }
1869
1870 public void send_getRowOrBefore(ByteBuffer tableName, ByteBuffer row, ByteBuffer family) throws org.apache.thrift.TException
1871 {
1872 getRowOrBefore_args args = new getRowOrBefore_args();
1873 args.setTableName(tableName);
1874 args.setRow(row);
1875 args.setFamily(family);
1876 sendBase("getRowOrBefore", args);
1877 }
1878
1879 public List<TCell> recv_getRowOrBefore() throws IOError, org.apache.thrift.TException
1880 {
1881 getRowOrBefore_result result = new getRowOrBefore_result();
1882 receiveBase(result, "getRowOrBefore");
1883 if (result.isSetSuccess()) {
1884 return result.success;
1885 }
1886 if (result.io != null) {
1887 throw result.io;
1888 }
1889 throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getRowOrBefore failed: unknown result");
1890 }
1891
1892 public TRegionInfo getRegionInfo(ByteBuffer row) throws IOError, org.apache.thrift.TException
1893 {
1894 send_getRegionInfo(row);
1895 return recv_getRegionInfo();
1896 }
1897
1898 public void send_getRegionInfo(ByteBuffer row) throws org.apache.thrift.TException
1899 {
1900 getRegionInfo_args args = new getRegionInfo_args();
1901 args.setRow(row);
1902 sendBase("getRegionInfo", args);
1903 }
1904
1905 public TRegionInfo recv_getRegionInfo() throws IOError, org.apache.thrift.TException
1906 {
1907 getRegionInfo_result result = new getRegionInfo_result();
1908 receiveBase(result, "getRegionInfo");
1909 if (result.isSetSuccess()) {
1910 return result.success;
1911 }
1912 if (result.io != null) {
1913 throw result.io;
1914 }
1915 throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getRegionInfo failed: unknown result");
1916 }
1917
1918 }
1919 public static class AsyncClient extends org.apache.thrift.async.TAsyncClient implements AsyncIface {
1920 public static class Factory implements org.apache.thrift.async.TAsyncClientFactory<AsyncClient> {
1921 private org.apache.thrift.async.TAsyncClientManager clientManager;
1922 private org.apache.thrift.protocol.TProtocolFactory protocolFactory;
1923 public Factory(org.apache.thrift.async.TAsyncClientManager clientManager, org.apache.thrift.protocol.TProtocolFactory protocolFactory) {
1924 this.clientManager = clientManager;
1925 this.protocolFactory = protocolFactory;
1926 }
1927 public AsyncClient getAsyncClient(org.apache.thrift.transport.TNonblockingTransport transport) {
1928 return new AsyncClient(protocolFactory, clientManager, transport);
1929 }
1930 }
1931
1932 public AsyncClient(org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.async.TAsyncClientManager clientManager, org.apache.thrift.transport.TNonblockingTransport transport) {
1933 super(protocolFactory, clientManager, transport);
1934 }
1935
1936 public void enableTable(ByteBuffer tableName, org.apache.thrift.async.AsyncMethodCallback<enableTable_call> resultHandler) throws org.apache.thrift.TException {
1937 checkReady();
1938 enableTable_call method_call = new enableTable_call(tableName, resultHandler, this, ___protocolFactory, ___transport);
1939 this.___currentMethod = method_call;
1940 ___manager.call(method_call);
1941 }
1942
1943 public static class enableTable_call extends org.apache.thrift.async.TAsyncMethodCall {
1944 private ByteBuffer tableName;
1945 public enableTable_call(ByteBuffer tableName, org.apache.thrift.async.AsyncMethodCallback<enableTable_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
1946 super(client, protocolFactory, transport, resultHandler, false);
1947 this.tableName = tableName;
1948 }
1949
1950 public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
1951 prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("enableTable", org.apache.thrift.protocol.TMessageType.CALL, 0));
1952 enableTable_args args = new enableTable_args();
1953 args.setTableName(tableName);
1954 args.write(prot);
1955 prot.writeMessageEnd();
1956 }
1957
1958 public void getResult() throws IOError, org.apache.thrift.TException {
1959 if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
1960 throw new IllegalStateException("Method call not finished!");
1961 }
1962 org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
1963 org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
1964 (new Client(prot)).recv_enableTable();
1965 }
1966 }
1967
1968 public void disableTable(ByteBuffer tableName, org.apache.thrift.async.AsyncMethodCallback<disableTable_call> resultHandler) throws org.apache.thrift.TException {
1969 checkReady();
1970 disableTable_call method_call = new disableTable_call(tableName, resultHandler, this, ___protocolFactory, ___transport);
1971 this.___currentMethod = method_call;
1972 ___manager.call(method_call);
1973 }
1974
1975 public static class disableTable_call extends org.apache.thrift.async.TAsyncMethodCall {
1976 private ByteBuffer tableName;
1977 public disableTable_call(ByteBuffer tableName, org.apache.thrift.async.AsyncMethodCallback<disableTable_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
1978 super(client, protocolFactory, transport, resultHandler, false);
1979 this.tableName = tableName;
1980 }
1981
1982 public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
1983 prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("disableTable", org.apache.thrift.protocol.TMessageType.CALL, 0));
1984 disableTable_args args = new disableTable_args();
1985 args.setTableName(tableName);
1986 args.write(prot);
1987 prot.writeMessageEnd();
1988 }
1989
1990 public void getResult() throws IOError, org.apache.thrift.TException {
1991 if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
1992 throw new IllegalStateException("Method call not finished!");
1993 }
1994 org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
1995 org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
1996 (new Client(prot)).recv_disableTable();
1997 }
1998 }
1999
2000 public void isTableEnabled(ByteBuffer tableName, org.apache.thrift.async.AsyncMethodCallback<isTableEnabled_call> resultHandler) throws org.apache.thrift.TException {
2001 checkReady();
2002 isTableEnabled_call method_call = new isTableEnabled_call(tableName, resultHandler, this, ___protocolFactory, ___transport);
2003 this.___currentMethod = method_call;
2004 ___manager.call(method_call);
2005 }
2006
2007 public static class isTableEnabled_call extends org.apache.thrift.async.TAsyncMethodCall {
2008 private ByteBuffer tableName;
2009 public isTableEnabled_call(ByteBuffer tableName, org.apache.thrift.async.AsyncMethodCallback<isTableEnabled_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
2010 super(client, protocolFactory, transport, resultHandler, false);
2011 this.tableName = tableName;
2012 }
2013
2014 public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
2015 prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("isTableEnabled", org.apache.thrift.protocol.TMessageType.CALL, 0));
2016 isTableEnabled_args args = new isTableEnabled_args();
2017 args.setTableName(tableName);
2018 args.write(prot);
2019 prot.writeMessageEnd();
2020 }
2021
2022 public boolean getResult() throws IOError, org.apache.thrift.TException {
2023 if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
2024 throw new IllegalStateException("Method call not finished!");
2025 }
2026 org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
2027 org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
2028 return (new Client(prot)).recv_isTableEnabled();
2029 }
2030 }
2031
2032 public void compact(ByteBuffer tableNameOrRegionName, org.apache.thrift.async.AsyncMethodCallback<compact_call> resultHandler) throws org.apache.thrift.TException {
2033 checkReady();
2034 compact_call method_call = new compact_call(tableNameOrRegionName, resultHandler, this, ___protocolFactory, ___transport);
2035 this.___currentMethod = method_call;
2036 ___manager.call(method_call);
2037 }
2038
2039 public static class compact_call extends org.apache.thrift.async.TAsyncMethodCall {
2040 private ByteBuffer tableNameOrRegionName;
2041 public compact_call(ByteBuffer tableNameOrRegionName, org.apache.thrift.async.AsyncMethodCallback<compact_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
2042 super(client, protocolFactory, transport, resultHandler, false);
2043 this.tableNameOrRegionName = tableNameOrRegionName;
2044 }
2045
2046 public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
2047 prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("compact", org.apache.thrift.protocol.TMessageType.CALL, 0));
2048 compact_args args = new compact_args();
2049 args.setTableNameOrRegionName(tableNameOrRegionName);
2050 args.write(prot);
2051 prot.writeMessageEnd();
2052 }
2053
2054 public void getResult() throws IOError, org.apache.thrift.TException {
2055 if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
2056 throw new IllegalStateException("Method call not finished!");
2057 }
2058 org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
2059 org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
2060 (new Client(prot)).recv_compact();
2061 }
2062 }
2063
2064 public void majorCompact(ByteBuffer tableNameOrRegionName, org.apache.thrift.async.AsyncMethodCallback<majorCompact_call> resultHandler) throws org.apache.thrift.TException {
2065 checkReady();
2066 majorCompact_call method_call = new majorCompact_call(tableNameOrRegionName, resultHandler, this, ___protocolFactory, ___transport);
2067 this.___currentMethod = method_call;
2068 ___manager.call(method_call);
2069 }
2070
2071 public static class majorCompact_call extends org.apache.thrift.async.TAsyncMethodCall {
2072 private ByteBuffer tableNameOrRegionName;
2073 public majorCompact_call(ByteBuffer tableNameOrRegionName, org.apache.thrift.async.AsyncMethodCallback<majorCompact_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
2074 super(client, protocolFactory, transport, resultHandler, false);
2075 this.tableNameOrRegionName = tableNameOrRegionName;
2076 }
2077
2078 public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
2079 prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("majorCompact", org.apache.thrift.protocol.TMessageType.CALL, 0));
2080 majorCompact_args args = new majorCompact_args();
2081 args.setTableNameOrRegionName(tableNameOrRegionName);
2082 args.write(prot);
2083 prot.writeMessageEnd();
2084 }
2085
2086 public void getResult() throws IOError, org.apache.thrift.TException {
2087 if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
2088 throw new IllegalStateException("Method call not finished!");
2089 }
2090 org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
2091 org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
2092 (new Client(prot)).recv_majorCompact();
2093 }
2094 }
2095
2096 public void getTableNames(org.apache.thrift.async.AsyncMethodCallback<getTableNames_call> resultHandler) throws org.apache.thrift.TException {
2097 checkReady();
2098 getTableNames_call method_call = new getTableNames_call(resultHandler, this, ___protocolFactory, ___transport);
2099 this.___currentMethod = method_call;
2100 ___manager.call(method_call);
2101 }
2102
2103 public static class getTableNames_call extends org.apache.thrift.async.TAsyncMethodCall {
2104 public getTableNames_call(org.apache.thrift.async.AsyncMethodCallback<getTableNames_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
2105 super(client, protocolFactory, transport, resultHandler, false);
2106 }
2107
2108 public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
2109 prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getTableNames", org.apache.thrift.protocol.TMessageType.CALL, 0));
2110 getTableNames_args args = new getTableNames_args();
2111 args.write(prot);
2112 prot.writeMessageEnd();
2113 }
2114
2115 public List<ByteBuffer> getResult() throws IOError, org.apache.thrift.TException {
2116 if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
2117 throw new IllegalStateException("Method call not finished!");
2118 }
2119 org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
2120 org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
2121 return (new Client(prot)).recv_getTableNames();
2122 }
2123 }
2124
2125 public void getColumnDescriptors(ByteBuffer tableName, org.apache.thrift.async.AsyncMethodCallback<getColumnDescriptors_call> resultHandler) throws org.apache.thrift.TException {
2126 checkReady();
2127 getColumnDescriptors_call method_call = new getColumnDescriptors_call(tableName, resultHandler, this, ___protocolFactory, ___transport);
2128 this.___currentMethod = method_call;
2129 ___manager.call(method_call);
2130 }
2131
2132 public static class getColumnDescriptors_call extends org.apache.thrift.async.TAsyncMethodCall {
2133 private ByteBuffer tableName;
2134 public getColumnDescriptors_call(ByteBuffer tableName, org.apache.thrift.async.AsyncMethodCallback<getColumnDescriptors_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
2135 super(client, protocolFactory, transport, resultHandler, false);
2136 this.tableName = tableName;
2137 }
2138
2139 public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
2140 prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getColumnDescriptors", org.apache.thrift.protocol.TMessageType.CALL, 0));
2141 getColumnDescriptors_args args = new getColumnDescriptors_args();
2142 args.setTableName(tableName);
2143 args.write(prot);
2144 prot.writeMessageEnd();
2145 }
2146
2147 public Map<ByteBuffer,ColumnDescriptor> getResult() throws IOError, org.apache.thrift.TException {
2148 if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
2149 throw new IllegalStateException("Method call not finished!");
2150 }
2151 org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
2152 org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
2153 return (new Client(prot)).recv_getColumnDescriptors();
2154 }
2155 }
2156
2157 public void getTableRegions(ByteBuffer tableName, org.apache.thrift.async.AsyncMethodCallback<getTableRegions_call> resultHandler) throws org.apache.thrift.TException {
2158 checkReady();
2159 getTableRegions_call method_call = new getTableRegions_call(tableName, resultHandler, this, ___protocolFactory, ___transport);
2160 this.___currentMethod = method_call;
2161 ___manager.call(method_call);
2162 }
2163
2164 public static class getTableRegions_call extends org.apache.thrift.async.TAsyncMethodCall {
2165 private ByteBuffer tableName;
2166 public getTableRegions_call(ByteBuffer tableName, org.apache.thrift.async.AsyncMethodCallback<getTableRegions_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
2167 super(client, protocolFactory, transport, resultHandler, false);
2168 this.tableName = tableName;
2169 }
2170
2171 public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
2172 prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getTableRegions", org.apache.thrift.protocol.TMessageType.CALL, 0));
2173 getTableRegions_args args = new getTableRegions_args();
2174 args.setTableName(tableName);
2175 args.write(prot);
2176 prot.writeMessageEnd();
2177 }
2178
2179 public List<TRegionInfo> getResult() throws IOError, org.apache.thrift.TException {
2180 if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
2181 throw new IllegalStateException("Method call not finished!");
2182 }
2183 org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
2184 org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
2185 return (new Client(prot)).recv_getTableRegions();
2186 }
2187 }
2188
2189 public void createTable(ByteBuffer tableName, List<ColumnDescriptor> columnFamilies, org.apache.thrift.async.AsyncMethodCallback<createTable_call> resultHandler) throws org.apache.thrift.TException {
2190 checkReady();
2191 createTable_call method_call = new createTable_call(tableName, columnFamilies, resultHandler, this, ___protocolFactory, ___transport);
2192 this.___currentMethod = method_call;
2193 ___manager.call(method_call);
2194 }
2195
2196 public static class createTable_call extends org.apache.thrift.async.TAsyncMethodCall {
2197 private ByteBuffer tableName;
2198 private List<ColumnDescriptor> columnFamilies;
2199 public createTable_call(ByteBuffer tableName, List<ColumnDescriptor> columnFamilies, org.apache.thrift.async.AsyncMethodCallback<createTable_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
2200 super(client, protocolFactory, transport, resultHandler, false);
2201 this.tableName = tableName;
2202 this.columnFamilies = columnFamilies;
2203 }
2204
2205 public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
2206 prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("createTable", org.apache.thrift.protocol.TMessageType.CALL, 0));
2207 createTable_args args = new createTable_args();
2208 args.setTableName(tableName);
2209 args.setColumnFamilies(columnFamilies);
2210 args.write(prot);
2211 prot.writeMessageEnd();
2212 }
2213
2214 public void getResult() throws IOError, IllegalArgument, AlreadyExists, org.apache.thrift.TException {
2215 if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
2216 throw new IllegalStateException("Method call not finished!");
2217 }
2218 org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
2219 org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
2220 (new Client(prot)).recv_createTable();
2221 }
2222 }
2223
2224 public void deleteTable(ByteBuffer tableName, org.apache.thrift.async.AsyncMethodCallback<deleteTable_call> resultHandler) throws org.apache.thrift.TException {
2225 checkReady();
2226 deleteTable_call method_call = new deleteTable_call(tableName, resultHandler, this, ___protocolFactory, ___transport);
2227 this.___currentMethod = method_call;
2228 ___manager.call(method_call);
2229 }
2230
2231 public static class deleteTable_call extends org.apache.thrift.async.TAsyncMethodCall {
2232 private ByteBuffer tableName;
2233 public deleteTable_call(ByteBuffer tableName, org.apache.thrift.async.AsyncMethodCallback<deleteTable_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
2234 super(client, protocolFactory, transport, resultHandler, false);
2235 this.tableName = tableName;
2236 }
2237
2238 public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
2239 prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("deleteTable", org.apache.thrift.protocol.TMessageType.CALL, 0));
2240 deleteTable_args args = new deleteTable_args();
2241 args.setTableName(tableName);
2242 args.write(prot);
2243 prot.writeMessageEnd();
2244 }
2245
2246 public void getResult() throws IOError, org.apache.thrift.TException {
2247 if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
2248 throw new IllegalStateException("Method call not finished!");
2249 }
2250 org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
2251 org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
2252 (new Client(prot)).recv_deleteTable();
2253 }
2254 }
2255
2256 public void get(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<get_call> resultHandler) throws org.apache.thrift.TException {
2257 checkReady();
2258 get_call method_call = new get_call(tableName, row, column, attributes, resultHandler, this, ___protocolFactory, ___transport);
2259 this.___currentMethod = method_call;
2260 ___manager.call(method_call);
2261 }
2262
2263 public static class get_call extends org.apache.thrift.async.TAsyncMethodCall {
2264 private ByteBuffer tableName;
2265 private ByteBuffer row;
2266 private ByteBuffer column;
2267 private Map<ByteBuffer,ByteBuffer> attributes;
2268 public get_call(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<get_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
2269 super(client, protocolFactory, transport, resultHandler, false);
2270 this.tableName = tableName;
2271 this.row = row;
2272 this.column = column;
2273 this.attributes = attributes;
2274 }
2275
2276 public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
2277 prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("get", org.apache.thrift.protocol.TMessageType.CALL, 0));
2278 get_args args = new get_args();
2279 args.setTableName(tableName);
2280 args.setRow(row);
2281 args.setColumn(column);
2282 args.setAttributes(attributes);
2283 args.write(prot);
2284 prot.writeMessageEnd();
2285 }
2286
2287 public List<TCell> getResult() throws IOError, org.apache.thrift.TException {
2288 if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
2289 throw new IllegalStateException("Method call not finished!");
2290 }
2291 org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
2292 org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
2293 return (new Client(prot)).recv_get();
2294 }
2295 }
2296
2297 public void getVer(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, int numVersions, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<getVer_call> resultHandler) throws org.apache.thrift.TException {
2298 checkReady();
2299 getVer_call method_call = new getVer_call(tableName, row, column, numVersions, attributes, resultHandler, this, ___protocolFactory, ___transport);
2300 this.___currentMethod = method_call;
2301 ___manager.call(method_call);
2302 }
2303
2304 public static class getVer_call extends org.apache.thrift.async.TAsyncMethodCall {
2305 private ByteBuffer tableName;
2306 private ByteBuffer row;
2307 private ByteBuffer column;
2308 private int numVersions;
2309 private Map<ByteBuffer,ByteBuffer> attributes;
2310 public getVer_call(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, int numVersions, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<getVer_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
2311 super(client, protocolFactory, transport, resultHandler, false);
2312 this.tableName = tableName;
2313 this.row = row;
2314 this.column = column;
2315 this.numVersions = numVersions;
2316 this.attributes = attributes;
2317 }
2318
2319 public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
2320 prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getVer", org.apache.thrift.protocol.TMessageType.CALL, 0));
2321 getVer_args args = new getVer_args();
2322 args.setTableName(tableName);
2323 args.setRow(row);
2324 args.setColumn(column);
2325 args.setNumVersions(numVersions);
2326 args.setAttributes(attributes);
2327 args.write(prot);
2328 prot.writeMessageEnd();
2329 }
2330
2331 public List<TCell> getResult() throws IOError, org.apache.thrift.TException {
2332 if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
2333 throw new IllegalStateException("Method call not finished!");
2334 }
2335 org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
2336 org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
2337 return (new Client(prot)).recv_getVer();
2338 }
2339 }
2340
2341 public void getVerTs(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, long timestamp, int numVersions, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<getVerTs_call> resultHandler) throws org.apache.thrift.TException {
2342 checkReady();
2343 getVerTs_call method_call = new getVerTs_call(tableName, row, column, timestamp, numVersions, attributes, resultHandler, this, ___protocolFactory, ___transport);
2344 this.___currentMethod = method_call;
2345 ___manager.call(method_call);
2346 }
2347
2348 public static class getVerTs_call extends org.apache.thrift.async.TAsyncMethodCall {
2349 private ByteBuffer tableName;
2350 private ByteBuffer row;
2351 private ByteBuffer column;
2352 private long timestamp;
2353 private int numVersions;
2354 private Map<ByteBuffer,ByteBuffer> attributes;
2355 public getVerTs_call(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, long timestamp, int numVersions, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<getVerTs_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
2356 super(client, protocolFactory, transport, resultHandler, false);
2357 this.tableName = tableName;
2358 this.row = row;
2359 this.column = column;
2360 this.timestamp = timestamp;
2361 this.numVersions = numVersions;
2362 this.attributes = attributes;
2363 }
2364
2365 public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
2366 prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getVerTs", org.apache.thrift.protocol.TMessageType.CALL, 0));
2367 getVerTs_args args = new getVerTs_args();
2368 args.setTableName(tableName);
2369 args.setRow(row);
2370 args.setColumn(column);
2371 args.setTimestamp(timestamp);
2372 args.setNumVersions(numVersions);
2373 args.setAttributes(attributes);
2374 args.write(prot);
2375 prot.writeMessageEnd();
2376 }
2377
2378 public List<TCell> getResult() throws IOError, org.apache.thrift.TException {
2379 if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
2380 throw new IllegalStateException("Method call not finished!");
2381 }
2382 org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
2383 org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
2384 return (new Client(prot)).recv_getVerTs();
2385 }
2386 }
2387
2388 public void getRow(ByteBuffer tableName, ByteBuffer row, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<getRow_call> resultHandler) throws org.apache.thrift.TException {
2389 checkReady();
2390 getRow_call method_call = new getRow_call(tableName, row, attributes, resultHandler, this, ___protocolFactory, ___transport);
2391 this.___currentMethod = method_call;
2392 ___manager.call(method_call);
2393 }
2394
2395 public static class getRow_call extends org.apache.thrift.async.TAsyncMethodCall {
2396 private ByteBuffer tableName;
2397 private ByteBuffer row;
2398 private Map<ByteBuffer,ByteBuffer> attributes;
2399 public getRow_call(ByteBuffer tableName, ByteBuffer row, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<getRow_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
2400 super(client, protocolFactory, transport, resultHandler, false);
2401 this.tableName = tableName;
2402 this.row = row;
2403 this.attributes = attributes;
2404 }
2405
2406 public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
2407 prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getRow", org.apache.thrift.protocol.TMessageType.CALL, 0));
2408 getRow_args args = new getRow_args();
2409 args.setTableName(tableName);
2410 args.setRow(row);
2411 args.setAttributes(attributes);
2412 args.write(prot);
2413 prot.writeMessageEnd();
2414 }
2415
2416 public List<TRowResult> getResult() throws IOError, org.apache.thrift.TException {
2417 if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
2418 throw new IllegalStateException("Method call not finished!");
2419 }
2420 org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
2421 org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
2422 return (new Client(prot)).recv_getRow();
2423 }
2424 }
2425
2426 public void getRowWithColumns(ByteBuffer tableName, ByteBuffer row, List<ByteBuffer> columns, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<getRowWithColumns_call> resultHandler) throws org.apache.thrift.TException {
2427 checkReady();
2428 getRowWithColumns_call method_call = new getRowWithColumns_call(tableName, row, columns, attributes, resultHandler, this, ___protocolFactory, ___transport);
2429 this.___currentMethod = method_call;
2430 ___manager.call(method_call);
2431 }
2432
2433 public static class getRowWithColumns_call extends org.apache.thrift.async.TAsyncMethodCall {
2434 private ByteBuffer tableName;
2435 private ByteBuffer row;
2436 private List<ByteBuffer> columns;
2437 private Map<ByteBuffer,ByteBuffer> attributes;
2438 public getRowWithColumns_call(ByteBuffer tableName, ByteBuffer row, List<ByteBuffer> columns, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<getRowWithColumns_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
2439 super(client, protocolFactory, transport, resultHandler, false);
2440 this.tableName = tableName;
2441 this.row = row;
2442 this.columns = columns;
2443 this.attributes = attributes;
2444 }
2445
2446 public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
2447 prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getRowWithColumns", org.apache.thrift.protocol.TMessageType.CALL, 0));
2448 getRowWithColumns_args args = new getRowWithColumns_args();
2449 args.setTableName(tableName);
2450 args.setRow(row);
2451 args.setColumns(columns);
2452 args.setAttributes(attributes);
2453 args.write(prot);
2454 prot.writeMessageEnd();
2455 }
2456
2457 public List<TRowResult> getResult() throws IOError, org.apache.thrift.TException {
2458 if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
2459 throw new IllegalStateException("Method call not finished!");
2460 }
2461 org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
2462 org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
2463 return (new Client(prot)).recv_getRowWithColumns();
2464 }
2465 }
2466
2467 public void getRowTs(ByteBuffer tableName, ByteBuffer row, long timestamp, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<getRowTs_call> resultHandler) throws org.apache.thrift.TException {
2468 checkReady();
2469 getRowTs_call method_call = new getRowTs_call(tableName, row, timestamp, attributes, resultHandler, this, ___protocolFactory, ___transport);
2470 this.___currentMethod = method_call;
2471 ___manager.call(method_call);
2472 }
2473
2474 public static class getRowTs_call extends org.apache.thrift.async.TAsyncMethodCall {
2475 private ByteBuffer tableName;
2476 private ByteBuffer row;
2477 private long timestamp;
2478 private Map<ByteBuffer,ByteBuffer> attributes;
2479 public getRowTs_call(ByteBuffer tableName, ByteBuffer row, long timestamp, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<getRowTs_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
2480 super(client, protocolFactory, transport, resultHandler, false);
2481 this.tableName = tableName;
2482 this.row = row;
2483 this.timestamp = timestamp;
2484 this.attributes = attributes;
2485 }
2486
2487 public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
2488 prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getRowTs", org.apache.thrift.protocol.TMessageType.CALL, 0));
2489 getRowTs_args args = new getRowTs_args();
2490 args.setTableName(tableName);
2491 args.setRow(row);
2492 args.setTimestamp(timestamp);
2493 args.setAttributes(attributes);
2494 args.write(prot);
2495 prot.writeMessageEnd();
2496 }
2497
2498 public List<TRowResult> getResult() throws IOError, org.apache.thrift.TException {
2499 if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
2500 throw new IllegalStateException("Method call not finished!");
2501 }
2502 org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
2503 org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
2504 return (new Client(prot)).recv_getRowTs();
2505 }
2506 }
2507
2508 public void getRowWithColumnsTs(ByteBuffer tableName, ByteBuffer row, List<ByteBuffer> columns, long timestamp, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<getRowWithColumnsTs_call> resultHandler) throws org.apache.thrift.TException {
2509 checkReady();
2510 getRowWithColumnsTs_call method_call = new getRowWithColumnsTs_call(tableName, row, columns, timestamp, attributes, resultHandler, this, ___protocolFactory, ___transport);
2511 this.___currentMethod = method_call;
2512 ___manager.call(method_call);
2513 }
2514
2515 public static class getRowWithColumnsTs_call extends org.apache.thrift.async.TAsyncMethodCall {
2516 private ByteBuffer tableName;
2517 private ByteBuffer row;
2518 private List<ByteBuffer> columns;
2519 private long timestamp;
2520 private Map<ByteBuffer,ByteBuffer> attributes;
2521 public getRowWithColumnsTs_call(ByteBuffer tableName, ByteBuffer row, List<ByteBuffer> columns, long timestamp, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<getRowWithColumnsTs_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
2522 super(client, protocolFactory, transport, resultHandler, false);
2523 this.tableName = tableName;
2524 this.row = row;
2525 this.columns = columns;
2526 this.timestamp = timestamp;
2527 this.attributes = attributes;
2528 }
2529
2530 public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
2531 prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getRowWithColumnsTs", org.apache.thrift.protocol.TMessageType.CALL, 0));
2532 getRowWithColumnsTs_args args = new getRowWithColumnsTs_args();
2533 args.setTableName(tableName);
2534 args.setRow(row);
2535 args.setColumns(columns);
2536 args.setTimestamp(timestamp);
2537 args.setAttributes(attributes);
2538 args.write(prot);
2539 prot.writeMessageEnd();
2540 }
2541
2542 public List<TRowResult> getResult() throws IOError, org.apache.thrift.TException {
2543 if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
2544 throw new IllegalStateException("Method call not finished!");
2545 }
2546 org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
2547 org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
2548 return (new Client(prot)).recv_getRowWithColumnsTs();
2549 }
2550 }
2551
2552 public void getRows(ByteBuffer tableName, List<ByteBuffer> rows, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<getRows_call> resultHandler) throws org.apache.thrift.TException {
2553 checkReady();
2554 getRows_call method_call = new getRows_call(tableName, rows, attributes, resultHandler, this, ___protocolFactory, ___transport);
2555 this.___currentMethod = method_call;
2556 ___manager.call(method_call);
2557 }
2558
2559 public static class getRows_call extends org.apache.thrift.async.TAsyncMethodCall {
2560 private ByteBuffer tableName;
2561 private List<ByteBuffer> rows;
2562 private Map<ByteBuffer,ByteBuffer> attributes;
2563 public getRows_call(ByteBuffer tableName, List<ByteBuffer> rows, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<getRows_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
2564 super(client, protocolFactory, transport, resultHandler, false);
2565 this.tableName = tableName;
2566 this.rows = rows;
2567 this.attributes = attributes;
2568 }
2569
2570 public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
2571 prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getRows", org.apache.thrift.protocol.TMessageType.CALL, 0));
2572 getRows_args args = new getRows_args();
2573 args.setTableName(tableName);
2574 args.setRows(rows);
2575 args.setAttributes(attributes);
2576 args.write(prot);
2577 prot.writeMessageEnd();
2578 }
2579
2580 public List<TRowResult> getResult() throws IOError, org.apache.thrift.TException {
2581 if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
2582 throw new IllegalStateException("Method call not finished!");
2583 }
2584 org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
2585 org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
2586 return (new Client(prot)).recv_getRows();
2587 }
2588 }
2589
2590 public void getRowsWithColumns(ByteBuffer tableName, List<ByteBuffer> rows, List<ByteBuffer> columns, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<getRowsWithColumns_call> resultHandler) throws org.apache.thrift.TException {
2591 checkReady();
2592 getRowsWithColumns_call method_call = new getRowsWithColumns_call(tableName, rows, columns, attributes, resultHandler, this, ___protocolFactory, ___transport);
2593 this.___currentMethod = method_call;
2594 ___manager.call(method_call);
2595 }
2596
2597 public static class getRowsWithColumns_call extends org.apache.thrift.async.TAsyncMethodCall {
2598 private ByteBuffer tableName;
2599 private List<ByteBuffer> rows;
2600 private List<ByteBuffer> columns;
2601 private Map<ByteBuffer,ByteBuffer> attributes;
2602 public getRowsWithColumns_call(ByteBuffer tableName, List<ByteBuffer> rows, List<ByteBuffer> columns, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<getRowsWithColumns_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
2603 super(client, protocolFactory, transport, resultHandler, false);
2604 this.tableName = tableName;
2605 this.rows = rows;
2606 this.columns = columns;
2607 this.attributes = attributes;
2608 }
2609
2610 public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
2611 prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getRowsWithColumns", org.apache.thrift.protocol.TMessageType.CALL, 0));
2612 getRowsWithColumns_args args = new getRowsWithColumns_args();
2613 args.setTableName(tableName);
2614 args.setRows(rows);
2615 args.setColumns(columns);
2616 args.setAttributes(attributes);
2617 args.write(prot);
2618 prot.writeMessageEnd();
2619 }
2620
2621 public List<TRowResult> getResult() throws IOError, org.apache.thrift.TException {
2622 if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
2623 throw new IllegalStateException("Method call not finished!");
2624 }
2625 org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
2626 org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
2627 return (new Client(prot)).recv_getRowsWithColumns();
2628 }
2629 }
2630
2631 public void getRowsTs(ByteBuffer tableName, List<ByteBuffer> rows, long timestamp, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<getRowsTs_call> resultHandler) throws org.apache.thrift.TException {
2632 checkReady();
2633 getRowsTs_call method_call = new getRowsTs_call(tableName, rows, timestamp, attributes, resultHandler, this, ___protocolFactory, ___transport);
2634 this.___currentMethod = method_call;
2635 ___manager.call(method_call);
2636 }
2637
2638 public static class getRowsTs_call extends org.apache.thrift.async.TAsyncMethodCall {
2639 private ByteBuffer tableName;
2640 private List<ByteBuffer> rows;
2641 private long timestamp;
2642 private Map<ByteBuffer,ByteBuffer> attributes;
2643 public getRowsTs_call(ByteBuffer tableName, List<ByteBuffer> rows, long timestamp, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<getRowsTs_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
2644 super(client, protocolFactory, transport, resultHandler, false);
2645 this.tableName = tableName;
2646 this.rows = rows;
2647 this.timestamp = timestamp;
2648 this.attributes = attributes;
2649 }
2650
2651 public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
2652 prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getRowsTs", org.apache.thrift.protocol.TMessageType.CALL, 0));
2653 getRowsTs_args args = new getRowsTs_args();
2654 args.setTableName(tableName);
2655 args.setRows(rows);
2656 args.setTimestamp(timestamp);
2657 args.setAttributes(attributes);
2658 args.write(prot);
2659 prot.writeMessageEnd();
2660 }
2661
2662 public List<TRowResult> getResult() throws IOError, org.apache.thrift.TException {
2663 if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
2664 throw new IllegalStateException("Method call not finished!");
2665 }
2666 org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
2667 org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
2668 return (new Client(prot)).recv_getRowsTs();
2669 }
2670 }
2671
2672 public void getRowsWithColumnsTs(ByteBuffer tableName, List<ByteBuffer> rows, List<ByteBuffer> columns, long timestamp, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<getRowsWithColumnsTs_call> resultHandler) throws org.apache.thrift.TException {
2673 checkReady();
2674 getRowsWithColumnsTs_call method_call = new getRowsWithColumnsTs_call(tableName, rows, columns, timestamp, attributes, resultHandler, this, ___protocolFactory, ___transport);
2675 this.___currentMethod = method_call;
2676 ___manager.call(method_call);
2677 }
2678
2679 public static class getRowsWithColumnsTs_call extends org.apache.thrift.async.TAsyncMethodCall {
2680 private ByteBuffer tableName;
2681 private List<ByteBuffer> rows;
2682 private List<ByteBuffer> columns;
2683 private long timestamp;
2684 private Map<ByteBuffer,ByteBuffer> attributes;
2685 public getRowsWithColumnsTs_call(ByteBuffer tableName, List<ByteBuffer> rows, List<ByteBuffer> columns, long timestamp, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<getRowsWithColumnsTs_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
2686 super(client, protocolFactory, transport, resultHandler, false);
2687 this.tableName = tableName;
2688 this.rows = rows;
2689 this.columns = columns;
2690 this.timestamp = timestamp;
2691 this.attributes = attributes;
2692 }
2693
2694 public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
2695 prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getRowsWithColumnsTs", org.apache.thrift.protocol.TMessageType.CALL, 0));
2696 getRowsWithColumnsTs_args args = new getRowsWithColumnsTs_args();
2697 args.setTableName(tableName);
2698 args.setRows(rows);
2699 args.setColumns(columns);
2700 args.setTimestamp(timestamp);
2701 args.setAttributes(attributes);
2702 args.write(prot);
2703 prot.writeMessageEnd();
2704 }
2705
2706 public List<TRowResult> getResult() throws IOError, org.apache.thrift.TException {
2707 if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
2708 throw new IllegalStateException("Method call not finished!");
2709 }
2710 org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
2711 org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
2712 return (new Client(prot)).recv_getRowsWithColumnsTs();
2713 }
2714 }
2715
2716 public void mutateRow(ByteBuffer tableName, ByteBuffer row, List<Mutation> mutations, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<mutateRow_call> resultHandler) throws org.apache.thrift.TException {
2717 checkReady();
2718 mutateRow_call method_call = new mutateRow_call(tableName, row, mutations, attributes, resultHandler, this, ___protocolFactory, ___transport);
2719 this.___currentMethod = method_call;
2720 ___manager.call(method_call);
2721 }
2722
2723 public static class mutateRow_call extends org.apache.thrift.async.TAsyncMethodCall {
2724 private ByteBuffer tableName;
2725 private ByteBuffer row;
2726 private List<Mutation> mutations;
2727 private Map<ByteBuffer,ByteBuffer> attributes;
2728 public mutateRow_call(ByteBuffer tableName, ByteBuffer row, List<Mutation> mutations, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<mutateRow_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
2729 super(client, protocolFactory, transport, resultHandler, false);
2730 this.tableName = tableName;
2731 this.row = row;
2732 this.mutations = mutations;
2733 this.attributes = attributes;
2734 }
2735
2736 public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
2737 prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("mutateRow", org.apache.thrift.protocol.TMessageType.CALL, 0));
2738 mutateRow_args args = new mutateRow_args();
2739 args.setTableName(tableName);
2740 args.setRow(row);
2741 args.setMutations(mutations);
2742 args.setAttributes(attributes);
2743 args.write(prot);
2744 prot.writeMessageEnd();
2745 }
2746
2747 public void getResult() throws IOError, IllegalArgument, org.apache.thrift.TException {
2748 if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
2749 throw new IllegalStateException("Method call not finished!");
2750 }
2751 org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
2752 org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
2753 (new Client(prot)).recv_mutateRow();
2754 }
2755 }
2756
2757 public void mutateRowTs(ByteBuffer tableName, ByteBuffer row, List<Mutation> mutations, long timestamp, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<mutateRowTs_call> resultHandler) throws org.apache.thrift.TException {
2758 checkReady();
2759 mutateRowTs_call method_call = new mutateRowTs_call(tableName, row, mutations, timestamp, attributes, resultHandler, this, ___protocolFactory, ___transport);
2760 this.___currentMethod = method_call;
2761 ___manager.call(method_call);
2762 }
2763
2764 public static class mutateRowTs_call extends org.apache.thrift.async.TAsyncMethodCall {
2765 private ByteBuffer tableName;
2766 private ByteBuffer row;
2767 private List<Mutation> mutations;
2768 private long timestamp;
2769 private Map<ByteBuffer,ByteBuffer> attributes;
2770 public mutateRowTs_call(ByteBuffer tableName, ByteBuffer row, List<Mutation> mutations, long timestamp, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<mutateRowTs_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
2771 super(client, protocolFactory, transport, resultHandler, false);
2772 this.tableName = tableName;
2773 this.row = row;
2774 this.mutations = mutations;
2775 this.timestamp = timestamp;
2776 this.attributes = attributes;
2777 }
2778
2779 public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
2780 prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("mutateRowTs", org.apache.thrift.protocol.TMessageType.CALL, 0));
2781 mutateRowTs_args args = new mutateRowTs_args();
2782 args.setTableName(tableName);
2783 args.setRow(row);
2784 args.setMutations(mutations);
2785 args.setTimestamp(timestamp);
2786 args.setAttributes(attributes);
2787 args.write(prot);
2788 prot.writeMessageEnd();
2789 }
2790
2791 public void getResult() throws IOError, IllegalArgument, org.apache.thrift.TException {
2792 if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
2793 throw new IllegalStateException("Method call not finished!");
2794 }
2795 org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
2796 org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
2797 (new Client(prot)).recv_mutateRowTs();
2798 }
2799 }
2800
2801 public void mutateRows(ByteBuffer tableName, List<BatchMutation> rowBatches, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<mutateRows_call> resultHandler) throws org.apache.thrift.TException {
2802 checkReady();
2803 mutateRows_call method_call = new mutateRows_call(tableName, rowBatches, attributes, resultHandler, this, ___protocolFactory, ___transport);
2804 this.___currentMethod = method_call;
2805 ___manager.call(method_call);
2806 }
2807
2808 public static class mutateRows_call extends org.apache.thrift.async.TAsyncMethodCall {
2809 private ByteBuffer tableName;
2810 private List<BatchMutation> rowBatches;
2811 private Map<ByteBuffer,ByteBuffer> attributes;
2812 public mutateRows_call(ByteBuffer tableName, List<BatchMutation> rowBatches, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<mutateRows_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
2813 super(client, protocolFactory, transport, resultHandler, false);
2814 this.tableName = tableName;
2815 this.rowBatches = rowBatches;
2816 this.attributes = attributes;
2817 }
2818
2819 public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
2820 prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("mutateRows", org.apache.thrift.protocol.TMessageType.CALL, 0));
2821 mutateRows_args args = new mutateRows_args();
2822 args.setTableName(tableName);
2823 args.setRowBatches(rowBatches);
2824 args.setAttributes(attributes);
2825 args.write(prot);
2826 prot.writeMessageEnd();
2827 }
2828
2829 public void getResult() throws IOError, IllegalArgument, org.apache.thrift.TException {
2830 if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
2831 throw new IllegalStateException("Method call not finished!");
2832 }
2833 org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
2834 org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
2835 (new Client(prot)).recv_mutateRows();
2836 }
2837 }
2838
2839 public void mutateRowsTs(ByteBuffer tableName, List<BatchMutation> rowBatches, long timestamp, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<mutateRowsTs_call> resultHandler) throws org.apache.thrift.TException {
2840 checkReady();
2841 mutateRowsTs_call method_call = new mutateRowsTs_call(tableName, rowBatches, timestamp, attributes, resultHandler, this, ___protocolFactory, ___transport);
2842 this.___currentMethod = method_call;
2843 ___manager.call(method_call);
2844 }
2845
2846 public static class mutateRowsTs_call extends org.apache.thrift.async.TAsyncMethodCall {
2847 private ByteBuffer tableName;
2848 private List<BatchMutation> rowBatches;
2849 private long timestamp;
2850 private Map<ByteBuffer,ByteBuffer> attributes;
2851 public mutateRowsTs_call(ByteBuffer tableName, List<BatchMutation> rowBatches, long timestamp, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<mutateRowsTs_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
2852 super(client, protocolFactory, transport, resultHandler, false);
2853 this.tableName = tableName;
2854 this.rowBatches = rowBatches;
2855 this.timestamp = timestamp;
2856 this.attributes = attributes;
2857 }
2858
2859 public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
2860 prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("mutateRowsTs", org.apache.thrift.protocol.TMessageType.CALL, 0));
2861 mutateRowsTs_args args = new mutateRowsTs_args();
2862 args.setTableName(tableName);
2863 args.setRowBatches(rowBatches);
2864 args.setTimestamp(timestamp);
2865 args.setAttributes(attributes);
2866 args.write(prot);
2867 prot.writeMessageEnd();
2868 }
2869
2870 public void getResult() throws IOError, IllegalArgument, org.apache.thrift.TException {
2871 if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
2872 throw new IllegalStateException("Method call not finished!");
2873 }
2874 org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
2875 org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
2876 (new Client(prot)).recv_mutateRowsTs();
2877 }
2878 }
2879
2880 public void atomicIncrement(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, long value, org.apache.thrift.async.AsyncMethodCallback<atomicIncrement_call> resultHandler) throws org.apache.thrift.TException {
2881 checkReady();
2882 atomicIncrement_call method_call = new atomicIncrement_call(tableName, row, column, value, resultHandler, this, ___protocolFactory, ___transport);
2883 this.___currentMethod = method_call;
2884 ___manager.call(method_call);
2885 }
2886
2887 public static class atomicIncrement_call extends org.apache.thrift.async.TAsyncMethodCall {
2888 private ByteBuffer tableName;
2889 private ByteBuffer row;
2890 private ByteBuffer column;
2891 private long value;
2892 public atomicIncrement_call(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, long value, org.apache.thrift.async.AsyncMethodCallback<atomicIncrement_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
2893 super(client, protocolFactory, transport, resultHandler, false);
2894 this.tableName = tableName;
2895 this.row = row;
2896 this.column = column;
2897 this.value = value;
2898 }
2899
2900 public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
2901 prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("atomicIncrement", org.apache.thrift.protocol.TMessageType.CALL, 0));
2902 atomicIncrement_args args = new atomicIncrement_args();
2903 args.setTableName(tableName);
2904 args.setRow(row);
2905 args.setColumn(column);
2906 args.setValue(value);
2907 args.write(prot);
2908 prot.writeMessageEnd();
2909 }
2910
2911 public long getResult() throws IOError, IllegalArgument, org.apache.thrift.TException {
2912 if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
2913 throw new IllegalStateException("Method call not finished!");
2914 }
2915 org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
2916 org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
2917 return (new Client(prot)).recv_atomicIncrement();
2918 }
2919 }
2920
2921 public void deleteAll(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<deleteAll_call> resultHandler) throws org.apache.thrift.TException {
2922 checkReady();
2923 deleteAll_call method_call = new deleteAll_call(tableName, row, column, attributes, resultHandler, this, ___protocolFactory, ___transport);
2924 this.___currentMethod = method_call;
2925 ___manager.call(method_call);
2926 }
2927
2928 public static class deleteAll_call extends org.apache.thrift.async.TAsyncMethodCall {
2929 private ByteBuffer tableName;
2930 private ByteBuffer row;
2931 private ByteBuffer column;
2932 private Map<ByteBuffer,ByteBuffer> attributes;
2933 public deleteAll_call(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<deleteAll_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
2934 super(client, protocolFactory, transport, resultHandler, false);
2935 this.tableName = tableName;
2936 this.row = row;
2937 this.column = column;
2938 this.attributes = attributes;
2939 }
2940
2941 public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
2942 prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("deleteAll", org.apache.thrift.protocol.TMessageType.CALL, 0));
2943 deleteAll_args args = new deleteAll_args();
2944 args.setTableName(tableName);
2945 args.setRow(row);
2946 args.setColumn(column);
2947 args.setAttributes(attributes);
2948 args.write(prot);
2949 prot.writeMessageEnd();
2950 }
2951
2952 public void getResult() throws IOError, org.apache.thrift.TException {
2953 if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
2954 throw new IllegalStateException("Method call not finished!");
2955 }
2956 org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
2957 org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
2958 (new Client(prot)).recv_deleteAll();
2959 }
2960 }
2961
2962 public void deleteAllTs(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, long timestamp, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<deleteAllTs_call> resultHandler) throws org.apache.thrift.TException {
2963 checkReady();
2964 deleteAllTs_call method_call = new deleteAllTs_call(tableName, row, column, timestamp, attributes, resultHandler, this, ___protocolFactory, ___transport);
2965 this.___currentMethod = method_call;
2966 ___manager.call(method_call);
2967 }
2968
2969 public static class deleteAllTs_call extends org.apache.thrift.async.TAsyncMethodCall {
2970 private ByteBuffer tableName;
2971 private ByteBuffer row;
2972 private ByteBuffer column;
2973 private long timestamp;
2974 private Map<ByteBuffer,ByteBuffer> attributes;
2975 public deleteAllTs_call(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, long timestamp, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<deleteAllTs_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
2976 super(client, protocolFactory, transport, resultHandler, false);
2977 this.tableName = tableName;
2978 this.row = row;
2979 this.column = column;
2980 this.timestamp = timestamp;
2981 this.attributes = attributes;
2982 }
2983
2984 public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
2985 prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("deleteAllTs", org.apache.thrift.protocol.TMessageType.CALL, 0));
2986 deleteAllTs_args args = new deleteAllTs_args();
2987 args.setTableName(tableName);
2988 args.setRow(row);
2989 args.setColumn(column);
2990 args.setTimestamp(timestamp);
2991 args.setAttributes(attributes);
2992 args.write(prot);
2993 prot.writeMessageEnd();
2994 }
2995
2996 public void getResult() throws IOError, org.apache.thrift.TException {
2997 if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
2998 throw new IllegalStateException("Method call not finished!");
2999 }
3000 org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
3001 org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
3002 (new Client(prot)).recv_deleteAllTs();
3003 }
3004 }
3005
3006 public void deleteAllRow(ByteBuffer tableName, ByteBuffer row, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<deleteAllRow_call> resultHandler) throws org.apache.thrift.TException {
3007 checkReady();
3008 deleteAllRow_call method_call = new deleteAllRow_call(tableName, row, attributes, resultHandler, this, ___protocolFactory, ___transport);
3009 this.___currentMethod = method_call;
3010 ___manager.call(method_call);
3011 }
3012
3013 public static class deleteAllRow_call extends org.apache.thrift.async.TAsyncMethodCall {
3014 private ByteBuffer tableName;
3015 private ByteBuffer row;
3016 private Map<ByteBuffer,ByteBuffer> attributes;
3017 public deleteAllRow_call(ByteBuffer tableName, ByteBuffer row, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<deleteAllRow_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
3018 super(client, protocolFactory, transport, resultHandler, false);
3019 this.tableName = tableName;
3020 this.row = row;
3021 this.attributes = attributes;
3022 }
3023
3024 public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
3025 prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("deleteAllRow", org.apache.thrift.protocol.TMessageType.CALL, 0));
3026 deleteAllRow_args args = new deleteAllRow_args();
3027 args.setTableName(tableName);
3028 args.setRow(row);
3029 args.setAttributes(attributes);
3030 args.write(prot);
3031 prot.writeMessageEnd();
3032 }
3033
3034 public void getResult() throws IOError, org.apache.thrift.TException {
3035 if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
3036 throw new IllegalStateException("Method call not finished!");
3037 }
3038 org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
3039 org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
3040 (new Client(prot)).recv_deleteAllRow();
3041 }
3042 }
3043
3044 public void increment(TIncrement increment, org.apache.thrift.async.AsyncMethodCallback<increment_call> resultHandler) throws org.apache.thrift.TException {
3045 checkReady();
3046 increment_call method_call = new increment_call(increment, resultHandler, this, ___protocolFactory, ___transport);
3047 this.___currentMethod = method_call;
3048 ___manager.call(method_call);
3049 }
3050
3051 public static class increment_call extends org.apache.thrift.async.TAsyncMethodCall {
3052 private TIncrement increment;
3053 public increment_call(TIncrement increment, org.apache.thrift.async.AsyncMethodCallback<increment_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
3054 super(client, protocolFactory, transport, resultHandler, false);
3055 this.increment = increment;
3056 }
3057
3058 public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
3059 prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("increment", org.apache.thrift.protocol.TMessageType.CALL, 0));
3060 increment_args args = new increment_args();
3061 args.setIncrement(increment);
3062 args.write(prot);
3063 prot.writeMessageEnd();
3064 }
3065
3066 public void getResult() throws IOError, org.apache.thrift.TException {
3067 if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
3068 throw new IllegalStateException("Method call not finished!");
3069 }
3070 org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
3071 org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
3072 (new Client(prot)).recv_increment();
3073 }
3074 }
3075
3076 public void incrementRows(List<TIncrement> increments, org.apache.thrift.async.AsyncMethodCallback<incrementRows_call> resultHandler) throws org.apache.thrift.TException {
3077 checkReady();
3078 incrementRows_call method_call = new incrementRows_call(increments, resultHandler, this, ___protocolFactory, ___transport);
3079 this.___currentMethod = method_call;
3080 ___manager.call(method_call);
3081 }
3082
3083 public static class incrementRows_call extends org.apache.thrift.async.TAsyncMethodCall {
3084 private List<TIncrement> increments;
3085 public incrementRows_call(List<TIncrement> increments, org.apache.thrift.async.AsyncMethodCallback<incrementRows_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
3086 super(client, protocolFactory, transport, resultHandler, false);
3087 this.increments = increments;
3088 }
3089
3090 public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
3091 prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("incrementRows", org.apache.thrift.protocol.TMessageType.CALL, 0));
3092 incrementRows_args args = new incrementRows_args();
3093 args.setIncrements(increments);
3094 args.write(prot);
3095 prot.writeMessageEnd();
3096 }
3097
3098 public void getResult() throws IOError, org.apache.thrift.TException {
3099 if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
3100 throw new IllegalStateException("Method call not finished!");
3101 }
3102 org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
3103 org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
3104 (new Client(prot)).recv_incrementRows();
3105 }
3106 }
3107
3108 public void deleteAllRowTs(ByteBuffer tableName, ByteBuffer row, long timestamp, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<deleteAllRowTs_call> resultHandler) throws org.apache.thrift.TException {
3109 checkReady();
3110 deleteAllRowTs_call method_call = new deleteAllRowTs_call(tableName, row, timestamp, attributes, resultHandler, this, ___protocolFactory, ___transport);
3111 this.___currentMethod = method_call;
3112 ___manager.call(method_call);
3113 }
3114
3115 public static class deleteAllRowTs_call extends org.apache.thrift.async.TAsyncMethodCall {
3116 private ByteBuffer tableName;
3117 private ByteBuffer row;
3118 private long timestamp;
3119 private Map<ByteBuffer,ByteBuffer> attributes;
3120 public deleteAllRowTs_call(ByteBuffer tableName, ByteBuffer row, long timestamp, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<deleteAllRowTs_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
3121 super(client, protocolFactory, transport, resultHandler, false);
3122 this.tableName = tableName;
3123 this.row = row;
3124 this.timestamp = timestamp;
3125 this.attributes = attributes;
3126 }
3127
3128 public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
3129 prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("deleteAllRowTs", org.apache.thrift.protocol.TMessageType.CALL, 0));
3130 deleteAllRowTs_args args = new deleteAllRowTs_args();
3131 args.setTableName(tableName);
3132 args.setRow(row);
3133 args.setTimestamp(timestamp);
3134 args.setAttributes(attributes);
3135 args.write(prot);
3136 prot.writeMessageEnd();
3137 }
3138
3139 public void getResult() throws IOError, org.apache.thrift.TException {
3140 if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
3141 throw new IllegalStateException("Method call not finished!");
3142 }
3143 org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
3144 org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
3145 (new Client(prot)).recv_deleteAllRowTs();
3146 }
3147 }
3148
3149 public void scannerOpenWithScan(ByteBuffer tableName, TScan scan, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<scannerOpenWithScan_call> resultHandler) throws org.apache.thrift.TException {
3150 checkReady();
3151 scannerOpenWithScan_call method_call = new scannerOpenWithScan_call(tableName, scan, attributes, resultHandler, this, ___protocolFactory, ___transport);
3152 this.___currentMethod = method_call;
3153 ___manager.call(method_call);
3154 }
3155
3156 public static class scannerOpenWithScan_call extends org.apache.thrift.async.TAsyncMethodCall {
3157 private ByteBuffer tableName;
3158 private TScan scan;
3159 private Map<ByteBuffer,ByteBuffer> attributes;
3160 public scannerOpenWithScan_call(ByteBuffer tableName, TScan scan, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<scannerOpenWithScan_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
3161 super(client, protocolFactory, transport, resultHandler, false);
3162 this.tableName = tableName;
3163 this.scan = scan;
3164 this.attributes = attributes;
3165 }
3166
3167 public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
3168 prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("scannerOpenWithScan", org.apache.thrift.protocol.TMessageType.CALL, 0));
3169 scannerOpenWithScan_args args = new scannerOpenWithScan_args();
3170 args.setTableName(tableName);
3171 args.setScan(scan);
3172 args.setAttributes(attributes);
3173 args.write(prot);
3174 prot.writeMessageEnd();
3175 }
3176
3177 public int getResult() throws IOError, org.apache.thrift.TException {
3178 if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
3179 throw new IllegalStateException("Method call not finished!");
3180 }
3181 org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
3182 org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
3183 return (new Client(prot)).recv_scannerOpenWithScan();
3184 }
3185 }
3186
3187 public void scannerOpen(ByteBuffer tableName, ByteBuffer startRow, List<ByteBuffer> columns, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<scannerOpen_call> resultHandler) throws org.apache.thrift.TException {
3188 checkReady();
3189 scannerOpen_call method_call = new scannerOpen_call(tableName, startRow, columns, attributes, resultHandler, this, ___protocolFactory, ___transport);
3190 this.___currentMethod = method_call;
3191 ___manager.call(method_call);
3192 }
3193
3194 public static class scannerOpen_call extends org.apache.thrift.async.TAsyncMethodCall {
3195 private ByteBuffer tableName;
3196 private ByteBuffer startRow;
3197 private List<ByteBuffer> columns;
3198 private Map<ByteBuffer,ByteBuffer> attributes;
3199 public scannerOpen_call(ByteBuffer tableName, ByteBuffer startRow, List<ByteBuffer> columns, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<scannerOpen_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
3200 super(client, protocolFactory, transport, resultHandler, false);
3201 this.tableName = tableName;
3202 this.startRow = startRow;
3203 this.columns = columns;
3204 this.attributes = attributes;
3205 }
3206
3207 public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
3208 prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("scannerOpen", org.apache.thrift.protocol.TMessageType.CALL, 0));
3209 scannerOpen_args args = new scannerOpen_args();
3210 args.setTableName(tableName);
3211 args.setStartRow(startRow);
3212 args.setColumns(columns);
3213 args.setAttributes(attributes);
3214 args.write(prot);
3215 prot.writeMessageEnd();
3216 }
3217
3218 public int getResult() throws IOError, org.apache.thrift.TException {
3219 if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
3220 throw new IllegalStateException("Method call not finished!");
3221 }
3222 org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
3223 org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
3224 return (new Client(prot)).recv_scannerOpen();
3225 }
3226 }
3227
3228 public void scannerOpenWithStop(ByteBuffer tableName, ByteBuffer startRow, ByteBuffer stopRow, List<ByteBuffer> columns, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<scannerOpenWithStop_call> resultHandler) throws org.apache.thrift.TException {
3229 checkReady();
3230 scannerOpenWithStop_call method_call = new scannerOpenWithStop_call(tableName, startRow, stopRow, columns, attributes, resultHandler, this, ___protocolFactory, ___transport);
3231 this.___currentMethod = method_call;
3232 ___manager.call(method_call);
3233 }
3234
3235 public static class scannerOpenWithStop_call extends org.apache.thrift.async.TAsyncMethodCall {
3236 private ByteBuffer tableName;
3237 private ByteBuffer startRow;
3238 private ByteBuffer stopRow;
3239 private List<ByteBuffer> columns;
3240 private Map<ByteBuffer,ByteBuffer> attributes;
3241 public scannerOpenWithStop_call(ByteBuffer tableName, ByteBuffer startRow, ByteBuffer stopRow, List<ByteBuffer> columns, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<scannerOpenWithStop_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
3242 super(client, protocolFactory, transport, resultHandler, false);
3243 this.tableName = tableName;
3244 this.startRow = startRow;
3245 this.stopRow = stopRow;
3246 this.columns = columns;
3247 this.attributes = attributes;
3248 }
3249
3250 public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
3251 prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("scannerOpenWithStop", org.apache.thrift.protocol.TMessageType.CALL, 0));
3252 scannerOpenWithStop_args args = new scannerOpenWithStop_args();
3253 args.setTableName(tableName);
3254 args.setStartRow(startRow);
3255 args.setStopRow(stopRow);
3256 args.setColumns(columns);
3257 args.setAttributes(attributes);
3258 args.write(prot);
3259 prot.writeMessageEnd();
3260 }
3261
3262 public int getResult() throws IOError, org.apache.thrift.TException {
3263 if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
3264 throw new IllegalStateException("Method call not finished!");
3265 }
3266 org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
3267 org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
3268 return (new Client(prot)).recv_scannerOpenWithStop();
3269 }
3270 }
3271
3272 public void scannerOpenWithPrefix(ByteBuffer tableName, ByteBuffer startAndPrefix, List<ByteBuffer> columns, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<scannerOpenWithPrefix_call> resultHandler) throws org.apache.thrift.TException {
3273 checkReady();
3274 scannerOpenWithPrefix_call method_call = new scannerOpenWithPrefix_call(tableName, startAndPrefix, columns, attributes, resultHandler, this, ___protocolFactory, ___transport);
3275 this.___currentMethod = method_call;
3276 ___manager.call(method_call);
3277 }
3278
3279 public static class scannerOpenWithPrefix_call extends org.apache.thrift.async.TAsyncMethodCall {
3280 private ByteBuffer tableName;
3281 private ByteBuffer startAndPrefix;
3282 private List<ByteBuffer> columns;
3283 private Map<ByteBuffer,ByteBuffer> attributes;
3284 public scannerOpenWithPrefix_call(ByteBuffer tableName, ByteBuffer startAndPrefix, List<ByteBuffer> columns, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<scannerOpenWithPrefix_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
3285 super(client, protocolFactory, transport, resultHandler, false);
3286 this.tableName = tableName;
3287 this.startAndPrefix = startAndPrefix;
3288 this.columns = columns;
3289 this.attributes = attributes;
3290 }
3291
3292 public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
3293 prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("scannerOpenWithPrefix", org.apache.thrift.protocol.TMessageType.CALL, 0));
3294 scannerOpenWithPrefix_args args = new scannerOpenWithPrefix_args();
3295 args.setTableName(tableName);
3296 args.setStartAndPrefix(startAndPrefix);
3297 args.setColumns(columns);
3298 args.setAttributes(attributes);
3299 args.write(prot);
3300 prot.writeMessageEnd();
3301 }
3302
3303 public int getResult() throws IOError, org.apache.thrift.TException {
3304 if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
3305 throw new IllegalStateException("Method call not finished!");
3306 }
3307 org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
3308 org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
3309 return (new Client(prot)).recv_scannerOpenWithPrefix();
3310 }
3311 }
3312
3313 public void scannerOpenTs(ByteBuffer tableName, ByteBuffer startRow, List<ByteBuffer> columns, long timestamp, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<scannerOpenTs_call> resultHandler) throws org.apache.thrift.TException {
3314 checkReady();
3315 scannerOpenTs_call method_call = new scannerOpenTs_call(tableName, startRow, columns, timestamp, attributes, resultHandler, this, ___protocolFactory, ___transport);
3316 this.___currentMethod = method_call;
3317 ___manager.call(method_call);
3318 }
3319
3320 public static class scannerOpenTs_call extends org.apache.thrift.async.TAsyncMethodCall {
3321 private ByteBuffer tableName;
3322 private ByteBuffer startRow;
3323 private List<ByteBuffer> columns;
3324 private long timestamp;
3325 private Map<ByteBuffer,ByteBuffer> attributes;
3326 public scannerOpenTs_call(ByteBuffer tableName, ByteBuffer startRow, List<ByteBuffer> columns, long timestamp, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<scannerOpenTs_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
3327 super(client, protocolFactory, transport, resultHandler, false);
3328 this.tableName = tableName;
3329 this.startRow = startRow;
3330 this.columns = columns;
3331 this.timestamp = timestamp;
3332 this.attributes = attributes;
3333 }
3334
3335 public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
3336 prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("scannerOpenTs", org.apache.thrift.protocol.TMessageType.CALL, 0));
3337 scannerOpenTs_args args = new scannerOpenTs_args();
3338 args.setTableName(tableName);
3339 args.setStartRow(startRow);
3340 args.setColumns(columns);
3341 args.setTimestamp(timestamp);
3342 args.setAttributes(attributes);
3343 args.write(prot);
3344 prot.writeMessageEnd();
3345 }
3346
3347 public int getResult() throws IOError, org.apache.thrift.TException {
3348 if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
3349 throw new IllegalStateException("Method call not finished!");
3350 }
3351 org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
3352 org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
3353 return (new Client(prot)).recv_scannerOpenTs();
3354 }
3355 }
3356
3357 public void scannerOpenWithStopTs(ByteBuffer tableName, ByteBuffer startRow, ByteBuffer stopRow, List<ByteBuffer> columns, long timestamp, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<scannerOpenWithStopTs_call> resultHandler) throws org.apache.thrift.TException {
3358 checkReady();
3359 scannerOpenWithStopTs_call method_call = new scannerOpenWithStopTs_call(tableName, startRow, stopRow, columns, timestamp, attributes, resultHandler, this, ___protocolFactory, ___transport);
3360 this.___currentMethod = method_call;
3361 ___manager.call(method_call);
3362 }
3363
3364 public static class scannerOpenWithStopTs_call extends org.apache.thrift.async.TAsyncMethodCall {
3365 private ByteBuffer tableName;
3366 private ByteBuffer startRow;
3367 private ByteBuffer stopRow;
3368 private List<ByteBuffer> columns;
3369 private long timestamp;
3370 private Map<ByteBuffer,ByteBuffer> attributes;
3371 public scannerOpenWithStopTs_call(ByteBuffer tableName, ByteBuffer startRow, ByteBuffer stopRow, List<ByteBuffer> columns, long timestamp, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<scannerOpenWithStopTs_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
3372 super(client, protocolFactory, transport, resultHandler, false);
3373 this.tableName = tableName;
3374 this.startRow = startRow;
3375 this.stopRow = stopRow;
3376 this.columns = columns;
3377 this.timestamp = timestamp;
3378 this.attributes = attributes;
3379 }
3380
3381 public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
3382 prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("scannerOpenWithStopTs", org.apache.thrift.protocol.TMessageType.CALL, 0));
3383 scannerOpenWithStopTs_args args = new scannerOpenWithStopTs_args();
3384 args.setTableName(tableName);
3385 args.setStartRow(startRow);
3386 args.setStopRow(stopRow);
3387 args.setColumns(columns);
3388 args.setTimestamp(timestamp);
3389 args.setAttributes(attributes);
3390 args.write(prot);
3391 prot.writeMessageEnd();
3392 }
3393
3394 public int getResult() throws IOError, org.apache.thrift.TException {
3395 if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
3396 throw new IllegalStateException("Method call not finished!");
3397 }
3398 org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
3399 org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
3400 return (new Client(prot)).recv_scannerOpenWithStopTs();
3401 }
3402 }
3403
3404 public void scannerGet(int id, org.apache.thrift.async.AsyncMethodCallback<scannerGet_call> resultHandler) throws org.apache.thrift.TException {
3405 checkReady();
3406 scannerGet_call method_call = new scannerGet_call(id, resultHandler, this, ___protocolFactory, ___transport);
3407 this.___currentMethod = method_call;
3408 ___manager.call(method_call);
3409 }
3410
3411 public static class scannerGet_call extends org.apache.thrift.async.TAsyncMethodCall {
3412 private int id;
3413 public scannerGet_call(int id, org.apache.thrift.async.AsyncMethodCallback<scannerGet_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
3414 super(client, protocolFactory, transport, resultHandler, false);
3415 this.id = id;
3416 }
3417
3418 public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
3419 prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("scannerGet", org.apache.thrift.protocol.TMessageType.CALL, 0));
3420 scannerGet_args args = new scannerGet_args();
3421 args.setId(id);
3422 args.write(prot);
3423 prot.writeMessageEnd();
3424 }
3425
3426 public List<TRowResult> getResult() throws IOError, IllegalArgument, org.apache.thrift.TException {
3427 if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
3428 throw new IllegalStateException("Method call not finished!");
3429 }
3430 org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
3431 org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
3432 return (new Client(prot)).recv_scannerGet();
3433 }
3434 }
3435
3436 public void scannerGetList(int id, int nbRows, org.apache.thrift.async.AsyncMethodCallback<scannerGetList_call> resultHandler) throws org.apache.thrift.TException {
3437 checkReady();
3438 scannerGetList_call method_call = new scannerGetList_call(id, nbRows, resultHandler, this, ___protocolFactory, ___transport);
3439 this.___currentMethod = method_call;
3440 ___manager.call(method_call);
3441 }
3442
3443 public static class scannerGetList_call extends org.apache.thrift.async.TAsyncMethodCall {
3444 private int id;
3445 private int nbRows;
3446 public scannerGetList_call(int id, int nbRows, org.apache.thrift.async.AsyncMethodCallback<scannerGetList_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
3447 super(client, protocolFactory, transport, resultHandler, false);
3448 this.id = id;
3449 this.nbRows = nbRows;
3450 }
3451
3452 public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
3453 prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("scannerGetList", org.apache.thrift.protocol.TMessageType.CALL, 0));
3454 scannerGetList_args args = new scannerGetList_args();
3455 args.setId(id);
3456 args.setNbRows(nbRows);
3457 args.write(prot);
3458 prot.writeMessageEnd();
3459 }
3460
3461 public List<TRowResult> getResult() throws IOError, IllegalArgument, org.apache.thrift.TException {
3462 if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
3463 throw new IllegalStateException("Method call not finished!");
3464 }
3465 org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
3466 org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
3467 return (new Client(prot)).recv_scannerGetList();
3468 }
3469 }
3470
3471 public void scannerClose(int id, org.apache.thrift.async.AsyncMethodCallback<scannerClose_call> resultHandler) throws org.apache.thrift.TException {
3472 checkReady();
3473 scannerClose_call method_call = new scannerClose_call(id, resultHandler, this, ___protocolFactory, ___transport);
3474 this.___currentMethod = method_call;
3475 ___manager.call(method_call);
3476 }
3477
3478 public static class scannerClose_call extends org.apache.thrift.async.TAsyncMethodCall {
3479 private int id;
3480 public scannerClose_call(int id, org.apache.thrift.async.AsyncMethodCallback<scannerClose_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
3481 super(client, protocolFactory, transport, resultHandler, false);
3482 this.id = id;
3483 }
3484
3485 public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
3486 prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("scannerClose", org.apache.thrift.protocol.TMessageType.CALL, 0));
3487 scannerClose_args args = new scannerClose_args();
3488 args.setId(id);
3489 args.write(prot);
3490 prot.writeMessageEnd();
3491 }
3492
3493 public void getResult() throws IOError, IllegalArgument, org.apache.thrift.TException {
3494 if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
3495 throw new IllegalStateException("Method call not finished!");
3496 }
3497 org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
3498 org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
3499 (new Client(prot)).recv_scannerClose();
3500 }
3501 }
3502
3503 public void getRowOrBefore(ByteBuffer tableName, ByteBuffer row, ByteBuffer family, org.apache.thrift.async.AsyncMethodCallback<getRowOrBefore_call> resultHandler) throws org.apache.thrift.TException {
3504 checkReady();
3505 getRowOrBefore_call method_call = new getRowOrBefore_call(tableName, row, family, resultHandler, this, ___protocolFactory, ___transport);
3506 this.___currentMethod = method_call;
3507 ___manager.call(method_call);
3508 }
3509
3510 public static class getRowOrBefore_call extends org.apache.thrift.async.TAsyncMethodCall {
3511 private ByteBuffer tableName;
3512 private ByteBuffer row;
3513 private ByteBuffer family;
3514 public getRowOrBefore_call(ByteBuffer tableName, ByteBuffer row, ByteBuffer family, org.apache.thrift.async.AsyncMethodCallback<getRowOrBefore_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
3515 super(client, protocolFactory, transport, resultHandler, false);
3516 this.tableName = tableName;
3517 this.row = row;
3518 this.family = family;
3519 }
3520
3521 public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
3522 prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getRowOrBefore", org.apache.thrift.protocol.TMessageType.CALL, 0));
3523 getRowOrBefore_args args = new getRowOrBefore_args();
3524 args.setTableName(tableName);
3525 args.setRow(row);
3526 args.setFamily(family);
3527 args.write(prot);
3528 prot.writeMessageEnd();
3529 }
3530
3531 public List<TCell> getResult() throws IOError, org.apache.thrift.TException {
3532 if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
3533 throw new IllegalStateException("Method call not finished!");
3534 }
3535 org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
3536 org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
3537 return (new Client(prot)).recv_getRowOrBefore();
3538 }
3539 }
3540
3541 public void getRegionInfo(ByteBuffer row, org.apache.thrift.async.AsyncMethodCallback<getRegionInfo_call> resultHandler) throws org.apache.thrift.TException {
3542 checkReady();
3543 getRegionInfo_call method_call = new getRegionInfo_call(row, resultHandler, this, ___protocolFactory, ___transport);
3544 this.___currentMethod = method_call;
3545 ___manager.call(method_call);
3546 }
3547
3548 public static class getRegionInfo_call extends org.apache.thrift.async.TAsyncMethodCall {
3549 private ByteBuffer row;
3550 public getRegionInfo_call(ByteBuffer row, org.apache.thrift.async.AsyncMethodCallback<getRegionInfo_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
3551 super(client, protocolFactory, transport, resultHandler, false);
3552 this.row = row;
3553 }
3554
3555 public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
3556 prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getRegionInfo", org.apache.thrift.protocol.TMessageType.CALL, 0));
3557 getRegionInfo_args args = new getRegionInfo_args();
3558 args.setRow(row);
3559 args.write(prot);
3560 prot.writeMessageEnd();
3561 }
3562
3563 public TRegionInfo getResult() throws IOError, org.apache.thrift.TException {
3564 if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
3565 throw new IllegalStateException("Method call not finished!");
3566 }
3567 org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
3568 org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
3569 return (new Client(prot)).recv_getRegionInfo();
3570 }
3571 }
3572
3573 }
3574
3575 public static class Processor<I extends Iface> extends org.apache.thrift.TBaseProcessor<I> implements org.apache.thrift.TProcessor {
3576 private static final Logger LOGGER = LoggerFactory.getLogger(Processor.class.getName());
3577 public Processor(I iface) {
3578 super(iface, getProcessMap(new HashMap<String, org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>>()));
3579 }
3580
3581 protected Processor(I iface, Map<String, org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>> processMap) {
3582 super(iface, getProcessMap(processMap));
3583 }
3584
3585 private static <I extends Iface> Map<String, org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>> getProcessMap(Map<String, org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>> processMap) {
3586 processMap.put("enableTable", new enableTable());
3587 processMap.put("disableTable", new disableTable());
3588 processMap.put("isTableEnabled", new isTableEnabled());
3589 processMap.put("compact", new compact());
3590 processMap.put("majorCompact", new majorCompact());
3591 processMap.put("getTableNames", new getTableNames());
3592 processMap.put("getColumnDescriptors", new getColumnDescriptors());
3593 processMap.put("getTableRegions", new getTableRegions());
3594 processMap.put("createTable", new createTable());
3595 processMap.put("deleteTable", new deleteTable());
3596 processMap.put("get", new get());
3597 processMap.put("getVer", new getVer());
3598 processMap.put("getVerTs", new getVerTs());
3599 processMap.put("getRow", new getRow());
3600 processMap.put("getRowWithColumns", new getRowWithColumns());
3601 processMap.put("getRowTs", new getRowTs());
3602 processMap.put("getRowWithColumnsTs", new getRowWithColumnsTs());
3603 processMap.put("getRows", new getRows());
3604 processMap.put("getRowsWithColumns", new getRowsWithColumns());
3605 processMap.put("getRowsTs", new getRowsTs());
3606 processMap.put("getRowsWithColumnsTs", new getRowsWithColumnsTs());
3607 processMap.put("mutateRow", new mutateRow());
3608 processMap.put("mutateRowTs", new mutateRowTs());
3609 processMap.put("mutateRows", new mutateRows());
3610 processMap.put("mutateRowsTs", new mutateRowsTs());
3611 processMap.put("atomicIncrement", new atomicIncrement());
3612 processMap.put("deleteAll", new deleteAll());
3613 processMap.put("deleteAllTs", new deleteAllTs());
3614 processMap.put("deleteAllRow", new deleteAllRow());
3615 processMap.put("increment", new increment());
3616 processMap.put("incrementRows", new incrementRows());
3617 processMap.put("deleteAllRowTs", new deleteAllRowTs());
3618 processMap.put("scannerOpenWithScan", new scannerOpenWithScan());
3619 processMap.put("scannerOpen", new scannerOpen());
3620 processMap.put("scannerOpenWithStop", new scannerOpenWithStop());
3621 processMap.put("scannerOpenWithPrefix", new scannerOpenWithPrefix());
3622 processMap.put("scannerOpenTs", new scannerOpenTs());
3623 processMap.put("scannerOpenWithStopTs", new scannerOpenWithStopTs());
3624 processMap.put("scannerGet", new scannerGet());
3625 processMap.put("scannerGetList", new scannerGetList());
3626 processMap.put("scannerClose", new scannerClose());
3627 processMap.put("getRowOrBefore", new getRowOrBefore());
3628 processMap.put("getRegionInfo", new getRegionInfo());
3629 return processMap;
3630 }
3631
3632 public static class enableTable<I extends Iface> extends org.apache.thrift.ProcessFunction<I, enableTable_args> {
3633 public enableTable() {
3634 super("enableTable");
3635 }
3636
3637 public enableTable_args getEmptyArgsInstance() {
3638 return new enableTable_args();
3639 }
3640
3641 protected boolean isOneway() {
3642 return false;
3643 }
3644
3645 public enableTable_result getResult(I iface, enableTable_args args) throws org.apache.thrift.TException {
3646 enableTable_result result = new enableTable_result();
3647 try {
3648 iface.enableTable(args.tableName);
3649 } catch (IOError io) {
3650 result.io = io;
3651 }
3652 return result;
3653 }
3654 }
3655
3656 public static class disableTable<I extends Iface> extends org.apache.thrift.ProcessFunction<I, disableTable_args> {
3657 public disableTable() {
3658 super("disableTable");
3659 }
3660
3661 public disableTable_args getEmptyArgsInstance() {
3662 return new disableTable_args();
3663 }
3664
3665 protected boolean isOneway() {
3666 return false;
3667 }
3668
3669 public disableTable_result getResult(I iface, disableTable_args args) throws org.apache.thrift.TException {
3670 disableTable_result result = new disableTable_result();
3671 try {
3672 iface.disableTable(args.tableName);
3673 } catch (IOError io) {
3674 result.io = io;
3675 }
3676 return result;
3677 }
3678 }
3679
3680 public static class isTableEnabled<I extends Iface> extends org.apache.thrift.ProcessFunction<I, isTableEnabled_args> {
3681 public isTableEnabled() {
3682 super("isTableEnabled");
3683 }
3684
3685 public isTableEnabled_args getEmptyArgsInstance() {
3686 return new isTableEnabled_args();
3687 }
3688
3689 protected boolean isOneway() {
3690 return false;
3691 }
3692
3693 public isTableEnabled_result getResult(I iface, isTableEnabled_args args) throws org.apache.thrift.TException {
3694 isTableEnabled_result result = new isTableEnabled_result();
3695 try {
3696 result.success = iface.isTableEnabled(args.tableName);
3697 result.setSuccessIsSet(true);
3698 } catch (IOError io) {
3699 result.io = io;
3700 }
3701 return result;
3702 }
3703 }
3704
3705 public static class compact<I extends Iface> extends org.apache.thrift.ProcessFunction<I, compact_args> {
3706 public compact() {
3707 super("compact");
3708 }
3709
3710 public compact_args getEmptyArgsInstance() {
3711 return new compact_args();
3712 }
3713
3714 protected boolean isOneway() {
3715 return false;
3716 }
3717
3718 public compact_result getResult(I iface, compact_args args) throws org.apache.thrift.TException {
3719 compact_result result = new compact_result();
3720 try {
3721 iface.compact(args.tableNameOrRegionName);
3722 } catch (IOError io) {
3723 result.io = io;
3724 }
3725 return result;
3726 }
3727 }
3728
3729 public static class majorCompact<I extends Iface> extends org.apache.thrift.ProcessFunction<I, majorCompact_args> {
3730 public majorCompact() {
3731 super("majorCompact");
3732 }
3733
3734 public majorCompact_args getEmptyArgsInstance() {
3735 return new majorCompact_args();
3736 }
3737
3738 protected boolean isOneway() {
3739 return false;
3740 }
3741
3742 public majorCompact_result getResult(I iface, majorCompact_args args) throws org.apache.thrift.TException {
3743 majorCompact_result result = new majorCompact_result();
3744 try {
3745 iface.majorCompact(args.tableNameOrRegionName);
3746 } catch (IOError io) {
3747 result.io = io;
3748 }
3749 return result;
3750 }
3751 }
3752
3753 public static class getTableNames<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getTableNames_args> {
3754 public getTableNames() {
3755 super("getTableNames");
3756 }
3757
3758 public getTableNames_args getEmptyArgsInstance() {
3759 return new getTableNames_args();
3760 }
3761
3762 protected boolean isOneway() {
3763 return false;
3764 }
3765
3766 public getTableNames_result getResult(I iface, getTableNames_args args) throws org.apache.thrift.TException {
3767 getTableNames_result result = new getTableNames_result();
3768 try {
3769 result.success = iface.getTableNames();
3770 } catch (IOError io) {
3771 result.io = io;
3772 }
3773 return result;
3774 }
3775 }
3776
3777 public static class getColumnDescriptors<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getColumnDescriptors_args> {
3778 public getColumnDescriptors() {
3779 super("getColumnDescriptors");
3780 }
3781
3782 public getColumnDescriptors_args getEmptyArgsInstance() {
3783 return new getColumnDescriptors_args();
3784 }
3785
3786 protected boolean isOneway() {
3787 return false;
3788 }
3789
3790 public getColumnDescriptors_result getResult(I iface, getColumnDescriptors_args args) throws org.apache.thrift.TException {
3791 getColumnDescriptors_result result = new getColumnDescriptors_result();
3792 try {
3793 result.success = iface.getColumnDescriptors(args.tableName);
3794 } catch (IOError io) {
3795 result.io = io;
3796 }
3797 return result;
3798 }
3799 }
3800
3801 public static class getTableRegions<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getTableRegions_args> {
3802 public getTableRegions() {
3803 super("getTableRegions");
3804 }
3805
3806 public getTableRegions_args getEmptyArgsInstance() {
3807 return new getTableRegions_args();
3808 }
3809
3810 protected boolean isOneway() {
3811 return false;
3812 }
3813
3814 public getTableRegions_result getResult(I iface, getTableRegions_args args) throws org.apache.thrift.TException {
3815 getTableRegions_result result = new getTableRegions_result();
3816 try {
3817 result.success = iface.getTableRegions(args.tableName);
3818 } catch (IOError io) {
3819 result.io = io;
3820 }
3821 return result;
3822 }
3823 }
3824
3825 public static class createTable<I extends Iface> extends org.apache.thrift.ProcessFunction<I, createTable_args> {
3826 public createTable() {
3827 super("createTable");
3828 }
3829
3830 public createTable_args getEmptyArgsInstance() {
3831 return new createTable_args();
3832 }
3833
3834 protected boolean isOneway() {
3835 return false;
3836 }
3837
3838 public createTable_result getResult(I iface, createTable_args args) throws org.apache.thrift.TException {
3839 createTable_result result = new createTable_result();
3840 try {
3841 iface.createTable(args.tableName, args.columnFamilies);
3842 } catch (IOError io) {
3843 result.io = io;
3844 } catch (IllegalArgument ia) {
3845 result.ia = ia;
3846 } catch (AlreadyExists exist) {
3847 result.exist = exist;
3848 }
3849 return result;
3850 }
3851 }
3852
3853 public static class deleteTable<I extends Iface> extends org.apache.thrift.ProcessFunction<I, deleteTable_args> {
3854 public deleteTable() {
3855 super("deleteTable");
3856 }
3857
3858 public deleteTable_args getEmptyArgsInstance() {
3859 return new deleteTable_args();
3860 }
3861
3862 protected boolean isOneway() {
3863 return false;
3864 }
3865
3866 public deleteTable_result getResult(I iface, deleteTable_args args) throws org.apache.thrift.TException {
3867 deleteTable_result result = new deleteTable_result();
3868 try {
3869 iface.deleteTable(args.tableName);
3870 } catch (IOError io) {
3871 result.io = io;
3872 }
3873 return result;
3874 }
3875 }
3876
3877 public static class get<I extends Iface> extends org.apache.thrift.ProcessFunction<I, get_args> {
3878 public get() {
3879 super("get");
3880 }
3881
3882 public get_args getEmptyArgsInstance() {
3883 return new get_args();
3884 }
3885
3886 protected boolean isOneway() {
3887 return false;
3888 }
3889
3890 public get_result getResult(I iface, get_args args) throws org.apache.thrift.TException {
3891 get_result result = new get_result();
3892 try {
3893 result.success = iface.get(args.tableName, args.row, args.column, args.attributes);
3894 } catch (IOError io) {
3895 result.io = io;
3896 }
3897 return result;
3898 }
3899 }
3900
3901 public static class getVer<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getVer_args> {
3902 public getVer() {
3903 super("getVer");
3904 }
3905
3906 public getVer_args getEmptyArgsInstance() {
3907 return new getVer_args();
3908 }
3909
3910 protected boolean isOneway() {
3911 return false;
3912 }
3913
3914 public getVer_result getResult(I iface, getVer_args args) throws org.apache.thrift.TException {
3915 getVer_result result = new getVer_result();
3916 try {
3917 result.success = iface.getVer(args.tableName, args.row, args.column, args.numVersions, args.attributes);
3918 } catch (IOError io) {
3919 result.io = io;
3920 }
3921 return result;
3922 }
3923 }
3924
3925 public static class getVerTs<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getVerTs_args> {
3926 public getVerTs() {
3927 super("getVerTs");
3928 }
3929
3930 public getVerTs_args getEmptyArgsInstance() {
3931 return new getVerTs_args();
3932 }
3933
3934 protected boolean isOneway() {
3935 return false;
3936 }
3937
3938 public getVerTs_result getResult(I iface, getVerTs_args args) throws org.apache.thrift.TException {
3939 getVerTs_result result = new getVerTs_result();
3940 try {
3941 result.success = iface.getVerTs(args.tableName, args.row, args.column, args.timestamp, args.numVersions, args.attributes);
3942 } catch (IOError io) {
3943 result.io = io;
3944 }
3945 return result;
3946 }
3947 }
3948
3949 public static class getRow<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getRow_args> {
3950 public getRow() {
3951 super("getRow");
3952 }
3953
3954 public getRow_args getEmptyArgsInstance() {
3955 return new getRow_args();
3956 }
3957
3958 protected boolean isOneway() {
3959 return false;
3960 }
3961
3962 public getRow_result getResult(I iface, getRow_args args) throws org.apache.thrift.TException {
3963 getRow_result result = new getRow_result();
3964 try {
3965 result.success = iface.getRow(args.tableName, args.row, args.attributes);
3966 } catch (IOError io) {
3967 result.io = io;
3968 }
3969 return result;
3970 }
3971 }
3972
3973 public static class getRowWithColumns<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getRowWithColumns_args> {
3974 public getRowWithColumns() {
3975 super("getRowWithColumns");
3976 }
3977
3978 public getRowWithColumns_args getEmptyArgsInstance() {
3979 return new getRowWithColumns_args();
3980 }
3981
3982 protected boolean isOneway() {
3983 return false;
3984 }
3985
3986 public getRowWithColumns_result getResult(I iface, getRowWithColumns_args args) throws org.apache.thrift.TException {
3987 getRowWithColumns_result result = new getRowWithColumns_result();
3988 try {
3989 result.success = iface.getRowWithColumns(args.tableName, args.row, args.columns, args.attributes);
3990 } catch (IOError io) {
3991 result.io = io;
3992 }
3993 return result;
3994 }
3995 }
3996
3997 public static class getRowTs<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getRowTs_args> {
3998 public getRowTs() {
3999 super("getRowTs");
4000 }
4001
4002 public getRowTs_args getEmptyArgsInstance() {
4003 return new getRowTs_args();
4004 }
4005
4006 protected boolean isOneway() {
4007 return false;
4008 }
4009
4010 public getRowTs_result getResult(I iface, getRowTs_args args) throws org.apache.thrift.TException {
4011 getRowTs_result result = new getRowTs_result();
4012 try {
4013 result.success = iface.getRowTs(args.tableName, args.row, args.timestamp, args.attributes);
4014 } catch (IOError io) {
4015 result.io = io;
4016 }
4017 return result;
4018 }
4019 }
4020
4021 public static class getRowWithColumnsTs<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getRowWithColumnsTs_args> {
4022 public getRowWithColumnsTs() {
4023 super("getRowWithColumnsTs");
4024 }
4025
4026 public getRowWithColumnsTs_args getEmptyArgsInstance() {
4027 return new getRowWithColumnsTs_args();
4028 }
4029
4030 protected boolean isOneway() {
4031 return false;
4032 }
4033
4034 public getRowWithColumnsTs_result getResult(I iface, getRowWithColumnsTs_args args) throws org.apache.thrift.TException {
4035 getRowWithColumnsTs_result result = new getRowWithColumnsTs_result();
4036 try {
4037 result.success = iface.getRowWithColumnsTs(args.tableName, args.row, args.columns, args.timestamp, args.attributes);
4038 } catch (IOError io) {
4039 result.io = io;
4040 }
4041 return result;
4042 }
4043 }
4044
4045 public static class getRows<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getRows_args> {
4046 public getRows() {
4047 super("getRows");
4048 }
4049
4050 public getRows_args getEmptyArgsInstance() {
4051 return new getRows_args();
4052 }
4053
4054 protected boolean isOneway() {
4055 return false;
4056 }
4057
4058 public getRows_result getResult(I iface, getRows_args args) throws org.apache.thrift.TException {
4059 getRows_result result = new getRows_result();
4060 try {
4061 result.success = iface.getRows(args.tableName, args.rows, args.attributes);
4062 } catch (IOError io) {
4063 result.io = io;
4064 }
4065 return result;
4066 }
4067 }
4068
4069 public static class getRowsWithColumns<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getRowsWithColumns_args> {
4070 public getRowsWithColumns() {
4071 super("getRowsWithColumns");
4072 }
4073
4074 public getRowsWithColumns_args getEmptyArgsInstance() {
4075 return new getRowsWithColumns_args();
4076 }
4077
4078 protected boolean isOneway() {
4079 return false;
4080 }
4081
4082 public getRowsWithColumns_result getResult(I iface, getRowsWithColumns_args args) throws org.apache.thrift.TException {
4083 getRowsWithColumns_result result = new getRowsWithColumns_result();
4084 try {
4085 result.success = iface.getRowsWithColumns(args.tableName, args.rows, args.columns, args.attributes);
4086 } catch (IOError io) {
4087 result.io = io;
4088 }
4089 return result;
4090 }
4091 }
4092
4093 public static class getRowsTs<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getRowsTs_args> {
4094 public getRowsTs() {
4095 super("getRowsTs");
4096 }
4097
4098 public getRowsTs_args getEmptyArgsInstance() {
4099 return new getRowsTs_args();
4100 }
4101
4102 protected boolean isOneway() {
4103 return false;
4104 }
4105
4106 public getRowsTs_result getResult(I iface, getRowsTs_args args) throws org.apache.thrift.TException {
4107 getRowsTs_result result = new getRowsTs_result();
4108 try {
4109 result.success = iface.getRowsTs(args.tableName, args.rows, args.timestamp, args.attributes);
4110 } catch (IOError io) {
4111 result.io = io;
4112 }
4113 return result;
4114 }
4115 }
4116
4117 public static class getRowsWithColumnsTs<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getRowsWithColumnsTs_args> {
4118 public getRowsWithColumnsTs() {
4119 super("getRowsWithColumnsTs");
4120 }
4121
4122 public getRowsWithColumnsTs_args getEmptyArgsInstance() {
4123 return new getRowsWithColumnsTs_args();
4124 }
4125
4126 protected boolean isOneway() {
4127 return false;
4128 }
4129
4130 public getRowsWithColumnsTs_result getResult(I iface, getRowsWithColumnsTs_args args) throws org.apache.thrift.TException {
4131 getRowsWithColumnsTs_result result = new getRowsWithColumnsTs_result();
4132 try {
4133 result.success = iface.getRowsWithColumnsTs(args.tableName, args.rows, args.columns, args.timestamp, args.attributes);
4134 } catch (IOError io) {
4135 result.io = io;
4136 }
4137 return result;
4138 }
4139 }
4140
4141 public static class mutateRow<I extends Iface> extends org.apache.thrift.ProcessFunction<I, mutateRow_args> {
4142 public mutateRow() {
4143 super("mutateRow");
4144 }
4145
4146 public mutateRow_args getEmptyArgsInstance() {
4147 return new mutateRow_args();
4148 }
4149
4150 protected boolean isOneway() {
4151 return false;
4152 }
4153
4154 public mutateRow_result getResult(I iface, mutateRow_args args) throws org.apache.thrift.TException {
4155 mutateRow_result result = new mutateRow_result();
4156 try {
4157 iface.mutateRow(args.tableName, args.row, args.mutations, args.attributes);
4158 } catch (IOError io) {
4159 result.io = io;
4160 } catch (IllegalArgument ia) {
4161 result.ia = ia;
4162 }
4163 return result;
4164 }
4165 }
4166
4167 public static class mutateRowTs<I extends Iface> extends org.apache.thrift.ProcessFunction<I, mutateRowTs_args> {
4168 public mutateRowTs() {
4169 super("mutateRowTs");
4170 }
4171
4172 public mutateRowTs_args getEmptyArgsInstance() {
4173 return new mutateRowTs_args();
4174 }
4175
4176 protected boolean isOneway() {
4177 return false;
4178 }
4179
4180 public mutateRowTs_result getResult(I iface, mutateRowTs_args args) throws org.apache.thrift.TException {
4181 mutateRowTs_result result = new mutateRowTs_result();
4182 try {
4183 iface.mutateRowTs(args.tableName, args.row, args.mutations, args.timestamp, args.attributes);
4184 } catch (IOError io) {
4185 result.io = io;
4186 } catch (IllegalArgument ia) {
4187 result.ia = ia;
4188 }
4189 return result;
4190 }
4191 }
4192
4193 public static class mutateRows<I extends Iface> extends org.apache.thrift.ProcessFunction<I, mutateRows_args> {
4194 public mutateRows() {
4195 super("mutateRows");
4196 }
4197
4198 public mutateRows_args getEmptyArgsInstance() {
4199 return new mutateRows_args();
4200 }
4201
4202 protected boolean isOneway() {
4203 return false;
4204 }
4205
4206 public mutateRows_result getResult(I iface, mutateRows_args args) throws org.apache.thrift.TException {
4207 mutateRows_result result = new mutateRows_result();
4208 try {
4209 iface.mutateRows(args.tableName, args.rowBatches, args.attributes);
4210 } catch (IOError io) {
4211 result.io = io;
4212 } catch (IllegalArgument ia) {
4213 result.ia = ia;
4214 }
4215 return result;
4216 }
4217 }
4218
4219 public static class mutateRowsTs<I extends Iface> extends org.apache.thrift.ProcessFunction<I, mutateRowsTs_args> {
4220 public mutateRowsTs() {
4221 super("mutateRowsTs");
4222 }
4223
4224 public mutateRowsTs_args getEmptyArgsInstance() {
4225 return new mutateRowsTs_args();
4226 }
4227
4228 protected boolean isOneway() {
4229 return false;
4230 }
4231
4232 public mutateRowsTs_result getResult(I iface, mutateRowsTs_args args) throws org.apache.thrift.TException {
4233 mutateRowsTs_result result = new mutateRowsTs_result();
4234 try {
4235 iface.mutateRowsTs(args.tableName, args.rowBatches, args.timestamp, args.attributes);
4236 } catch (IOError io) {
4237 result.io = io;
4238 } catch (IllegalArgument ia) {
4239 result.ia = ia;
4240 }
4241 return result;
4242 }
4243 }
4244
4245 public static class atomicIncrement<I extends Iface> extends org.apache.thrift.ProcessFunction<I, atomicIncrement_args> {
4246 public atomicIncrement() {
4247 super("atomicIncrement");
4248 }
4249
4250 public atomicIncrement_args getEmptyArgsInstance() {
4251 return new atomicIncrement_args();
4252 }
4253
4254 protected boolean isOneway() {
4255 return false;
4256 }
4257
4258 public atomicIncrement_result getResult(I iface, atomicIncrement_args args) throws org.apache.thrift.TException {
4259 atomicIncrement_result result = new atomicIncrement_result();
4260 try {
4261 result.success = iface.atomicIncrement(args.tableName, args.row, args.column, args.value);
4262 result.setSuccessIsSet(true);
4263 } catch (IOError io) {
4264 result.io = io;
4265 } catch (IllegalArgument ia) {
4266 result.ia = ia;
4267 }
4268 return result;
4269 }
4270 }
4271
4272 public static class deleteAll<I extends Iface> extends org.apache.thrift.ProcessFunction<I, deleteAll_args> {
4273 public deleteAll() {
4274 super("deleteAll");
4275 }
4276
4277 public deleteAll_args getEmptyArgsInstance() {
4278 return new deleteAll_args();
4279 }
4280
4281 protected boolean isOneway() {
4282 return false;
4283 }
4284
4285 public deleteAll_result getResult(I iface, deleteAll_args args) throws org.apache.thrift.TException {
4286 deleteAll_result result = new deleteAll_result();
4287 try {
4288 iface.deleteAll(args.tableName, args.row, args.column, args.attributes);
4289 } catch (IOError io) {
4290 result.io = io;
4291 }
4292 return result;
4293 }
4294 }
4295
4296 public static class deleteAllTs<I extends Iface> extends org.apache.thrift.ProcessFunction<I, deleteAllTs_args> {
4297 public deleteAllTs() {
4298 super("deleteAllTs");
4299 }
4300
4301 public deleteAllTs_args getEmptyArgsInstance() {
4302 return new deleteAllTs_args();
4303 }
4304
4305 protected boolean isOneway() {
4306 return false;
4307 }
4308
4309 public deleteAllTs_result getResult(I iface, deleteAllTs_args args) throws org.apache.thrift.TException {
4310 deleteAllTs_result result = new deleteAllTs_result();
4311 try {
4312 iface.deleteAllTs(args.tableName, args.row, args.column, args.timestamp, args.attributes);
4313 } catch (IOError io) {
4314 result.io = io;
4315 }
4316 return result;
4317 }
4318 }
4319
4320 public static class deleteAllRow<I extends Iface> extends org.apache.thrift.ProcessFunction<I, deleteAllRow_args> {
4321 public deleteAllRow() {
4322 super("deleteAllRow");
4323 }
4324
4325 public deleteAllRow_args getEmptyArgsInstance() {
4326 return new deleteAllRow_args();
4327 }
4328
4329 protected boolean isOneway() {
4330 return false;
4331 }
4332
4333 public deleteAllRow_result getResult(I iface, deleteAllRow_args args) throws org.apache.thrift.TException {
4334 deleteAllRow_result result = new deleteAllRow_result();
4335 try {
4336 iface.deleteAllRow(args.tableName, args.row, args.attributes);
4337 } catch (IOError io) {
4338 result.io = io;
4339 }
4340 return result;
4341 }
4342 }
4343
4344 public static class increment<I extends Iface> extends org.apache.thrift.ProcessFunction<I, increment_args> {
4345 public increment() {
4346 super("increment");
4347 }
4348
4349 public increment_args getEmptyArgsInstance() {
4350 return new increment_args();
4351 }
4352
4353 protected boolean isOneway() {
4354 return false;
4355 }
4356
4357 public increment_result getResult(I iface, increment_args args) throws org.apache.thrift.TException {
4358 increment_result result = new increment_result();
4359 try {
4360 iface.increment(args.increment);
4361 } catch (IOError io) {
4362 result.io = io;
4363 }
4364 return result;
4365 }
4366 }
4367
4368 public static class incrementRows<I extends Iface> extends org.apache.thrift.ProcessFunction<I, incrementRows_args> {
4369 public incrementRows() {
4370 super("incrementRows");
4371 }
4372
4373 public incrementRows_args getEmptyArgsInstance() {
4374 return new incrementRows_args();
4375 }
4376
4377 protected boolean isOneway() {
4378 return false;
4379 }
4380
4381 public incrementRows_result getResult(I iface, incrementRows_args args) throws org.apache.thrift.TException {
4382 incrementRows_result result = new incrementRows_result();
4383 try {
4384 iface.incrementRows(args.increments);
4385 } catch (IOError io) {
4386 result.io = io;
4387 }
4388 return result;
4389 }
4390 }
4391
4392 public static class deleteAllRowTs<I extends Iface> extends org.apache.thrift.ProcessFunction<I, deleteAllRowTs_args> {
4393 public deleteAllRowTs() {
4394 super("deleteAllRowTs");
4395 }
4396
4397 public deleteAllRowTs_args getEmptyArgsInstance() {
4398 return new deleteAllRowTs_args();
4399 }
4400
4401 protected boolean isOneway() {
4402 return false;
4403 }
4404
4405 public deleteAllRowTs_result getResult(I iface, deleteAllRowTs_args args) throws org.apache.thrift.TException {
4406 deleteAllRowTs_result result = new deleteAllRowTs_result();
4407 try {
4408 iface.deleteAllRowTs(args.tableName, args.row, args.timestamp, args.attributes);
4409 } catch (IOError io) {
4410 result.io = io;
4411 }
4412 return result;
4413 }
4414 }
4415
4416 public static class scannerOpenWithScan<I extends Iface> extends org.apache.thrift.ProcessFunction<I, scannerOpenWithScan_args> {
4417 public scannerOpenWithScan() {
4418 super("scannerOpenWithScan");
4419 }
4420
4421 public scannerOpenWithScan_args getEmptyArgsInstance() {
4422 return new scannerOpenWithScan_args();
4423 }
4424
4425 protected boolean isOneway() {
4426 return false;
4427 }
4428
4429 public scannerOpenWithScan_result getResult(I iface, scannerOpenWithScan_args args) throws org.apache.thrift.TException {
4430 scannerOpenWithScan_result result = new scannerOpenWithScan_result();
4431 try {
4432 result.success = iface.scannerOpenWithScan(args.tableName, args.scan, args.attributes);
4433 result.setSuccessIsSet(true);
4434 } catch (IOError io) {
4435 result.io = io;
4436 }
4437 return result;
4438 }
4439 }
4440
4441 public static class scannerOpen<I extends Iface> extends org.apache.thrift.ProcessFunction<I, scannerOpen_args> {
4442 public scannerOpen() {
4443 super("scannerOpen");
4444 }
4445
4446 public scannerOpen_args getEmptyArgsInstance() {
4447 return new scannerOpen_args();
4448 }
4449
4450 protected boolean isOneway() {
4451 return false;
4452 }
4453
4454 public scannerOpen_result getResult(I iface, scannerOpen_args args) throws org.apache.thrift.TException {
4455 scannerOpen_result result = new scannerOpen_result();
4456 try {
4457 result.success = iface.scannerOpen(args.tableName, args.startRow, args.columns, args.attributes);
4458 result.setSuccessIsSet(true);
4459 } catch (IOError io) {
4460 result.io = io;
4461 }
4462 return result;
4463 }
4464 }
4465
4466 public static class scannerOpenWithStop<I extends Iface> extends org.apache.thrift.ProcessFunction<I, scannerOpenWithStop_args> {
4467 public scannerOpenWithStop() {
4468 super("scannerOpenWithStop");
4469 }
4470
4471 public scannerOpenWithStop_args getEmptyArgsInstance() {
4472 return new scannerOpenWithStop_args();
4473 }
4474
4475 protected boolean isOneway() {
4476 return false;
4477 }
4478
4479 public scannerOpenWithStop_result getResult(I iface, scannerOpenWithStop_args args) throws org.apache.thrift.TException {
4480 scannerOpenWithStop_result result = new scannerOpenWithStop_result();
4481 try {
4482 result.success = iface.scannerOpenWithStop(args.tableName, args.startRow, args.stopRow, args.columns, args.attributes);
4483 result.setSuccessIsSet(true);
4484 } catch (IOError io) {
4485 result.io = io;
4486 }
4487 return result;
4488 }
4489 }
4490
4491 public static class scannerOpenWithPrefix<I extends Iface> extends org.apache.thrift.ProcessFunction<I, scannerOpenWithPrefix_args> {
4492 public scannerOpenWithPrefix() {
4493 super("scannerOpenWithPrefix");
4494 }
4495
4496 public scannerOpenWithPrefix_args getEmptyArgsInstance() {
4497 return new scannerOpenWithPrefix_args();
4498 }
4499
4500 protected boolean isOneway() {
4501 return false;
4502 }
4503
4504 public scannerOpenWithPrefix_result getResult(I iface, scannerOpenWithPrefix_args args) throws org.apache.thrift.TException {
4505 scannerOpenWithPrefix_result result = new scannerOpenWithPrefix_result();
4506 try {
4507 result.success = iface.scannerOpenWithPrefix(args.tableName, args.startAndPrefix, args.columns, args.attributes);
4508 result.setSuccessIsSet(true);
4509 } catch (IOError io) {
4510 result.io = io;
4511 }
4512 return result;
4513 }
4514 }
4515
4516 public static class scannerOpenTs<I extends Iface> extends org.apache.thrift.ProcessFunction<I, scannerOpenTs_args> {
4517 public scannerOpenTs() {
4518 super("scannerOpenTs");
4519 }
4520
4521 public scannerOpenTs_args getEmptyArgsInstance() {
4522 return new scannerOpenTs_args();
4523 }
4524
4525 protected boolean isOneway() {
4526 return false;
4527 }
4528
4529 public scannerOpenTs_result getResult(I iface, scannerOpenTs_args args) throws org.apache.thrift.TException {
4530 scannerOpenTs_result result = new scannerOpenTs_result();
4531 try {
4532 result.success = iface.scannerOpenTs(args.tableName, args.startRow, args.columns, args.timestamp, args.attributes);
4533 result.setSuccessIsSet(true);
4534 } catch (IOError io) {
4535 result.io = io;
4536 }
4537 return result;
4538 }
4539 }
4540
4541 public static class scannerOpenWithStopTs<I extends Iface> extends org.apache.thrift.ProcessFunction<I, scannerOpenWithStopTs_args> {
4542 public scannerOpenWithStopTs() {
4543 super("scannerOpenWithStopTs");
4544 }
4545
4546 public scannerOpenWithStopTs_args getEmptyArgsInstance() {
4547 return new scannerOpenWithStopTs_args();
4548 }
4549
4550 protected boolean isOneway() {
4551 return false;
4552 }
4553
4554 public scannerOpenWithStopTs_result getResult(I iface, scannerOpenWithStopTs_args args) throws org.apache.thrift.TException {
4555 scannerOpenWithStopTs_result result = new scannerOpenWithStopTs_result();
4556 try {
4557 result.success = iface.scannerOpenWithStopTs(args.tableName, args.startRow, args.stopRow, args.columns, args.timestamp, args.attributes);
4558 result.setSuccessIsSet(true);
4559 } catch (IOError io) {
4560 result.io = io;
4561 }
4562 return result;
4563 }
4564 }
4565
4566 public static class scannerGet<I extends Iface> extends org.apache.thrift.ProcessFunction<I, scannerGet_args> {
4567 public scannerGet() {
4568 super("scannerGet");
4569 }
4570
4571 public scannerGet_args getEmptyArgsInstance() {
4572 return new scannerGet_args();
4573 }
4574
4575 protected boolean isOneway() {
4576 return false;
4577 }
4578
4579 public scannerGet_result getResult(I iface, scannerGet_args args) throws org.apache.thrift.TException {
4580 scannerGet_result result = new scannerGet_result();
4581 try {
4582 result.success = iface.scannerGet(args.id);
4583 } catch (IOError io) {
4584 result.io = io;
4585 } catch (IllegalArgument ia) {
4586 result.ia = ia;
4587 }
4588 return result;
4589 }
4590 }
4591
4592 public static class scannerGetList<I extends Iface> extends org.apache.thrift.ProcessFunction<I, scannerGetList_args> {
4593 public scannerGetList() {
4594 super("scannerGetList");
4595 }
4596
4597 public scannerGetList_args getEmptyArgsInstance() {
4598 return new scannerGetList_args();
4599 }
4600
4601 protected boolean isOneway() {
4602 return false;
4603 }
4604
4605 public scannerGetList_result getResult(I iface, scannerGetList_args args) throws org.apache.thrift.TException {
4606 scannerGetList_result result = new scannerGetList_result();
4607 try {
4608 result.success = iface.scannerGetList(args.id, args.nbRows);
4609 } catch (IOError io) {
4610 result.io = io;
4611 } catch (IllegalArgument ia) {
4612 result.ia = ia;
4613 }
4614 return result;
4615 }
4616 }
4617
4618 public static class scannerClose<I extends Iface> extends org.apache.thrift.ProcessFunction<I, scannerClose_args> {
4619 public scannerClose() {
4620 super("scannerClose");
4621 }
4622
4623 public scannerClose_args getEmptyArgsInstance() {
4624 return new scannerClose_args();
4625 }
4626
4627 protected boolean isOneway() {
4628 return false;
4629 }
4630
4631 public scannerClose_result getResult(I iface, scannerClose_args args) throws org.apache.thrift.TException {
4632 scannerClose_result result = new scannerClose_result();
4633 try {
4634 iface.scannerClose(args.id);
4635 } catch (IOError io) {
4636 result.io = io;
4637 } catch (IllegalArgument ia) {
4638 result.ia = ia;
4639 }
4640 return result;
4641 }
4642 }
4643
4644 public static class getRowOrBefore<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getRowOrBefore_args> {
4645 public getRowOrBefore() {
4646 super("getRowOrBefore");
4647 }
4648
4649 public getRowOrBefore_args getEmptyArgsInstance() {
4650 return new getRowOrBefore_args();
4651 }
4652
4653 protected boolean isOneway() {
4654 return false;
4655 }
4656
4657 public getRowOrBefore_result getResult(I iface, getRowOrBefore_args args) throws org.apache.thrift.TException {
4658 getRowOrBefore_result result = new getRowOrBefore_result();
4659 try {
4660 result.success = iface.getRowOrBefore(args.tableName, args.row, args.family);
4661 } catch (IOError io) {
4662 result.io = io;
4663 }
4664 return result;
4665 }
4666 }
4667
4668 public static class getRegionInfo<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getRegionInfo_args> {
4669 public getRegionInfo() {
4670 super("getRegionInfo");
4671 }
4672
4673 public getRegionInfo_args getEmptyArgsInstance() {
4674 return new getRegionInfo_args();
4675 }
4676
4677 protected boolean isOneway() {
4678 return false;
4679 }
4680
4681 public getRegionInfo_result getResult(I iface, getRegionInfo_args args) throws org.apache.thrift.TException {
4682 getRegionInfo_result result = new getRegionInfo_result();
4683 try {
4684 result.success = iface.getRegionInfo(args.row);
4685 } catch (IOError io) {
4686 result.io = io;
4687 }
4688 return result;
4689 }
4690 }
4691
4692 }
4693
4694 public static class enableTable_args implements org.apache.thrift.TBase<enableTable_args, enableTable_args._Fields>, java.io.Serializable, Cloneable {
4695 private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("enableTable_args");
4696
4697 private static final org.apache.thrift.protocol.TField TABLE_NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("tableName", org.apache.thrift.protocol.TType.STRING, (short)1);
4698
4699 private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
4700 static {
4701 schemes.put(StandardScheme.class, new enableTable_argsStandardSchemeFactory());
4702 schemes.put(TupleScheme.class, new enableTable_argsTupleSchemeFactory());
4703 }
4704
4705
4706
4707
4708 public ByteBuffer tableName;
4709
4710
4711 public enum _Fields implements org.apache.thrift.TFieldIdEnum {
4712
4713
4714
4715 TABLE_NAME((short)1, "tableName");
4716
4717 private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
4718
4719 static {
4720 for (_Fields field : EnumSet.allOf(_Fields.class)) {
4721 byName.put(field.getFieldName(), field);
4722 }
4723 }
4724
4725
4726
4727
4728 public static _Fields findByThriftId(int fieldId) {
4729 switch(fieldId) {
4730 case 1:
4731 return TABLE_NAME;
4732 default:
4733 return null;
4734 }
4735 }
4736
4737
4738
4739
4740
4741 public static _Fields findByThriftIdOrThrow(int fieldId) {
4742 _Fields fields = findByThriftId(fieldId);
4743 if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
4744 return fields;
4745 }
4746
4747
4748
4749
4750 public static _Fields findByName(String name) {
4751 return byName.get(name);
4752 }
4753
4754 private final short _thriftId;
4755 private final String _fieldName;
4756
4757 _Fields(short thriftId, String fieldName) {
4758 _thriftId = thriftId;
4759 _fieldName = fieldName;
4760 }
4761
4762 public short getThriftFieldId() {
4763 return _thriftId;
4764 }
4765
4766 public String getFieldName() {
4767 return _fieldName;
4768 }
4769 }
4770
4771
4772 public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
4773 static {
4774 Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
4775 tmpMap.put(_Fields.TABLE_NAME, new org.apache.thrift.meta_data.FieldMetaData("tableName", org.apache.thrift.TFieldRequirementType.DEFAULT,
4776 new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING , "Bytes")));
4777 metaDataMap = Collections.unmodifiableMap(tmpMap);
4778 org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(enableTable_args.class, metaDataMap);
4779 }
4780
4781 public enableTable_args() {
4782 }
4783
4784 public enableTable_args(
4785 ByteBuffer tableName)
4786 {
4787 this();
4788 this.tableName = tableName;
4789 }
4790
4791
4792
4793
4794 public enableTable_args(enableTable_args other) {
4795 if (other.isSetTableName()) {
4796 this.tableName = other.tableName;
4797 }
4798 }
4799
4800 public enableTable_args deepCopy() {
4801 return new enableTable_args(this);
4802 }
4803
4804 @Override
4805 public void clear() {
4806 this.tableName = null;
4807 }
4808
4809
4810
4811
4812 public byte[] getTableName() {
4813 setTableName(org.apache.thrift.TBaseHelper.rightSize(tableName));
4814 return tableName == null ? null : tableName.array();
4815 }
4816
4817 public ByteBuffer bufferForTableName() {
4818 return tableName;
4819 }
4820
4821
4822
4823
4824 public enableTable_args setTableName(byte[] tableName) {
4825 setTableName(tableName == null ? (ByteBuffer)null : ByteBuffer.wrap(tableName));
4826 return this;
4827 }
4828
4829 public enableTable_args setTableName(ByteBuffer tableName) {
4830 this.tableName = tableName;
4831 return this;
4832 }
4833
4834 public void unsetTableName() {
4835 this.tableName = null;
4836 }
4837
4838
4839 public boolean isSetTableName() {
4840 return this.tableName != null;
4841 }
4842
4843 public void setTableNameIsSet(boolean value) {
4844 if (!value) {
4845 this.tableName = null;
4846 }
4847 }
4848
4849 public void setFieldValue(_Fields field, Object value) {
4850 switch (field) {
4851 case TABLE_NAME:
4852 if (value == null) {
4853 unsetTableName();
4854 } else {
4855 setTableName((ByteBuffer)value);
4856 }
4857 break;
4858
4859 }
4860 }
4861
4862 public Object getFieldValue(_Fields field) {
4863 switch (field) {
4864 case TABLE_NAME:
4865 return getTableName();
4866
4867 }
4868 throw new IllegalStateException();
4869 }
4870
4871
4872 public boolean isSet(_Fields field) {
4873 if (field == null) {
4874 throw new IllegalArgumentException();
4875 }
4876
4877 switch (field) {
4878 case TABLE_NAME:
4879 return isSetTableName();
4880 }
4881 throw new IllegalStateException();
4882 }
4883
4884 @Override
4885 public boolean equals(Object that) {
4886 if (that == null)
4887 return false;
4888 if (that instanceof enableTable_args)
4889 return this.equals((enableTable_args)that);
4890 return false;
4891 }
4892
4893 public boolean equals(enableTable_args that) {
4894 if (that == null)
4895 return false;
4896
4897 boolean this_present_tableName = true && this.isSetTableName();
4898 boolean that_present_tableName = true && that.isSetTableName();
4899 if (this_present_tableName || that_present_tableName) {
4900 if (!(this_present_tableName && that_present_tableName))
4901 return false;
4902 if (!this.tableName.equals(that.tableName))
4903 return false;
4904 }
4905
4906 return true;
4907 }
4908
4909 @Override
4910 public int hashCode() {
4911 return 0;
4912 }
4913
4914 public int compareTo(enableTable_args other) {
4915 if (!getClass().equals(other.getClass())) {
4916 return getClass().getName().compareTo(other.getClass().getName());
4917 }
4918
4919 int lastComparison = 0;
4920 enableTable_args typedOther = (enableTable_args)other;
4921
4922 lastComparison = Boolean.valueOf(isSetTableName()).compareTo(typedOther.isSetTableName());
4923 if (lastComparison != 0) {
4924 return lastComparison;
4925 }
4926 if (isSetTableName()) {
4927 lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.tableName, typedOther.tableName);
4928 if (lastComparison != 0) {
4929 return lastComparison;
4930 }
4931 }
4932 return 0;
4933 }
4934
4935 public _Fields fieldForId(int fieldId) {
4936 return _Fields.findByThriftId(fieldId);
4937 }
4938
4939 public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException {
4940 schemes.get(iprot.getScheme()).getScheme().read(iprot, this);
4941 }
4942
4943 public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
4944 schemes.get(oprot.getScheme()).getScheme().write(oprot, this);
4945 }
4946
4947 @Override
4948 public String toString() {
4949 StringBuilder sb = new StringBuilder("enableTable_args(");
4950 boolean first = true;
4951
4952 sb.append("tableName:");
4953 if (this.tableName == null) {
4954 sb.append("null");
4955 } else {
4956 sb.append(this.tableName);
4957 }
4958 first = false;
4959 sb.append(")");
4960 return sb.toString();
4961 }
4962
4963 public void validate() throws org.apache.thrift.TException {
4964
4965
4966 }
4967
4968 private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
4969 try {
4970 write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out)));
4971 } catch (org.apache.thrift.TException te) {
4972 throw new java.io.IOException(te);
4973 }
4974 }
4975
4976 private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
4977 try {
4978 read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
4979 } catch (org.apache.thrift.TException te) {
4980 throw new java.io.IOException(te);
4981 }
4982 }
4983
4984 private static class enableTable_argsStandardSchemeFactory implements SchemeFactory {
4985 public enableTable_argsStandardScheme getScheme() {
4986 return new enableTable_argsStandardScheme();
4987 }
4988 }
4989
4990 private static class enableTable_argsStandardScheme extends StandardScheme<enableTable_args> {
4991
4992 public void read(org.apache.thrift.protocol.TProtocol iprot, enableTable_args struct) throws org.apache.thrift.TException {
4993 org.apache.thrift.protocol.TField schemeField;
4994 iprot.readStructBegin();
4995 while (true)
4996 {
4997 schemeField = iprot.readFieldBegin();
4998 if (schemeField.type == org.apache.thrift.protocol.TType.STOP) {
4999 break;
5000 }
5001 switch (schemeField.id) {
5002 case 1:
5003 if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
5004 struct.tableName = iprot.readBinary();
5005 struct.setTableNameIsSet(true);
5006 } else {
5007 org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
5008 }
5009 break;
5010 default:
5011 org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
5012 }
5013 iprot.readFieldEnd();
5014 }
5015 iprot.readStructEnd();
5016
5017
5018 struct.validate();
5019 }
5020
5021 public void write(org.apache.thrift.protocol.TProtocol oprot, enableTable_args struct) throws org.apache.thrift.TException {
5022 struct.validate();
5023
5024 oprot.writeStructBegin(STRUCT_DESC);
5025 if (struct.tableName != null) {
5026 oprot.writeFieldBegin(TABLE_NAME_FIELD_DESC);
5027 oprot.writeBinary(struct.tableName);
5028 oprot.writeFieldEnd();
5029 }
5030 oprot.writeFieldStop();
5031 oprot.writeStructEnd();
5032 }
5033
5034 }
5035
5036 private static class enableTable_argsTupleSchemeFactory implements SchemeFactory {
5037 public enableTable_argsTupleScheme getScheme() {
5038 return new enableTable_argsTupleScheme();
5039 }
5040 }
5041
5042 private static class enableTable_argsTupleScheme extends TupleScheme<enableTable_args> {
5043
5044 @Override
5045 public void write(org.apache.thrift.protocol.TProtocol prot, enableTable_args struct) throws org.apache.thrift.TException {
5046 TTupleProtocol oprot = (TTupleProtocol) prot;
5047 BitSet optionals = new BitSet();
5048 if (struct.isSetTableName()) {
5049 optionals.set(0);
5050 }
5051 oprot.writeBitSet(optionals, 1);
5052 if (struct.isSetTableName()) {
5053 oprot.writeBinary(struct.tableName);
5054 }
5055 }
5056
5057 @Override
5058 public void read(org.apache.thrift.protocol.TProtocol prot, enableTable_args struct) throws org.apache.thrift.TException {
5059 TTupleProtocol iprot = (TTupleProtocol) prot;
5060 BitSet incoming = iprot.readBitSet(1);
5061 if (incoming.get(0)) {
5062 struct.tableName = iprot.readBinary();
5063 struct.setTableNameIsSet(true);
5064 }
5065 }
5066 }
5067
5068 }
5069
5070 public static class enableTable_result implements org.apache.thrift.TBase<enableTable_result, enableTable_result._Fields>, java.io.Serializable, Cloneable {
5071 private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("enableTable_result");
5072
5073 private static final org.apache.thrift.protocol.TField IO_FIELD_DESC = new org.apache.thrift.protocol.TField("io", org.apache.thrift.protocol.TType.STRUCT, (short)1);
5074
5075 private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
5076 static {
5077 schemes.put(StandardScheme.class, new enableTable_resultStandardSchemeFactory());
5078 schemes.put(TupleScheme.class, new enableTable_resultTupleSchemeFactory());
5079 }
5080
5081 public IOError io;
5082
5083
5084 public enum _Fields implements org.apache.thrift.TFieldIdEnum {
5085 IO((short)1, "io");
5086
5087 private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
5088
5089 static {
5090 for (_Fields field : EnumSet.allOf(_Fields.class)) {
5091 byName.put(field.getFieldName(), field);
5092 }
5093 }
5094
5095
5096
5097
5098 public static _Fields findByThriftId(int fieldId) {
5099 switch(fieldId) {
5100 case 1:
5101 return IO;
5102 default:
5103 return null;
5104 }
5105 }
5106
5107
5108
5109
5110
5111 public static _Fields findByThriftIdOrThrow(int fieldId) {
5112 _Fields fields = findByThriftId(fieldId);
5113 if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
5114 return fields;
5115 }
5116
5117
5118
5119
5120 public static _Fields findByName(String name) {
5121 return byName.get(name);
5122 }
5123
5124 private final short _thriftId;
5125 private final String _fieldName;
5126
5127 _Fields(short thriftId, String fieldName) {
5128 _thriftId = thriftId;
5129 _fieldName = fieldName;
5130 }
5131
5132 public short getThriftFieldId() {
5133 return _thriftId;
5134 }
5135
5136 public String getFieldName() {
5137 return _fieldName;
5138 }
5139 }
5140
5141
5142 public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
5143 static {
5144 Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
5145 tmpMap.put(_Fields.IO, new org.apache.thrift.meta_data.FieldMetaData("io", org.apache.thrift.TFieldRequirementType.DEFAULT,
5146 new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT)));
5147 metaDataMap = Collections.unmodifiableMap(tmpMap);
5148 org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(enableTable_result.class, metaDataMap);
5149 }
5150
5151 public enableTable_result() {
5152 }
5153
5154 public enableTable_result(
5155 IOError io)
5156 {
5157 this();
5158 this.io = io;
5159 }
5160
5161
5162
5163
5164 public enableTable_result(enableTable_result other) {
5165 if (other.isSetIo()) {
5166 this.io = new IOError(other.io);
5167 }
5168 }
5169
5170 public enableTable_result deepCopy() {
5171 return new enableTable_result(this);
5172 }
5173
5174 @Override
5175 public void clear() {
5176 this.io = null;
5177 }
5178
5179 public IOError getIo() {
5180 return this.io;
5181 }
5182
5183 public enableTable_result setIo(IOError io) {
5184 this.io = io;
5185 return this;
5186 }
5187
5188 public void unsetIo() {
5189 this.io = null;
5190 }
5191
5192
5193 public boolean isSetIo() {
5194 return this.io != null;
5195 }
5196
5197 public void setIoIsSet(boolean value) {
5198 if (!value) {
5199 this.io = null;
5200 }
5201 }
5202
5203 public void setFieldValue(_Fields field, Object value) {
5204 switch (field) {
5205 case IO:
5206 if (value == null) {
5207 unsetIo();
5208 } else {
5209 setIo((IOError)value);
5210 }
5211 break;
5212
5213 }
5214 }
5215
5216 public Object getFieldValue(_Fields field) {
5217 switch (field) {
5218 case IO:
5219 return getIo();
5220
5221 }
5222 throw new IllegalStateException();
5223 }
5224
5225
5226 public boolean isSet(_Fields field) {
5227 if (field == null) {
5228 throw new IllegalArgumentException();
5229 }
5230
5231 switch (field) {
5232 case IO:
5233 return isSetIo();
5234 }
5235 throw new IllegalStateException();
5236 }
5237
5238 @Override
5239 public boolean equals(Object that) {
5240 if (that == null)
5241 return false;
5242 if (that instanceof enableTable_result)
5243 return this.equals((enableTable_result)that);
5244 return false;
5245 }
5246
5247 public boolean equals(enableTable_result that) {
5248 if (that == null)
5249 return false;
5250
5251 boolean this_present_io = true && this.isSetIo();
5252 boolean that_present_io = true && that.isSetIo();
5253 if (this_present_io || that_present_io) {
5254 if (!(this_present_io && that_present_io))
5255 return false;
5256 if (!this.io.equals(that.io))
5257 return false;
5258 }
5259
5260 return true;
5261 }
5262
5263 @Override
5264 public int hashCode() {
5265 return 0;
5266 }
5267
5268 public int compareTo(enableTable_result other) {
5269 if (!getClass().equals(other.getClass())) {
5270 return getClass().getName().compareTo(other.getClass().getName());
5271 }
5272
5273 int lastComparison = 0;
5274 enableTable_result typedOther = (enableTable_result)other;
5275
5276 lastComparison = Boolean.valueOf(isSetIo()).compareTo(typedOther.isSetIo());
5277 if (lastComparison != 0) {
5278 return lastComparison;
5279 }
5280 if (isSetIo()) {
5281 lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.io, typedOther.io);
5282 if (lastComparison != 0) {
5283 return lastComparison;
5284 }
5285 }
5286 return 0;
5287 }
5288
5289 public _Fields fieldForId(int fieldId) {
5290 return _Fields.findByThriftId(fieldId);
5291 }
5292
5293 public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException {
5294 schemes.get(iprot.getScheme()).getScheme().read(iprot, this);
5295 }
5296
5297 public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
5298 schemes.get(oprot.getScheme()).getScheme().write(oprot, this);
5299 }
5300
5301 @Override
5302 public String toString() {
5303 StringBuilder sb = new StringBuilder("enableTable_result(");
5304 boolean first = true;
5305
5306 sb.append("io:");
5307 if (this.io == null) {
5308 sb.append("null");
5309 } else {
5310 sb.append(this.io);
5311 }
5312 first = false;
5313 sb.append(")");
5314 return sb.toString();
5315 }
5316
5317 public void validate() throws org.apache.thrift.TException {
5318
5319
5320 }
5321
5322 private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
5323 try {
5324 write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out)));
5325 } catch (org.apache.thrift.TException te) {
5326 throw new java.io.IOException(te);
5327 }
5328 }
5329
5330 private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
5331 try {
5332 read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
5333 } catch (org.apache.thrift.TException te) {
5334 throw new java.io.IOException(te);
5335 }
5336 }
5337
5338 private static class enableTable_resultStandardSchemeFactory implements SchemeFactory {
5339 public enableTable_resultStandardScheme getScheme() {
5340 return new enableTable_resultStandardScheme();
5341 }
5342 }
5343
5344 private static class enableTable_resultStandardScheme extends StandardScheme<enableTable_result> {
5345
5346 public void read(org.apache.thrift.protocol.TProtocol iprot, enableTable_result struct) throws org.apache.thrift.TException {
5347 org.apache.thrift.protocol.TField schemeField;
5348 iprot.readStructBegin();
5349 while (true)
5350 {
5351 schemeField = iprot.readFieldBegin();
5352 if (schemeField.type == org.apache.thrift.protocol.TType.STOP) {
5353 break;
5354 }
5355 switch (schemeField.id) {
5356 case 1:
5357 if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
5358 struct.io = new IOError();
5359 struct.io.read(iprot);
5360 struct.setIoIsSet(true);
5361 } else {
5362 org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
5363 }
5364 break;
5365 default:
5366 org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
5367 }
5368 iprot.readFieldEnd();
5369 }
5370 iprot.readStructEnd();
5371
5372
5373 struct.validate();
5374 }
5375
5376 public void write(org.apache.thrift.protocol.TProtocol oprot, enableTable_result struct) throws org.apache.thrift.TException {
5377 struct.validate();
5378
5379 oprot.writeStructBegin(STRUCT_DESC);
5380 if (struct.io != null) {
5381 oprot.writeFieldBegin(IO_FIELD_DESC);
5382 struct.io.write(oprot);
5383 oprot.writeFieldEnd();
5384 }
5385 oprot.writeFieldStop();
5386 oprot.writeStructEnd();
5387 }
5388
5389 }
5390
5391 private static class enableTable_resultTupleSchemeFactory implements SchemeFactory {
5392 public enableTable_resultTupleScheme getScheme() {
5393 return new enableTable_resultTupleScheme();
5394 }
5395 }
5396
5397 private static class enableTable_resultTupleScheme extends TupleScheme<enableTable_result> {
5398
5399 @Override
5400 public void write(org.apache.thrift.protocol.TProtocol prot, enableTable_result struct) throws org.apache.thrift.TException {
5401 TTupleProtocol oprot = (TTupleProtocol) prot;
5402 BitSet optionals = new BitSet();
5403 if (struct.isSetIo()) {
5404 optionals.set(0);
5405 }
5406 oprot.writeBitSet(optionals, 1);
5407 if (struct.isSetIo()) {
5408 struct.io.write(oprot);
5409 }
5410 }
5411
5412 @Override
5413 public void read(org.apache.thrift.protocol.TProtocol prot, enableTable_result struct) throws org.apache.thrift.TException {
5414 TTupleProtocol iprot = (TTupleProtocol) prot;
5415 BitSet incoming = iprot.readBitSet(1);
5416 if (incoming.get(0)) {
5417 struct.io = new IOError();
5418 struct.io.read(iprot);
5419 struct.setIoIsSet(true);
5420 }
5421 }
5422 }
5423
5424 }
5425
5426 public static class disableTable_args implements org.apache.thrift.TBase<disableTable_args, disableTable_args._Fields>, java.io.Serializable, Cloneable {
5427 private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("disableTable_args");
5428
5429 private static final org.apache.thrift.protocol.TField TABLE_NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("tableName", org.apache.thrift.protocol.TType.STRING, (short)1);
5430
5431 private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
5432 static {
5433 schemes.put(StandardScheme.class, new disableTable_argsStandardSchemeFactory());
5434 schemes.put(TupleScheme.class, new disableTable_argsTupleSchemeFactory());
5435 }
5436
5437
5438
5439
5440 public ByteBuffer tableName;
5441
5442
5443 public enum _Fields implements org.apache.thrift.TFieldIdEnum {
5444
5445
5446
5447 TABLE_NAME((short)1, "tableName");
5448
5449 private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
5450
5451 static {
5452 for (_Fields field : EnumSet.allOf(_Fields.class)) {
5453 byName.put(field.getFieldName(), field);
5454 }
5455 }
5456
5457
5458
5459
5460 public static _Fields findByThriftId(int fieldId) {
5461 switch(fieldId) {
5462 case 1:
5463 return TABLE_NAME;
5464 default:
5465 return null;
5466 }
5467 }
5468
5469
5470
5471
5472
5473 public static _Fields findByThriftIdOrThrow(int fieldId) {
5474 _Fields fields = findByThriftId(fieldId);
5475 if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
5476 return fields;
5477 }
5478
5479
5480
5481
5482 public static _Fields findByName(String name) {
5483 return byName.get(name);
5484 }
5485
5486 private final short _thriftId;
5487 private final String _fieldName;
5488
5489 _Fields(short thriftId, String fieldName) {
5490 _thriftId = thriftId;
5491 _fieldName = fieldName;
5492 }
5493
5494 public short getThriftFieldId() {
5495 return _thriftId;
5496 }
5497
5498 public String getFieldName() {
5499 return _fieldName;
5500 }
5501 }
5502
5503
5504 public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
5505 static {
5506 Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
5507 tmpMap.put(_Fields.TABLE_NAME, new org.apache.thrift.meta_data.FieldMetaData("tableName", org.apache.thrift.TFieldRequirementType.DEFAULT,
5508 new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING , "Bytes")));
5509 metaDataMap = Collections.unmodifiableMap(tmpMap);
5510 org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(disableTable_args.class, metaDataMap);
5511 }
5512
5513 public disableTable_args() {
5514 }
5515
5516 public disableTable_args(
5517 ByteBuffer tableName)
5518 {
5519 this();
5520 this.tableName = tableName;
5521 }
5522
5523
5524
5525
5526 public disableTable_args(disableTable_args other) {
5527 if (other.isSetTableName()) {
5528 this.tableName = other.tableName;
5529 }
5530 }
5531
5532 public disableTable_args deepCopy() {
5533 return new disableTable_args(this);
5534 }
5535
5536 @Override
5537 public void clear() {
5538 this.tableName = null;
5539 }
5540
5541
5542
5543
5544 public byte[] getTableName() {
5545 setTableName(org.apache.thrift.TBaseHelper.rightSize(tableName));
5546 return tableName == null ? null : tableName.array();
5547 }
5548
5549 public ByteBuffer bufferForTableName() {
5550 return tableName;
5551 }
5552
5553
5554
5555
5556 public disableTable_args setTableName(byte[] tableName) {
5557 setTableName(tableName == null ? (ByteBuffer)null : ByteBuffer.wrap(tableName));
5558 return this;
5559 }
5560
5561 public disableTable_args setTableName(ByteBuffer tableName) {
5562 this.tableName = tableName;
5563 return this;
5564 }
5565
5566 public void unsetTableName() {
5567 this.tableName = null;
5568 }
5569
5570
5571 public boolean isSetTableName() {
5572 return this.tableName != null;
5573 }
5574
5575 public void setTableNameIsSet(boolean value) {
5576 if (!value) {
5577 this.tableName = null;
5578 }
5579 }
5580
5581 public void setFieldValue(_Fields field, Object value) {
5582 switch (field) {
5583 case TABLE_NAME:
5584 if (value == null) {
5585 unsetTableName();
5586 } else {
5587 setTableName((ByteBuffer)value);
5588 }
5589 break;
5590
5591 }
5592 }
5593
5594 public Object getFieldValue(_Fields field) {
5595 switch (field) {
5596 case TABLE_NAME:
5597 return getTableName();
5598
5599 }
5600 throw new IllegalStateException();
5601 }
5602
5603
5604 public boolean isSet(_Fields field) {
5605 if (field == null) {
5606 throw new IllegalArgumentException();
5607 }
5608
5609 switch (field) {
5610 case TABLE_NAME:
5611 return isSetTableName();
5612 }
5613 throw new IllegalStateException();
5614 }
5615
5616 @Override
5617 public boolean equals(Object that) {
5618 if (that == null)
5619 return false;
5620 if (that instanceof disableTable_args)
5621 return this.equals((disableTable_args)that);
5622 return false;
5623 }
5624
5625 public boolean equals(disableTable_args that) {
5626 if (that == null)
5627 return false;
5628
5629 boolean this_present_tableName = true && this.isSetTableName();
5630 boolean that_present_tableName = true && that.isSetTableName();
5631 if (this_present_tableName || that_present_tableName) {
5632 if (!(this_present_tableName && that_present_tableName))
5633 return false;
5634 if (!this.tableName.equals(that.tableName))
5635 return false;
5636 }
5637
5638 return true;
5639 }
5640
5641 @Override
5642 public int hashCode() {
5643 return 0;
5644 }
5645
5646 public int compareTo(disableTable_args other) {
5647 if (!getClass().equals(other.getClass())) {
5648 return getClass().getName().compareTo(other.getClass().getName());
5649 }
5650
5651 int lastComparison = 0;
5652 disableTable_args typedOther = (disableTable_args)other;
5653
5654 lastComparison = Boolean.valueOf(isSetTableName()).compareTo(typedOther.isSetTableName());
5655 if (lastComparison != 0) {
5656 return lastComparison;
5657 }
5658 if (isSetTableName()) {
5659 lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.tableName, typedOther.tableName);
5660 if (lastComparison != 0) {
5661 return lastComparison;
5662 }
5663 }
5664 return 0;
5665 }
5666
5667 public _Fields fieldForId(int fieldId) {
5668 return _Fields.findByThriftId(fieldId);
5669 }
5670
5671 public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException {
5672 schemes.get(iprot.getScheme()).getScheme().read(iprot, this);
5673 }
5674
5675 public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
5676 schemes.get(oprot.getScheme()).getScheme().write(oprot, this);
5677 }
5678
5679 @Override
5680 public String toString() {
5681 StringBuilder sb = new StringBuilder("disableTable_args(");
5682 boolean first = true;
5683
5684 sb.append("tableName:");
5685 if (this.tableName == null) {
5686 sb.append("null");
5687 } else {
5688 sb.append(this.tableName);
5689 }
5690 first = false;
5691 sb.append(")");
5692 return sb.toString();
5693 }
5694
5695 public void validate() throws org.apache.thrift.TException {
5696
5697
5698 }
5699
5700 private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
5701 try {
5702 write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out)));
5703 } catch (org.apache.thrift.TException te) {
5704 throw new java.io.IOException(te);
5705 }
5706 }
5707
5708 private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
5709 try {
5710 read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
5711 } catch (org.apache.thrift.TException te) {
5712 throw new java.io.IOException(te);
5713 }
5714 }
5715
5716 private static class disableTable_argsStandardSchemeFactory implements SchemeFactory {
5717 public disableTable_argsStandardScheme getScheme() {
5718 return new disableTable_argsStandardScheme();
5719 }
5720 }
5721
5722 private static class disableTable_argsStandardScheme extends StandardScheme<disableTable_args> {
5723
5724 public void read(org.apache.thrift.protocol.TProtocol iprot, disableTable_args struct) throws org.apache.thrift.TException {
5725 org.apache.thrift.protocol.TField schemeField;
5726 iprot.readStructBegin();
5727 while (true)
5728 {
5729 schemeField = iprot.readFieldBegin();
5730 if (schemeField.type == org.apache.thrift.protocol.TType.STOP) {
5731 break;
5732 }
5733 switch (schemeField.id) {
5734 case 1:
5735 if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
5736 struct.tableName = iprot.readBinary();
5737 struct.setTableNameIsSet(true);
5738 } else {
5739 org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
5740 }
5741 break;
5742 default:
5743 org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
5744 }
5745 iprot.readFieldEnd();
5746 }
5747 iprot.readStructEnd();
5748
5749
5750 struct.validate();
5751 }
5752
5753 public void write(org.apache.thrift.protocol.TProtocol oprot, disableTable_args struct) throws org.apache.thrift.TException {
5754 struct.validate();
5755
5756 oprot.writeStructBegin(STRUCT_DESC);
5757 if (struct.tableName != null) {
5758 oprot.writeFieldBegin(TABLE_NAME_FIELD_DESC);
5759 oprot.writeBinary(struct.tableName);
5760 oprot.writeFieldEnd();
5761 }
5762 oprot.writeFieldStop();
5763 oprot.writeStructEnd();
5764 }
5765
5766 }
5767
5768 private static class disableTable_argsTupleSchemeFactory implements SchemeFactory {
5769 public disableTable_argsTupleScheme getScheme() {
5770 return new disableTable_argsTupleScheme();
5771 }
5772 }
5773
5774 private static class disableTable_argsTupleScheme extends TupleScheme<disableTable_args> {
5775
5776 @Override
5777 public void write(org.apache.thrift.protocol.TProtocol prot, disableTable_args struct) throws org.apache.thrift.TException {
5778 TTupleProtocol oprot = (TTupleProtocol) prot;
5779 BitSet optionals = new BitSet();
5780 if (struct.isSetTableName()) {
5781 optionals.set(0);
5782 }
5783 oprot.writeBitSet(optionals, 1);
5784 if (struct.isSetTableName()) {
5785 oprot.writeBinary(struct.tableName);
5786 }
5787 }
5788
5789 @Override
5790 public void read(org.apache.thrift.protocol.TProtocol prot, disableTable_args struct) throws org.apache.thrift.TException {
5791 TTupleProtocol iprot = (TTupleProtocol) prot;
5792 BitSet incoming = iprot.readBitSet(1);
5793 if (incoming.get(0)) {
5794 struct.tableName = iprot.readBinary();
5795 struct.setTableNameIsSet(true);
5796 }
5797 }
5798 }
5799
5800 }
5801
5802 public static class disableTable_result implements org.apache.thrift.TBase<disableTable_result, disableTable_result._Fields>, java.io.Serializable, Cloneable {
5803 private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("disableTable_result");
5804
5805 private static final org.apache.thrift.protocol.TField IO_FIELD_DESC = new org.apache.thrift.protocol.TField("io", org.apache.thrift.protocol.TType.STRUCT, (short)1);
5806
5807 private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
5808 static {
5809 schemes.put(StandardScheme.class, new disableTable_resultStandardSchemeFactory());
5810 schemes.put(TupleScheme.class, new disableTable_resultTupleSchemeFactory());
5811 }
5812
5813 public IOError io;
5814
5815
5816 public enum _Fields implements org.apache.thrift.TFieldIdEnum {
5817 IO((short)1, "io");
5818
5819 private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
5820
5821 static {
5822 for (_Fields field : EnumSet.allOf(_Fields.class)) {
5823 byName.put(field.getFieldName(), field);
5824 }
5825 }
5826
5827
5828
5829
5830 public static _Fields findByThriftId(int fieldId) {
5831 switch(fieldId) {
5832 case 1:
5833 return IO;
5834 default:
5835 return null;
5836 }
5837 }
5838
5839
5840
5841
5842
5843 public static _Fields findByThriftIdOrThrow(int fieldId) {
5844 _Fields fields = findByThriftId(fieldId);
5845 if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
5846 return fields;
5847 }
5848
5849
5850
5851
5852 public static _Fields findByName(String name) {
5853 return byName.get(name);
5854 }
5855
5856 private final short _thriftId;
5857 private final String _fieldName;
5858
5859 _Fields(short thriftId, String fieldName) {
5860 _thriftId = thriftId;
5861 _fieldName = fieldName;
5862 }
5863
5864 public short getThriftFieldId() {
5865 return _thriftId;
5866 }
5867
5868 public String getFieldName() {
5869 return _fieldName;
5870 }
5871 }
5872
5873
5874 public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
5875 static {
5876 Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
5877 tmpMap.put(_Fields.IO, new org.apache.thrift.meta_data.FieldMetaData("io", org.apache.thrift.TFieldRequirementType.DEFAULT,
5878 new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT)));
5879 metaDataMap = Collections.unmodifiableMap(tmpMap);
5880 org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(disableTable_result.class, metaDataMap);
5881 }
5882
5883 public disableTable_result() {
5884 }
5885
5886 public disableTable_result(
5887 IOError io)
5888 {
5889 this();
5890 this.io = io;
5891 }
5892
5893
5894
5895
5896 public disableTable_result(disableTable_result other) {
5897 if (other.isSetIo()) {
5898 this.io = new IOError(other.io);
5899 }
5900 }
5901
5902 public disableTable_result deepCopy() {
5903 return new disableTable_result(this);
5904 }
5905
5906 @Override
5907 public void clear() {
5908 this.io = null;
5909 }
5910
5911 public IOError getIo() {
5912 return this.io;
5913 }
5914
5915 public disableTable_result setIo(IOError io) {
5916 this.io = io;
5917 return this;
5918 }
5919
5920 public void unsetIo() {
5921 this.io = null;
5922 }
5923
5924
5925 public boolean isSetIo() {
5926 return this.io != null;
5927 }
5928
5929 public void setIoIsSet(boolean value) {
5930 if (!value) {
5931 this.io = null;
5932 }
5933 }
5934
5935 public void setFieldValue(_Fields field, Object value) {
5936 switch (field) {
5937 case IO:
5938 if (value == null) {
5939 unsetIo();
5940 } else {
5941 setIo((IOError)value);
5942 }
5943 break;
5944
5945 }
5946 }
5947
5948 public Object getFieldValue(_Fields field) {
5949 switch (field) {
5950 case IO:
5951 return getIo();
5952
5953 }
5954 throw new IllegalStateException();
5955 }
5956
5957
5958 public boolean isSet(_Fields field) {
5959 if (field == null) {
5960 throw new IllegalArgumentException();
5961 }
5962
5963 switch (field) {
5964 case IO:
5965 return isSetIo();
5966 }
5967 throw new IllegalStateException();
5968 }
5969
5970 @Override
5971 public boolean equals(Object that) {
5972 if (that == null)
5973 return false;
5974 if (that instanceof disableTable_result)
5975 return this.equals((disableTable_result)that);
5976 return false;
5977 }
5978
5979 public boolean equals(disableTable_result that) {
5980 if (that == null)
5981 return false;
5982
5983 boolean this_present_io = true && this.isSetIo();
5984 boolean that_present_io = true && that.isSetIo();
5985 if (this_present_io || that_present_io) {
5986 if (!(this_present_io && that_present_io))
5987 return false;
5988 if (!this.io.equals(that.io))
5989 return false;
5990 }
5991
5992 return true;
5993 }
5994
5995 @Override
5996 public int hashCode() {
5997 return 0;
5998 }
5999
6000 public int compareTo(disableTable_result other) {
6001 if (!getClass().equals(other.getClass())) {
6002 return getClass().getName().compareTo(other.getClass().getName());
6003 }
6004
6005 int lastComparison = 0;
6006 disableTable_result typedOther = (disableTable_result)other;
6007
6008 lastComparison = Boolean.valueOf(isSetIo()).compareTo(typedOther.isSetIo());
6009 if (lastComparison != 0) {
6010 return lastComparison;
6011 }
6012 if (isSetIo()) {
6013 lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.io, typedOther.io);
6014 if (lastComparison != 0) {
6015 return lastComparison;
6016 }
6017 }
6018 return 0;
6019 }
6020
6021 public _Fields fieldForId(int fieldId) {
6022 return _Fields.findByThriftId(fieldId);
6023 }
6024
6025 public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException {
6026 schemes.get(iprot.getScheme()).getScheme().read(iprot, this);
6027 }
6028
6029 public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
6030 schemes.get(oprot.getScheme()).getScheme().write(oprot, this);
6031 }
6032
6033 @Override
6034 public String toString() {
6035 StringBuilder sb = new StringBuilder("disableTable_result(");
6036 boolean first = true;
6037
6038 sb.append("io:");
6039 if (this.io == null) {
6040 sb.append("null");
6041 } else {
6042 sb.append(this.io);
6043 }
6044 first = false;
6045 sb.append(")");
6046 return sb.toString();
6047 }
6048
6049 public void validate() throws org.apache.thrift.TException {
6050
6051
6052 }
6053
6054 private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
6055 try {
6056 write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out)));
6057 } catch (org.apache.thrift.TException te) {
6058 throw new java.io.IOException(te);
6059 }
6060 }
6061
6062 private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
6063 try {
6064 read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
6065 } catch (org.apache.thrift.TException te) {
6066 throw new java.io.IOException(te);
6067 }
6068 }
6069
6070 private static class disableTable_resultStandardSchemeFactory implements SchemeFactory {
6071 public disableTable_resultStandardScheme getScheme() {
6072 return new disableTable_resultStandardScheme();
6073 }
6074 }
6075
6076 private static class disableTable_resultStandardScheme extends StandardScheme<disableTable_result> {
6077
6078 public void read(org.apache.thrift.protocol.TProtocol iprot, disableTable_result struct) throws org.apache.thrift.TException {
6079 org.apache.thrift.protocol.TField schemeField;
6080 iprot.readStructBegin();
6081 while (true)
6082 {
6083 schemeField = iprot.readFieldBegin();
6084 if (schemeField.type == org.apache.thrift.protocol.TType.STOP) {
6085 break;
6086 }
6087 switch (schemeField.id) {
6088 case 1:
6089 if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
6090 struct.io = new IOError();
6091 struct.io.read(iprot);
6092 struct.setIoIsSet(true);
6093 } else {
6094 org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
6095 }
6096 break;
6097 default:
6098 org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
6099 }
6100 iprot.readFieldEnd();
6101 }
6102 iprot.readStructEnd();
6103
6104
6105 struct.validate();
6106 }
6107
6108 public void write(org.apache.thrift.protocol.TProtocol oprot, disableTable_result struct) throws org.apache.thrift.TException {
6109 struct.validate();
6110
6111 oprot.writeStructBegin(STRUCT_DESC);
6112 if (struct.io != null) {
6113 oprot.writeFieldBegin(IO_FIELD_DESC);
6114 struct.io.write(oprot);
6115 oprot.writeFieldEnd();
6116 }
6117 oprot.writeFieldStop();
6118 oprot.writeStructEnd();
6119 }
6120
6121 }
6122
6123 private static class disableTable_resultTupleSchemeFactory implements SchemeFactory {
6124 public disableTable_resultTupleScheme getScheme() {
6125 return new disableTable_resultTupleScheme();
6126 }
6127 }
6128
6129 private static class disableTable_resultTupleScheme extends TupleScheme<disableTable_result> {
6130
6131 @Override
6132 public void write(org.apache.thrift.protocol.TProtocol prot, disableTable_result struct) throws org.apache.thrift.TException {
6133 TTupleProtocol oprot = (TTupleProtocol) prot;
6134 BitSet optionals = new BitSet();
6135 if (struct.isSetIo()) {
6136 optionals.set(0);
6137 }
6138 oprot.writeBitSet(optionals, 1);
6139 if (struct.isSetIo()) {
6140 struct.io.write(oprot);
6141 }
6142 }
6143
6144 @Override
6145 public void read(org.apache.thrift.protocol.TProtocol prot, disableTable_result struct) throws org.apache.thrift.TException {
6146 TTupleProtocol iprot = (TTupleProtocol) prot;
6147 BitSet incoming = iprot.readBitSet(1);
6148 if (incoming.get(0)) {
6149 struct.io = new IOError();
6150 struct.io.read(iprot);
6151 struct.setIoIsSet(true);
6152 }
6153 }
6154 }
6155
6156 }
6157
6158 public static class isTableEnabled_args implements org.apache.thrift.TBase<isTableEnabled_args, isTableEnabled_args._Fields>, java.io.Serializable, Cloneable {
6159 private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("isTableEnabled_args");
6160
6161 private static final org.apache.thrift.protocol.TField TABLE_NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("tableName", org.apache.thrift.protocol.TType.STRING, (short)1);
6162
6163 private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
6164 static {
6165 schemes.put(StandardScheme.class, new isTableEnabled_argsStandardSchemeFactory());
6166 schemes.put(TupleScheme.class, new isTableEnabled_argsTupleSchemeFactory());
6167 }
6168
6169
6170
6171
6172 public ByteBuffer tableName;
6173
6174
6175 public enum _Fields implements org.apache.thrift.TFieldIdEnum {
6176
6177
6178
6179 TABLE_NAME((short)1, "tableName");
6180
6181 private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
6182
6183 static {
6184 for (_Fields field : EnumSet.allOf(_Fields.class)) {
6185 byName.put(field.getFieldName(), field);
6186 }
6187 }
6188
6189
6190
6191
6192 public static _Fields findByThriftId(int fieldId) {
6193 switch(fieldId) {
6194 case 1:
6195 return TABLE_NAME;
6196 default:
6197 return null;
6198 }
6199 }
6200
6201
6202
6203
6204
6205 public static _Fields findByThriftIdOrThrow(int fieldId) {
6206 _Fields fields = findByThriftId(fieldId);
6207 if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
6208 return fields;
6209 }
6210
6211
6212
6213
6214 public static _Fields findByName(String name) {
6215 return byName.get(name);
6216 }
6217
6218 private final short _thriftId;
6219 private final String _fieldName;
6220
6221 _Fields(short thriftId, String fieldName) {
6222 _thriftId = thriftId;
6223 _fieldName = fieldName;
6224 }
6225
6226 public short getThriftFieldId() {
6227 return _thriftId;
6228 }
6229
6230 public String getFieldName() {
6231 return _fieldName;
6232 }
6233 }
6234
6235
6236 public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
6237 static {
6238 Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
6239 tmpMap.put(_Fields.TABLE_NAME, new org.apache.thrift.meta_data.FieldMetaData("tableName", org.apache.thrift.TFieldRequirementType.DEFAULT,
6240 new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING , "Bytes")));
6241 metaDataMap = Collections.unmodifiableMap(tmpMap);
6242 org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(isTableEnabled_args.class, metaDataMap);
6243 }
6244
6245 public isTableEnabled_args() {
6246 }
6247
6248 public isTableEnabled_args(
6249 ByteBuffer tableName)
6250 {
6251 this();
6252 this.tableName = tableName;
6253 }
6254
6255
6256
6257
6258 public isTableEnabled_args(isTableEnabled_args other) {
6259 if (other.isSetTableName()) {
6260 this.tableName = other.tableName;
6261 }
6262 }
6263
6264 public isTableEnabled_args deepCopy() {
6265 return new isTableEnabled_args(this);
6266 }
6267
6268 @Override
6269 public void clear() {
6270 this.tableName = null;
6271 }
6272
6273
6274
6275
6276 public byte[] getTableName() {
6277 setTableName(org.apache.thrift.TBaseHelper.rightSize(tableName));
6278 return tableName == null ? null : tableName.array();
6279 }
6280
6281 public ByteBuffer bufferForTableName() {
6282 return tableName;
6283 }
6284
6285
6286
6287
6288 public isTableEnabled_args setTableName(byte[] tableName) {
6289 setTableName(tableName == null ? (ByteBuffer)null : ByteBuffer.wrap(tableName));
6290 return this;
6291 }
6292
6293 public isTableEnabled_args setTableName(ByteBuffer tableName) {
6294 this.tableName = tableName;
6295 return this;
6296 }
6297
6298 public void unsetTableName() {
6299 this.tableName = null;
6300 }
6301
6302
6303 public boolean isSetTableName() {
6304 return this.tableName != null;
6305 }
6306
6307 public void setTableNameIsSet(boolean value) {
6308 if (!value) {
6309 this.tableName = null;
6310 }
6311 }
6312
6313 public void setFieldValue(_Fields field, Object value) {
6314 switch (field) {
6315 case TABLE_NAME:
6316 if (value == null) {
6317 unsetTableName();
6318 } else {
6319 setTableName((ByteBuffer)value);
6320 }
6321 break;
6322
6323 }
6324 }
6325
6326 public Object getFieldValue(_Fields field) {
6327 switch (field) {
6328 case TABLE_NAME:
6329 return getTableName();
6330
6331 }
6332 throw new IllegalStateException();
6333 }
6334
6335
6336 public boolean isSet(_Fields field) {
6337 if (field == null) {
6338 throw new IllegalArgumentException();
6339 }
6340
6341 switch (field) {
6342 case TABLE_NAME:
6343 return isSetTableName();
6344 }
6345 throw new IllegalStateException();
6346 }
6347
6348 @Override
6349 public boolean equals(Object that) {
6350 if (that == null)
6351 return false;
6352 if (that instanceof isTableEnabled_args)
6353 return this.equals((isTableEnabled_args)that);
6354 return false;
6355 }
6356
6357 public boolean equals(isTableEnabled_args that) {
6358 if (that == null)
6359 return false;
6360
6361 boolean this_present_tableName = true && this.isSetTableName();
6362 boolean that_present_tableName = true && that.isSetTableName();
6363 if (this_present_tableName || that_present_tableName) {
6364 if (!(this_present_tableName && that_present_tableName))
6365 return false;
6366 if (!this.tableName.equals(that.tableName))
6367 return false;
6368 }
6369
6370 return true;
6371 }
6372
6373 @Override
6374 public int hashCode() {
6375 return 0;
6376 }
6377
6378 public int compareTo(isTableEnabled_args other) {
6379 if (!getClass().equals(other.getClass())) {
6380 return getClass().getName().compareTo(other.getClass().getName());
6381 }
6382
6383 int lastComparison = 0;
6384 isTableEnabled_args typedOther = (isTableEnabled_args)other;
6385
6386 lastComparison = Boolean.valueOf(isSetTableName()).compareTo(typedOther.isSetTableName());
6387 if (lastComparison != 0) {
6388 return lastComparison;
6389 }
6390 if (isSetTableName()) {
6391 lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.tableName, typedOther.tableName);
6392 if (lastComparison != 0) {
6393 return lastComparison;
6394 }
6395 }
6396 return 0;
6397 }
6398
6399 public _Fields fieldForId(int fieldId) {
6400 return _Fields.findByThriftId(fieldId);
6401 }
6402
6403 public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException {
6404 schemes.get(iprot.getScheme()).getScheme().read(iprot, this);
6405 }
6406
6407 public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
6408 schemes.get(oprot.getScheme()).getScheme().write(oprot, this);
6409 }
6410
6411 @Override
6412 public String toString() {
6413 StringBuilder sb = new StringBuilder("isTableEnabled_args(");
6414 boolean first = true;
6415
6416 sb.append("tableName:");
6417 if (this.tableName == null) {
6418 sb.append("null");
6419 } else {
6420 sb.append(this.tableName);
6421 }
6422 first = false;
6423 sb.append(")");
6424 return sb.toString();
6425 }
6426
6427 public void validate() throws org.apache.thrift.TException {
6428
6429
6430 }
6431
6432 private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
6433 try {
6434 write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out)));
6435 } catch (org.apache.thrift.TException te) {
6436 throw new java.io.IOException(te);
6437 }
6438 }
6439
6440 private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
6441 try {
6442 read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
6443 } catch (org.apache.thrift.TException te) {
6444 throw new java.io.IOException(te);
6445 }
6446 }
6447
6448 private static class isTableEnabled_argsStandardSchemeFactory implements SchemeFactory {
6449 public isTableEnabled_argsStandardScheme getScheme() {
6450 return new isTableEnabled_argsStandardScheme();
6451 }
6452 }
6453
6454 private static class isTableEnabled_argsStandardScheme extends StandardScheme<isTableEnabled_args> {
6455
6456 public void read(org.apache.thrift.protocol.TProtocol iprot, isTableEnabled_args struct) throws org.apache.thrift.TException {
6457 org.apache.thrift.protocol.TField schemeField;
6458 iprot.readStructBegin();
6459 while (true)
6460 {
6461 schemeField = iprot.readFieldBegin();
6462 if (schemeField.type == org.apache.thrift.protocol.TType.STOP) {
6463 break;
6464 }
6465 switch (schemeField.id) {
6466 case 1:
6467 if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
6468 struct.tableName = iprot.readBinary();
6469 struct.setTableNameIsSet(true);
6470 } else {
6471 org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
6472 }
6473 break;
6474 default:
6475 org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
6476 }
6477 iprot.readFieldEnd();
6478 }
6479 iprot.readStructEnd();
6480
6481
6482 struct.validate();
6483 }
6484
6485 public void write(org.apache.thrift.protocol.TProtocol oprot, isTableEnabled_args struct) throws org.apache.thrift.TException {
6486 struct.validate();
6487
6488 oprot.writeStructBegin(STRUCT_DESC);
6489 if (struct.tableName != null) {
6490 oprot.writeFieldBegin(TABLE_NAME_FIELD_DESC);
6491 oprot.writeBinary(struct.tableName);
6492 oprot.writeFieldEnd();
6493 }
6494 oprot.writeFieldStop();
6495 oprot.writeStructEnd();
6496 }
6497
6498 }
6499
6500 private static class isTableEnabled_argsTupleSchemeFactory implements SchemeFactory {
6501 public isTableEnabled_argsTupleScheme getScheme() {
6502 return new isTableEnabled_argsTupleScheme();
6503 }
6504 }
6505
6506 private static class isTableEnabled_argsTupleScheme extends TupleScheme<isTableEnabled_args> {
6507
6508 @Override
6509 public void write(org.apache.thrift.protocol.TProtocol prot, isTableEnabled_args struct) throws org.apache.thrift.TException {
6510 TTupleProtocol oprot = (TTupleProtocol) prot;
6511 BitSet optionals = new BitSet();
6512 if (struct.isSetTableName()) {
6513 optionals.set(0);
6514 }
6515 oprot.writeBitSet(optionals, 1);
6516 if (struct.isSetTableName()) {
6517 oprot.writeBinary(struct.tableName);
6518 }
6519 }
6520
6521 @Override
6522 public void read(org.apache.thrift.protocol.TProtocol prot, isTableEnabled_args struct) throws org.apache.thrift.TException {
6523 TTupleProtocol iprot = (TTupleProtocol) prot;
6524 BitSet incoming = iprot.readBitSet(1);
6525 if (incoming.get(0)) {
6526 struct.tableName = iprot.readBinary();
6527 struct.setTableNameIsSet(true);
6528 }
6529 }
6530 }
6531
6532 }
6533
6534 public static class isTableEnabled_result implements org.apache.thrift.TBase<isTableEnabled_result, isTableEnabled_result._Fields>, java.io.Serializable, Cloneable {
6535 private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("isTableEnabled_result");
6536
6537 private static final org.apache.thrift.protocol.TField SUCCESS_FIELD_DESC = new org.apache.thrift.protocol.TField("success", org.apache.thrift.protocol.TType.BOOL, (short)0);
6538 private static final org.apache.thrift.protocol.TField IO_FIELD_DESC = new org.apache.thrift.protocol.TField("io", org.apache.thrift.protocol.TType.STRUCT, (short)1);
6539
6540 private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
6541 static {
6542 schemes.put(StandardScheme.class, new isTableEnabled_resultStandardSchemeFactory());
6543 schemes.put(TupleScheme.class, new isTableEnabled_resultTupleSchemeFactory());
6544 }
6545
6546 public boolean success;
6547 public IOError io;
6548
6549
6550 public enum _Fields implements org.apache.thrift.TFieldIdEnum {
6551 SUCCESS((short)0, "success"),
6552 IO((short)1, "io");
6553
6554 private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
6555
6556 static {
6557 for (_Fields field : EnumSet.allOf(_Fields.class)) {
6558 byName.put(field.getFieldName(), field);
6559 }
6560 }
6561
6562
6563
6564
6565 public static _Fields findByThriftId(int fieldId) {
6566 switch(fieldId) {
6567 case 0:
6568 return SUCCESS;
6569 case 1:
6570 return IO;
6571 default:
6572 return null;
6573 }
6574 }
6575
6576
6577
6578
6579
6580 public static _Fields findByThriftIdOrThrow(int fieldId) {
6581 _Fields fields = findByThriftId(fieldId);
6582 if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
6583 return fields;
6584 }
6585
6586
6587
6588
6589 public static _Fields findByName(String name) {
6590 return byName.get(name);
6591 }
6592
6593 private final short _thriftId;
6594 private final String _fieldName;
6595
6596 _Fields(short thriftId, String fieldName) {
6597 _thriftId = thriftId;
6598 _fieldName = fieldName;
6599 }
6600
6601 public short getThriftFieldId() {
6602 return _thriftId;
6603 }
6604
6605 public String getFieldName() {
6606 return _fieldName;
6607 }
6608 }
6609
6610
6611 private static final int __SUCCESS_ISSET_ID = 0;
6612 private byte __isset_bitfield = 0;
6613 public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
6614 static {
6615 Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
6616 tmpMap.put(_Fields.SUCCESS, new org.apache.thrift.meta_data.FieldMetaData("success", org.apache.thrift.TFieldRequirementType.DEFAULT,
6617 new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.BOOL)));
6618 tmpMap.put(_Fields.IO, new org.apache.thrift.meta_data.FieldMetaData("io", org.apache.thrift.TFieldRequirementType.DEFAULT,
6619 new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT)));
6620 metaDataMap = Collections.unmodifiableMap(tmpMap);
6621 org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(isTableEnabled_result.class, metaDataMap);
6622 }
6623
6624 public isTableEnabled_result() {
6625 }
6626
6627 public isTableEnabled_result(
6628 boolean success,
6629 IOError io)
6630 {
6631 this();
6632 this.success = success;
6633 setSuccessIsSet(true);
6634 this.io = io;
6635 }
6636
6637
6638
6639
6640 public isTableEnabled_result(isTableEnabled_result other) {
6641 __isset_bitfield = other.__isset_bitfield;
6642 this.success = other.success;
6643 if (other.isSetIo()) {
6644 this.io = new IOError(other.io);
6645 }
6646 }
6647
6648 public isTableEnabled_result deepCopy() {
6649 return new isTableEnabled_result(this);
6650 }
6651
6652 @Override
6653 public void clear() {
6654 setSuccessIsSet(false);
6655 this.success = false;
6656 this.io = null;
6657 }
6658
6659 public boolean isSuccess() {
6660 return this.success;
6661 }
6662
6663 public isTableEnabled_result setSuccess(boolean success) {
6664 this.success = success;
6665 setSuccessIsSet(true);
6666 return this;
6667 }
6668
6669 public void unsetSuccess() {
6670 __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __SUCCESS_ISSET_ID);
6671 }
6672
6673
6674 public boolean isSetSuccess() {
6675 return EncodingUtils.testBit(__isset_bitfield, __SUCCESS_ISSET_ID);
6676 }
6677
6678 public void setSuccessIsSet(boolean value) {
6679 __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __SUCCESS_ISSET_ID, value);
6680 }
6681
6682 public IOError getIo() {
6683 return this.io;
6684 }
6685
6686 public isTableEnabled_result setIo(IOError io) {
6687 this.io = io;
6688 return this;
6689 }
6690
6691 public void unsetIo() {
6692 this.io = null;
6693 }
6694
6695
6696 public boolean isSetIo() {
6697 return this.io != null;
6698 }
6699
6700 public void setIoIsSet(boolean value) {
6701 if (!value) {
6702 this.io = null;
6703 }
6704 }
6705
6706 public void setFieldValue(_Fields field, Object value) {
6707 switch (field) {
6708 case SUCCESS:
6709 if (value == null) {
6710 unsetSuccess();
6711 } else {
6712 setSuccess((Boolean)value);
6713 }
6714 break;
6715
6716 case IO:
6717 if (value == null) {
6718 unsetIo();
6719 } else {
6720 setIo((IOError)value);
6721 }
6722 break;
6723
6724 }
6725 }
6726
6727 public Object getFieldValue(_Fields field) {
6728 switch (field) {
6729 case SUCCESS:
6730 return Boolean.valueOf(isSuccess());
6731
6732 case IO:
6733 return getIo();
6734
6735 }
6736 throw new IllegalStateException();
6737 }
6738
6739
6740 public boolean isSet(_Fields field) {
6741 if (field == null) {
6742 throw new IllegalArgumentException();
6743 }
6744
6745 switch (field) {
6746 case SUCCESS:
6747 return isSetSuccess();
6748 case IO:
6749 return isSetIo();
6750 }
6751 throw new IllegalStateException();
6752 }
6753
6754 @Override
6755 public boolean equals(Object that) {
6756 if (that == null)
6757 return false;
6758 if (that instanceof isTableEnabled_result)
6759 return this.equals((isTableEnabled_result)that);
6760 return false;
6761 }
6762
6763 public boolean equals(isTableEnabled_result that) {
6764 if (that == null)
6765 return false;
6766
6767 boolean this_present_success = true;
6768 boolean that_present_success = true;
6769 if (this_present_success || that_present_success) {
6770 if (!(this_present_success && that_present_success))
6771 return false;
6772 if (this.success != that.success)
6773 return false;
6774 }
6775
6776 boolean this_present_io = true && this.isSetIo();
6777 boolean that_present_io = true && that.isSetIo();
6778 if (this_present_io || that_present_io) {
6779 if (!(this_present_io && that_present_io))
6780 return false;
6781 if (!this.io.equals(that.io))
6782 return false;
6783 }
6784
6785 return true;
6786 }
6787
6788 @Override
6789 public int hashCode() {
6790 return 0;
6791 }
6792
6793 public int compareTo(isTableEnabled_result other) {
6794 if (!getClass().equals(other.getClass())) {
6795 return getClass().getName().compareTo(other.getClass().getName());
6796 }
6797
6798 int lastComparison = 0;
6799 isTableEnabled_result typedOther = (isTableEnabled_result)other;
6800
6801 lastComparison = Boolean.valueOf(isSetSuccess()).compareTo(typedOther.isSetSuccess());
6802 if (lastComparison != 0) {
6803 return lastComparison;
6804 }
6805 if (isSetSuccess()) {
6806 lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.success, typedOther.success);
6807 if (lastComparison != 0) {
6808 return lastComparison;
6809 }
6810 }
6811 lastComparison = Boolean.valueOf(isSetIo()).compareTo(typedOther.isSetIo());
6812 if (lastComparison != 0) {
6813 return lastComparison;
6814 }
6815 if (isSetIo()) {
6816 lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.io, typedOther.io);
6817 if (lastComparison != 0) {
6818 return lastComparison;
6819 }
6820 }
6821 return 0;
6822 }
6823
6824 public _Fields fieldForId(int fieldId) {
6825 return _Fields.findByThriftId(fieldId);
6826 }
6827
6828 public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException {
6829 schemes.get(iprot.getScheme()).getScheme().read(iprot, this);
6830 }
6831
6832 public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
6833 schemes.get(oprot.getScheme()).getScheme().write(oprot, this);
6834 }
6835
6836 @Override
6837 public String toString() {
6838 StringBuilder sb = new StringBuilder("isTableEnabled_result(");
6839 boolean first = true;
6840
6841 sb.append("success:");
6842 sb.append(this.success);
6843 first = false;
6844 if (!first) sb.append(", ");
6845 sb.append("io:");
6846 if (this.io == null) {
6847 sb.append("null");
6848 } else {
6849 sb.append(this.io);
6850 }
6851 first = false;
6852 sb.append(")");
6853 return sb.toString();
6854 }
6855
6856 public void validate() throws org.apache.thrift.TException {
6857
6858
6859 }
6860
6861 private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
6862 try {
6863 write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out)));
6864 } catch (org.apache.thrift.TException te) {
6865 throw new java.io.IOException(te);
6866 }
6867 }
6868
6869 private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
6870 try {
6871
6872 __isset_bitfield = 0;
6873 read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
6874 } catch (org.apache.thrift.TException te) {
6875 throw new java.io.IOException(te);
6876 }
6877 }
6878
6879 private static class isTableEnabled_resultStandardSchemeFactory implements SchemeFactory {
6880 public isTableEnabled_resultStandardScheme getScheme() {
6881 return new isTableEnabled_resultStandardScheme();
6882 }
6883 }
6884
6885 private static class isTableEnabled_resultStandardScheme extends StandardScheme<isTableEnabled_result> {
6886
6887 public void read(org.apache.thrift.protocol.TProtocol iprot, isTableEnabled_result struct) throws org.apache.thrift.TException {
6888 org.apache.thrift.protocol.TField schemeField;
6889 iprot.readStructBegin();
6890 while (true)
6891 {
6892 schemeField = iprot.readFieldBegin();
6893 if (schemeField.type == org.apache.thrift.protocol.TType.STOP) {
6894 break;
6895 }
6896 switch (schemeField.id) {
6897 case 0:
6898 if (schemeField.type == org.apache.thrift.protocol.TType.BOOL) {
6899 struct.success = iprot.readBool();
6900 struct.setSuccessIsSet(true);
6901 } else {
6902 org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
6903 }
6904 break;
6905 case 1:
6906 if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
6907 struct.io = new IOError();
6908 struct.io.read(iprot);
6909 struct.setIoIsSet(true);
6910 } else {
6911 org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
6912 }
6913 break;
6914 default:
6915 org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
6916 }
6917 iprot.readFieldEnd();
6918 }
6919 iprot.readStructEnd();
6920
6921
6922 struct.validate();
6923 }
6924
6925 public void write(org.apache.thrift.protocol.TProtocol oprot, isTableEnabled_result struct) throws org.apache.thrift.TException {
6926 struct.validate();
6927
6928 oprot.writeStructBegin(STRUCT_DESC);
6929 if (struct.isSetSuccess()) {
6930 oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
6931 oprot.writeBool(struct.success);
6932 oprot.writeFieldEnd();
6933 }
6934 if (struct.io != null) {
6935 oprot.writeFieldBegin(IO_FIELD_DESC);
6936 struct.io.write(oprot);
6937 oprot.writeFieldEnd();
6938 }
6939 oprot.writeFieldStop();
6940 oprot.writeStructEnd();
6941 }
6942
6943 }
6944
6945 private static class isTableEnabled_resultTupleSchemeFactory implements SchemeFactory {
6946 public isTableEnabled_resultTupleScheme getScheme() {
6947 return new isTableEnabled_resultTupleScheme();
6948 }
6949 }
6950
6951 private static class isTableEnabled_resultTupleScheme extends TupleScheme<isTableEnabled_result> {
6952
6953 @Override
6954 public void write(org.apache.thrift.protocol.TProtocol prot, isTableEnabled_result struct) throws org.apache.thrift.TException {
6955 TTupleProtocol oprot = (TTupleProtocol) prot;
6956 BitSet optionals = new BitSet();
6957 if (struct.isSetSuccess()) {
6958 optionals.set(0);
6959 }
6960 if (struct.isSetIo()) {
6961 optionals.set(1);
6962 }
6963 oprot.writeBitSet(optionals, 2);
6964 if (struct.isSetSuccess()) {
6965 oprot.writeBool(struct.success);
6966 }
6967 if (struct.isSetIo()) {
6968 struct.io.write(oprot);
6969 }
6970 }
6971
6972 @Override
6973 public void read(org.apache.thrift.protocol.TProtocol prot, isTableEnabled_result struct) throws org.apache.thrift.TException {
6974 TTupleProtocol iprot = (TTupleProtocol) prot;
6975 BitSet incoming = iprot.readBitSet(2);
6976 if (incoming.get(0)) {
6977 struct.success = iprot.readBool();
6978 struct.setSuccessIsSet(true);
6979 }
6980 if (incoming.get(1)) {
6981 struct.io = new IOError();
6982 struct.io.read(iprot);
6983 struct.setIoIsSet(true);
6984 }
6985 }
6986 }
6987
6988 }
6989
6990 public static class compact_args implements org.apache.thrift.TBase<compact_args, compact_args._Fields>, java.io.Serializable, Cloneable {
6991 private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("compact_args");
6992
6993 private static final org.apache.thrift.protocol.TField TABLE_NAME_OR_REGION_NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("tableNameOrRegionName", org.apache.thrift.protocol.TType.STRING, (short)1);
6994
6995 private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
6996 static {
6997 schemes.put(StandardScheme.class, new compact_argsStandardSchemeFactory());
6998 schemes.put(TupleScheme.class, new compact_argsTupleSchemeFactory());
6999 }
7000
7001 public ByteBuffer tableNameOrRegionName;
7002
7003