1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17 /**
18 * Autogenerated by Thrift Compiler (0.9.0)
19 *
20 * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
21 * @generated
22 */
23 package org.apache.accumulo.core.tabletserver.thrift;
24
25 import org.apache.thrift.scheme.IScheme;
26 import org.apache.thrift.scheme.SchemeFactory;
27 import org.apache.thrift.scheme.StandardScheme;
28
29 import org.apache.thrift.scheme.TupleScheme;
30 import org.apache.thrift.protocol.TTupleProtocol;
31 import org.apache.thrift.protocol.TProtocolException;
32 import org.apache.thrift.EncodingUtils;
33 import org.apache.thrift.TException;
34 import java.util.List;
35 import java.util.ArrayList;
36 import java.util.Map;
37 import java.util.HashMap;
38 import java.util.EnumMap;
39 import java.util.Set;
40 import java.util.HashSet;
41 import java.util.EnumSet;
42 import java.util.Collections;
43 import java.util.BitSet;
44 import java.nio.ByteBuffer;
45 import java.util.Arrays;
46 import org.slf4j.Logger;
47 import org.slf4j.LoggerFactory;
48
49 @SuppressWarnings("all") public class ActiveScan implements org.apache.thrift.TBase<ActiveScan, ActiveScan._Fields>, java.io.Serializable, Cloneable {
50 private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("ActiveScan");
51
52 private static final org.apache.thrift.protocol.TField CLIENT_FIELD_DESC = new org.apache.thrift.protocol.TField("client", org.apache.thrift.protocol.TType.STRING, (short)2);
53 private static final org.apache.thrift.protocol.TField USER_FIELD_DESC = new org.apache.thrift.protocol.TField("user", org.apache.thrift.protocol.TType.STRING, (short)3);
54 private static final org.apache.thrift.protocol.TField TABLE_ID_FIELD_DESC = new org.apache.thrift.protocol.TField("tableId", org.apache.thrift.protocol.TType.STRING, (short)4);
55 private static final org.apache.thrift.protocol.TField AGE_FIELD_DESC = new org.apache.thrift.protocol.TField("age", org.apache.thrift.protocol.TType.I64, (short)5);
56 private static final org.apache.thrift.protocol.TField IDLE_TIME_FIELD_DESC = new org.apache.thrift.protocol.TField("idleTime", org.apache.thrift.protocol.TType.I64, (short)6);
57 private static final org.apache.thrift.protocol.TField TYPE_FIELD_DESC = new org.apache.thrift.protocol.TField("type", org.apache.thrift.protocol.TType.I32, (short)7);
58 private static final org.apache.thrift.protocol.TField STATE_FIELD_DESC = new org.apache.thrift.protocol.TField("state", org.apache.thrift.protocol.TType.I32, (short)8);
59 private static final org.apache.thrift.protocol.TField EXTENT_FIELD_DESC = new org.apache.thrift.protocol.TField("extent", org.apache.thrift.protocol.TType.STRUCT, (short)9);
60 private static final org.apache.thrift.protocol.TField COLUMNS_FIELD_DESC = new org.apache.thrift.protocol.TField("columns", org.apache.thrift.protocol.TType.LIST, (short)10);
61 private static final org.apache.thrift.protocol.TField SSI_LIST_FIELD_DESC = new org.apache.thrift.protocol.TField("ssiList", org.apache.thrift.protocol.TType.LIST, (short)11);
62 private static final org.apache.thrift.protocol.TField SSIO_FIELD_DESC = new org.apache.thrift.protocol.TField("ssio", org.apache.thrift.protocol.TType.MAP, (short)12);
63 private static final org.apache.thrift.protocol.TField AUTHORIZATIONS_FIELD_DESC = new org.apache.thrift.protocol.TField("authorizations", org.apache.thrift.protocol.TType.LIST, (short)13);
64
65 private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
66 static {
67 schemes.put(StandardScheme.class, new ActiveScanStandardSchemeFactory());
68 schemes.put(TupleScheme.class, new ActiveScanTupleSchemeFactory());
69 }
70
71 public String client;
72 public String user;
73 public String tableId;
74 public long age;
75 public long idleTime;
76 /**
77 *
78 * @see ScanType
79 */
80 public ScanType type;
81 /**
82 *
83 * @see ScanState
84 */
85 public ScanState state;
86 public org.apache.accumulo.core.data.thrift.TKeyExtent extent;
87 public List<org.apache.accumulo.core.data.thrift.TColumn> columns;
88 public List<org.apache.accumulo.core.data.thrift.IterInfo> ssiList;
89 public Map<String,Map<String,String>> ssio;
90 public List<ByteBuffer> authorizations;
91
92 /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
93 @SuppressWarnings("all") public enum _Fields implements org.apache.thrift.TFieldIdEnum {
94 CLIENT((short)2, "client"),
95 USER((short)3, "user"),
96 TABLE_ID((short)4, "tableId"),
97 AGE((short)5, "age"),
98 IDLE_TIME((short)6, "idleTime"),
99 /**
100 *
101 * @see ScanType
102 */
103 TYPE((short)7, "type"),
104 /**
105 *
106 * @see ScanState
107 */
108 STATE((short)8, "state"),
109 EXTENT((short)9, "extent"),
110 COLUMNS((short)10, "columns"),
111 SSI_LIST((short)11, "ssiList"),
112 SSIO((short)12, "ssio"),
113 AUTHORIZATIONS((short)13, "authorizations");
114
115 private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
116
117 static {
118 for (_Fields field : EnumSet.allOf(_Fields.class)) {
119 byName.put(field.getFieldName(), field);
120 }
121 }
122
123 /**
124 * Find the _Fields constant that matches fieldId, or null if its not found.
125 */
126 public static _Fields findByThriftId(int fieldId) {
127 switch(fieldId) {
128 case 2:
129 return CLIENT;
130 case 3:
131 return USER;
132 case 4:
133 return TABLE_ID;
134 case 5:
135 return AGE;
136 case 6:
137 return IDLE_TIME;
138 case 7:
139 return TYPE;
140 case 8:
141 return STATE;
142 case 9:
143 return EXTENT;
144 case 10:
145 return COLUMNS;
146 case 11:
147 return SSI_LIST;
148 case 12:
149 return SSIO;
150 case 13:
151 return AUTHORIZATIONS;
152 default:
153 return null;
154 }
155 }
156
157 /**
158 * Find the _Fields constant that matches fieldId, throwing an exception
159 * if it is not found.
160 */
161 public static _Fields findByThriftIdOrThrow(int fieldId) {
162 _Fields fields = findByThriftId(fieldId);
163 if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
164 return fields;
165 }
166
167 /**
168 * Find the _Fields constant that matches name, or null if its not found.
169 */
170 public static _Fields findByName(String name) {
171 return byName.get(name);
172 }
173
174 private final short _thriftId;
175 private final String _fieldName;
176
177 _Fields(short thriftId, String fieldName) {
178 _thriftId = thriftId;
179 _fieldName = fieldName;
180 }
181
182 public short getThriftFieldId() {
183 return _thriftId;
184 }
185
186 public String getFieldName() {
187 return _fieldName;
188 }
189 }
190
191
192 private static final int __AGE_ISSET_ID = 0;
193 private static final int __IDLETIME_ISSET_ID = 1;
194 private byte __isset_bitfield = 0;
195 public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
196 static {
197 Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
198 tmpMap.put(_Fields.CLIENT, new org.apache.thrift.meta_data.FieldMetaData("client", org.apache.thrift.TFieldRequirementType.DEFAULT,
199 new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
200 tmpMap.put(_Fields.USER, new org.apache.thrift.meta_data.FieldMetaData("user", org.apache.thrift.TFieldRequirementType.DEFAULT,
201 new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
202 tmpMap.put(_Fields.TABLE_ID, new org.apache.thrift.meta_data.FieldMetaData("tableId", org.apache.thrift.TFieldRequirementType.DEFAULT,
203 new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
204 tmpMap.put(_Fields.AGE, new org.apache.thrift.meta_data.FieldMetaData("age", org.apache.thrift.TFieldRequirementType.DEFAULT,
205 new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
206 tmpMap.put(_Fields.IDLE_TIME, new org.apache.thrift.meta_data.FieldMetaData("idleTime", org.apache.thrift.TFieldRequirementType.DEFAULT,
207 new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
208 tmpMap.put(_Fields.TYPE, new org.apache.thrift.meta_data.FieldMetaData("type", org.apache.thrift.TFieldRequirementType.DEFAULT,
209 new org.apache.thrift.meta_data.EnumMetaData(org.apache.thrift.protocol.TType.ENUM, ScanType.class)));
210 tmpMap.put(_Fields.STATE, new org.apache.thrift.meta_data.FieldMetaData("state", org.apache.thrift.TFieldRequirementType.DEFAULT,
211 new org.apache.thrift.meta_data.EnumMetaData(org.apache.thrift.protocol.TType.ENUM, ScanState.class)));
212 tmpMap.put(_Fields.EXTENT, new org.apache.thrift.meta_data.FieldMetaData("extent", org.apache.thrift.TFieldRequirementType.DEFAULT,
213 new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, org.apache.accumulo.core.data.thrift.TKeyExtent.class)));
214 tmpMap.put(_Fields.COLUMNS, new org.apache.thrift.meta_data.FieldMetaData("columns", org.apache.thrift.TFieldRequirementType.DEFAULT,
215 new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST,
216 new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, org.apache.accumulo.core.data.thrift.TColumn.class))));
217 tmpMap.put(_Fields.SSI_LIST, new org.apache.thrift.meta_data.FieldMetaData("ssiList", org.apache.thrift.TFieldRequirementType.DEFAULT,
218 new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST,
219 new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, org.apache.accumulo.core.data.thrift.IterInfo.class))));
220 tmpMap.put(_Fields.SSIO, new org.apache.thrift.meta_data.FieldMetaData("ssio", org.apache.thrift.TFieldRequirementType.DEFAULT,
221 new org.apache.thrift.meta_data.MapMetaData(org.apache.thrift.protocol.TType.MAP,
222 new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING),
223 new org.apache.thrift.meta_data.MapMetaData(org.apache.thrift.protocol.TType.MAP,
224 new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING),
225 new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)))));
226 tmpMap.put(_Fields.AUTHORIZATIONS, new org.apache.thrift.meta_data.FieldMetaData("authorizations", org.apache.thrift.TFieldRequirementType.DEFAULT,
227 new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST,
228 new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING , true))));
229 metaDataMap = Collections.unmodifiableMap(tmpMap);
230 org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(ActiveScan.class, metaDataMap);
231 }
232
233 public ActiveScan() {
234 }
235
236 public ActiveScan(
237 String client,
238 String user,
239 String tableId,
240 long age,
241 long idleTime,
242 ScanType type,
243 ScanState state,
244 org.apache.accumulo.core.data.thrift.TKeyExtent extent,
245 List<org.apache.accumulo.core.data.thrift.TColumn> columns,
246 List<org.apache.accumulo.core.data.thrift.IterInfo> ssiList,
247 Map<String,Map<String,String>> ssio,
248 List<ByteBuffer> authorizations)
249 {
250 this();
251 this.client = client;
252 this.user = user;
253 this.tableId = tableId;
254 this.age = age;
255 setAgeIsSet(true);
256 this.idleTime = idleTime;
257 setIdleTimeIsSet(true);
258 this.type = type;
259 this.state = state;
260 this.extent = extent;
261 this.columns = columns;
262 this.ssiList = ssiList;
263 this.ssio = ssio;
264 this.authorizations = authorizations;
265 }
266
267 /**
268 * Performs a deep copy on <i>other</i>.
269 */
270 public ActiveScan(ActiveScan other) {
271 __isset_bitfield = other.__isset_bitfield;
272 if (other.isSetClient()) {
273 this.client = other.client;
274 }
275 if (other.isSetUser()) {
276 this.user = other.user;
277 }
278 if (other.isSetTableId()) {
279 this.tableId = other.tableId;
280 }
281 this.age = other.age;
282 this.idleTime = other.idleTime;
283 if (other.isSetType()) {
284 this.type = other.type;
285 }
286 if (other.isSetState()) {
287 this.state = other.state;
288 }
289 if (other.isSetExtent()) {
290 this.extent = new org.apache.accumulo.core.data.thrift.TKeyExtent(other.extent);
291 }
292 if (other.isSetColumns()) {
293 List<org.apache.accumulo.core.data.thrift.TColumn> __this__columns = new ArrayList<org.apache.accumulo.core.data.thrift.TColumn>();
294 for (org.apache.accumulo.core.data.thrift.TColumn other_element : other.columns) {
295 __this__columns.add(new org.apache.accumulo.core.data.thrift.TColumn(other_element));
296 }
297 this.columns = __this__columns;
298 }
299 if (other.isSetSsiList()) {
300 List<org.apache.accumulo.core.data.thrift.IterInfo> __this__ssiList = new ArrayList<org.apache.accumulo.core.data.thrift.IterInfo>();
301 for (org.apache.accumulo.core.data.thrift.IterInfo other_element : other.ssiList) {
302 __this__ssiList.add(new org.apache.accumulo.core.data.thrift.IterInfo(other_element));
303 }
304 this.ssiList = __this__ssiList;
305 }
306 if (other.isSetSsio()) {
307 Map<String,Map<String,String>> __this__ssio = new HashMap<String,Map<String,String>>();
308 for (Map.Entry<String, Map<String,String>> other_element : other.ssio.entrySet()) {
309
310 String other_element_key = other_element.getKey();
311 Map<String,String> other_element_value = other_element.getValue();
312
313 String __this__ssio_copy_key = other_element_key;
314
315 Map<String,String> __this__ssio_copy_value = new HashMap<String,String>();
316 for (Map.Entry<String, String> other_element_value_element : other_element_value.entrySet()) {
317
318 String other_element_value_element_key = other_element_value_element.getKey();
319 String other_element_value_element_value = other_element_value_element.getValue();
320
321 String __this__ssio_copy_value_copy_key = other_element_value_element_key;
322
323 String __this__ssio_copy_value_copy_value = other_element_value_element_value;
324
325 __this__ssio_copy_value.put(__this__ssio_copy_value_copy_key, __this__ssio_copy_value_copy_value);
326 }
327
328 __this__ssio.put(__this__ssio_copy_key, __this__ssio_copy_value);
329 }
330 this.ssio = __this__ssio;
331 }
332 if (other.isSetAuthorizations()) {
333 List<ByteBuffer> __this__authorizations = new ArrayList<ByteBuffer>();
334 for (ByteBuffer other_element : other.authorizations) {
335 ByteBuffer temp_binary_element = org.apache.thrift.TBaseHelper.copyBinary(other_element);
336 ;
337 __this__authorizations.add(temp_binary_element);
338 }
339 this.authorizations = __this__authorizations;
340 }
341 }
342
343 public ActiveScan deepCopy() {
344 return new ActiveScan(this);
345 }
346
347 @Override
348 public void clear() {
349 this.client = null;
350 this.user = null;
351 this.tableId = null;
352 setAgeIsSet(false);
353 this.age = 0;
354 setIdleTimeIsSet(false);
355 this.idleTime = 0;
356 this.type = null;
357 this.state = null;
358 this.extent = null;
359 this.columns = null;
360 this.ssiList = null;
361 this.ssio = null;
362 this.authorizations = null;
363 }
364
365 public String getClient() {
366 return this.client;
367 }
368
369 public ActiveScan setClient(String client) {
370 this.client = client;
371 return this;
372 }
373
374 public void unsetClient() {
375 this.client = null;
376 }
377
378 /** Returns true if field client is set (has been assigned a value) and false otherwise */
379 public boolean isSetClient() {
380 return this.client != null;
381 }
382
383 public void setClientIsSet(boolean value) {
384 if (!value) {
385 this.client = null;
386 }
387 }
388
389 public String getUser() {
390 return this.user;
391 }
392
393 public ActiveScan setUser(String user) {
394 this.user = user;
395 return this;
396 }
397
398 public void unsetUser() {
399 this.user = null;
400 }
401
402 /** Returns true if field user is set (has been assigned a value) and false otherwise */
403 public boolean isSetUser() {
404 return this.user != null;
405 }
406
407 public void setUserIsSet(boolean value) {
408 if (!value) {
409 this.user = null;
410 }
411 }
412
413 public String getTableId() {
414 return this.tableId;
415 }
416
417 public ActiveScan setTableId(String tableId) {
418 this.tableId = tableId;
419 return this;
420 }
421
422 public void unsetTableId() {
423 this.tableId = null;
424 }
425
426 /** Returns true if field tableId is set (has been assigned a value) and false otherwise */
427 public boolean isSetTableId() {
428 return this.tableId != null;
429 }
430
431 public void setTableIdIsSet(boolean value) {
432 if (!value) {
433 this.tableId = null;
434 }
435 }
436
437 public long getAge() {
438 return this.age;
439 }
440
441 public ActiveScan setAge(long age) {
442 this.age = age;
443 setAgeIsSet(true);
444 return this;
445 }
446
447 public void unsetAge() {
448 __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __AGE_ISSET_ID);
449 }
450
451 /** Returns true if field age is set (has been assigned a value) and false otherwise */
452 public boolean isSetAge() {
453 return EncodingUtils.testBit(__isset_bitfield, __AGE_ISSET_ID);
454 }
455
456 public void setAgeIsSet(boolean value) {
457 __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __AGE_ISSET_ID, value);
458 }
459
460 public long getIdleTime() {
461 return this.idleTime;
462 }
463
464 public ActiveScan setIdleTime(long idleTime) {
465 this.idleTime = idleTime;
466 setIdleTimeIsSet(true);
467 return this;
468 }
469
470 public void unsetIdleTime() {
471 __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __IDLETIME_ISSET_ID);
472 }
473
474 /** Returns true if field idleTime is set (has been assigned a value) and false otherwise */
475 public boolean isSetIdleTime() {
476 return EncodingUtils.testBit(__isset_bitfield, __IDLETIME_ISSET_ID);
477 }
478
479 public void setIdleTimeIsSet(boolean value) {
480 __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __IDLETIME_ISSET_ID, value);
481 }
482
483 /**
484 *
485 * @see ScanType
486 */
487 public ScanType getType() {
488 return this.type;
489 }
490
491 /**
492 *
493 * @see ScanType
494 */
495 public ActiveScan setType(ScanType type) {
496 this.type = type;
497 return this;
498 }
499
500 public void unsetType() {
501 this.type = null;
502 }
503
504 /** Returns true if field type is set (has been assigned a value) and false otherwise */
505 public boolean isSetType() {
506 return this.type != null;
507 }
508
509 public void setTypeIsSet(boolean value) {
510 if (!value) {
511 this.type = null;
512 }
513 }
514
515 /**
516 *
517 * @see ScanState
518 */
519 public ScanState getState() {
520 return this.state;
521 }
522
523 /**
524 *
525 * @see ScanState
526 */
527 public ActiveScan setState(ScanState state) {
528 this.state = state;
529 return this;
530 }
531
532 public void unsetState() {
533 this.state = null;
534 }
535
536 /** Returns true if field state is set (has been assigned a value) and false otherwise */
537 public boolean isSetState() {
538 return this.state != null;
539 }
540
541 public void setStateIsSet(boolean value) {
542 if (!value) {
543 this.state = null;
544 }
545 }
546
547 public org.apache.accumulo.core.data.thrift.TKeyExtent getExtent() {
548 return this.extent;
549 }
550
551 public ActiveScan setExtent(org.apache.accumulo.core.data.thrift.TKeyExtent extent) {
552 this.extent = extent;
553 return this;
554 }
555
556 public void unsetExtent() {
557 this.extent = null;
558 }
559
560 /** Returns true if field extent is set (has been assigned a value) and false otherwise */
561 public boolean isSetExtent() {
562 return this.extent != null;
563 }
564
565 public void setExtentIsSet(boolean value) {
566 if (!value) {
567 this.extent = null;
568 }
569 }
570
571 public int getColumnsSize() {
572 return (this.columns == null) ? 0 : this.columns.size();
573 }
574
575 public java.util.Iterator<org.apache.accumulo.core.data.thrift.TColumn> getColumnsIterator() {
576 return (this.columns == null) ? null : this.columns.iterator();
577 }
578
579 public void addToColumns(org.apache.accumulo.core.data.thrift.TColumn elem) {
580 if (this.columns == null) {
581 this.columns = new ArrayList<org.apache.accumulo.core.data.thrift.TColumn>();
582 }
583 this.columns.add(elem);
584 }
585
586 public List<org.apache.accumulo.core.data.thrift.TColumn> getColumns() {
587 return this.columns;
588 }
589
590 public ActiveScan setColumns(List<org.apache.accumulo.core.data.thrift.TColumn> columns) {
591 this.columns = columns;
592 return this;
593 }
594
595 public void unsetColumns() {
596 this.columns = null;
597 }
598
599 /** Returns true if field columns is set (has been assigned a value) and false otherwise */
600 public boolean isSetColumns() {
601 return this.columns != null;
602 }
603
604 public void setColumnsIsSet(boolean value) {
605 if (!value) {
606 this.columns = null;
607 }
608 }
609
610 public int getSsiListSize() {
611 return (this.ssiList == null) ? 0 : this.ssiList.size();
612 }
613
614 public java.util.Iterator<org.apache.accumulo.core.data.thrift.IterInfo> getSsiListIterator() {
615 return (this.ssiList == null) ? null : this.ssiList.iterator();
616 }
617
618 public void addToSsiList(org.apache.accumulo.core.data.thrift.IterInfo elem) {
619 if (this.ssiList == null) {
620 this.ssiList = new ArrayList<org.apache.accumulo.core.data.thrift.IterInfo>();
621 }
622 this.ssiList.add(elem);
623 }
624
625 public List<org.apache.accumulo.core.data.thrift.IterInfo> getSsiList() {
626 return this.ssiList;
627 }
628
629 public ActiveScan setSsiList(List<org.apache.accumulo.core.data.thrift.IterInfo> ssiList) {
630 this.ssiList = ssiList;
631 return this;
632 }
633
634 public void unsetSsiList() {
635 this.ssiList = null;
636 }
637
638 /** Returns true if field ssiList is set (has been assigned a value) and false otherwise */
639 public boolean isSetSsiList() {
640 return this.ssiList != null;
641 }
642
643 public void setSsiListIsSet(boolean value) {
644 if (!value) {
645 this.ssiList = null;
646 }
647 }
648
649 public int getSsioSize() {
650 return (this.ssio == null) ? 0 : this.ssio.size();
651 }
652
653 public void putToSsio(String key, Map<String,String> val) {
654 if (this.ssio == null) {
655 this.ssio = new HashMap<String,Map<String,String>>();
656 }
657 this.ssio.put(key, val);
658 }
659
660 public Map<String,Map<String,String>> getSsio() {
661 return this.ssio;
662 }
663
664 public ActiveScan setSsio(Map<String,Map<String,String>> ssio) {
665 this.ssio = ssio;
666 return this;
667 }
668
669 public void unsetSsio() {
670 this.ssio = null;
671 }
672
673 /** Returns true if field ssio is set (has been assigned a value) and false otherwise */
674 public boolean isSetSsio() {
675 return this.ssio != null;
676 }
677
678 public void setSsioIsSet(boolean value) {
679 if (!value) {
680 this.ssio = null;
681 }
682 }
683
684 public int getAuthorizationsSize() {
685 return (this.authorizations == null) ? 0 : this.authorizations.size();
686 }
687
688 public java.util.Iterator<ByteBuffer> getAuthorizationsIterator() {
689 return (this.authorizations == null) ? null : this.authorizations.iterator();
690 }
691
692 public void addToAuthorizations(ByteBuffer elem) {
693 if (this.authorizations == null) {
694 this.authorizations = new ArrayList<ByteBuffer>();
695 }
696 this.authorizations.add(elem);
697 }
698
699 public List<ByteBuffer> getAuthorizations() {
700 return this.authorizations;
701 }
702
703 public ActiveScan setAuthorizations(List<ByteBuffer> authorizations) {
704 this.authorizations = authorizations;
705 return this;
706 }
707
708 public void unsetAuthorizations() {
709 this.authorizations = null;
710 }
711
712 /** Returns true if field authorizations is set (has been assigned a value) and false otherwise */
713 public boolean isSetAuthorizations() {
714 return this.authorizations != null;
715 }
716
717 public void setAuthorizationsIsSet(boolean value) {
718 if (!value) {
719 this.authorizations = null;
720 }
721 }
722
723 public void setFieldValue(_Fields field, Object value) {
724 switch (field) {
725 case CLIENT:
726 if (value == null) {
727 unsetClient();
728 } else {
729 setClient((String)value);
730 }
731 break;
732
733 case USER:
734 if (value == null) {
735 unsetUser();
736 } else {
737 setUser((String)value);
738 }
739 break;
740
741 case TABLE_ID:
742 if (value == null) {
743 unsetTableId();
744 } else {
745 setTableId((String)value);
746 }
747 break;
748
749 case AGE:
750 if (value == null) {
751 unsetAge();
752 } else {
753 setAge((Long)value);
754 }
755 break;
756
757 case IDLE_TIME:
758 if (value == null) {
759 unsetIdleTime();
760 } else {
761 setIdleTime((Long)value);
762 }
763 break;
764
765 case TYPE:
766 if (value == null) {
767 unsetType();
768 } else {
769 setType((ScanType)value);
770 }
771 break;
772
773 case STATE:
774 if (value == null) {
775 unsetState();
776 } else {
777 setState((ScanState)value);
778 }
779 break;
780
781 case EXTENT:
782 if (value == null) {
783 unsetExtent();
784 } else {
785 setExtent((org.apache.accumulo.core.data.thrift.TKeyExtent)value);
786 }
787 break;
788
789 case COLUMNS:
790 if (value == null) {
791 unsetColumns();
792 } else {
793 setColumns((List<org.apache.accumulo.core.data.thrift.TColumn>)value);
794 }
795 break;
796
797 case SSI_LIST:
798 if (value == null) {
799 unsetSsiList();
800 } else {
801 setSsiList((List<org.apache.accumulo.core.data.thrift.IterInfo>)value);
802 }
803 break;
804
805 case SSIO:
806 if (value == null) {
807 unsetSsio();
808 } else {
809 setSsio((Map<String,Map<String,String>>)value);
810 }
811 break;
812
813 case AUTHORIZATIONS:
814 if (value == null) {
815 unsetAuthorizations();
816 } else {
817 setAuthorizations((List<ByteBuffer>)value);
818 }
819 break;
820
821 }
822 }
823
824 public Object getFieldValue(_Fields field) {
825 switch (field) {
826 case CLIENT:
827 return getClient();
828
829 case USER:
830 return getUser();
831
832 case TABLE_ID:
833 return getTableId();
834
835 case AGE:
836 return Long.valueOf(getAge());
837
838 case IDLE_TIME:
839 return Long.valueOf(getIdleTime());
840
841 case TYPE:
842 return getType();
843
844 case STATE:
845 return getState();
846
847 case EXTENT:
848 return getExtent();
849
850 case COLUMNS:
851 return getColumns();
852
853 case SSI_LIST:
854 return getSsiList();
855
856 case SSIO:
857 return getSsio();
858
859 case AUTHORIZATIONS:
860 return getAuthorizations();
861
862 }
863 throw new IllegalStateException();
864 }
865
866 /** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */
867 public boolean isSet(_Fields field) {
868 if (field == null) {
869 throw new IllegalArgumentException();
870 }
871
872 switch (field) {
873 case CLIENT:
874 return isSetClient();
875 case USER:
876 return isSetUser();
877 case TABLE_ID:
878 return isSetTableId();
879 case AGE:
880 return isSetAge();
881 case IDLE_TIME:
882 return isSetIdleTime();
883 case TYPE:
884 return isSetType();
885 case STATE:
886 return isSetState();
887 case EXTENT:
888 return isSetExtent();
889 case COLUMNS:
890 return isSetColumns();
891 case SSI_LIST:
892 return isSetSsiList();
893 case SSIO:
894 return isSetSsio();
895 case AUTHORIZATIONS:
896 return isSetAuthorizations();
897 }
898 throw new IllegalStateException();
899 }
900
901 @Override
902 public boolean equals(Object that) {
903 if (that == null)
904 return false;
905 if (that instanceof ActiveScan)
906 return this.equals((ActiveScan)that);
907 return false;
908 }
909
910 public boolean equals(ActiveScan that) {
911 if (that == null)
912 return false;
913
914 boolean this_present_client = true && this.isSetClient();
915 boolean that_present_client = true && that.isSetClient();
916 if (this_present_client || that_present_client) {
917 if (!(this_present_client && that_present_client))
918 return false;
919 if (!this.client.equals(that.client))
920 return false;
921 }
922
923 boolean this_present_user = true && this.isSetUser();
924 boolean that_present_user = true && that.isSetUser();
925 if (this_present_user || that_present_user) {
926 if (!(this_present_user && that_present_user))
927 return false;
928 if (!this.user.equals(that.user))
929 return false;
930 }
931
932 boolean this_present_tableId = true && this.isSetTableId();
933 boolean that_present_tableId = true && that.isSetTableId();
934 if (this_present_tableId || that_present_tableId) {
935 if (!(this_present_tableId && that_present_tableId))
936 return false;
937 if (!this.tableId.equals(that.tableId))
938 return false;
939 }
940
941 boolean this_present_age = true;
942 boolean that_present_age = true;
943 if (this_present_age || that_present_age) {
944 if (!(this_present_age && that_present_age))
945 return false;
946 if (this.age != that.age)
947 return false;
948 }
949
950 boolean this_present_idleTime = true;
951 boolean that_present_idleTime = true;
952 if (this_present_idleTime || that_present_idleTime) {
953 if (!(this_present_idleTime && that_present_idleTime))
954 return false;
955 if (this.idleTime != that.idleTime)
956 return false;
957 }
958
959 boolean this_present_type = true && this.isSetType();
960 boolean that_present_type = true && that.isSetType();
961 if (this_present_type || that_present_type) {
962 if (!(this_present_type && that_present_type))
963 return false;
964 if (!this.type.equals(that.type))
965 return false;
966 }
967
968 boolean this_present_state = true && this.isSetState();
969 boolean that_present_state = true && that.isSetState();
970 if (this_present_state || that_present_state) {
971 if (!(this_present_state && that_present_state))
972 return false;
973 if (!this.state.equals(that.state))
974 return false;
975 }
976
977 boolean this_present_extent = true && this.isSetExtent();
978 boolean that_present_extent = true && that.isSetExtent();
979 if (this_present_extent || that_present_extent) {
980 if (!(this_present_extent && that_present_extent))
981 return false;
982 if (!this.extent.equals(that.extent))
983 return false;
984 }
985
986 boolean this_present_columns = true && this.isSetColumns();
987 boolean that_present_columns = true && that.isSetColumns();
988 if (this_present_columns || that_present_columns) {
989 if (!(this_present_columns && that_present_columns))
990 return false;
991 if (!this.columns.equals(that.columns))
992 return false;
993 }
994
995 boolean this_present_ssiList = true && this.isSetSsiList();
996 boolean that_present_ssiList = true && that.isSetSsiList();
997 if (this_present_ssiList || that_present_ssiList) {
998 if (!(this_present_ssiList && that_present_ssiList))
999 return false;
1000 if (!this.ssiList.equals(that.ssiList))
1001 return false;
1002 }
1003
1004 boolean this_present_ssio = true && this.isSetSsio();
1005 boolean that_present_ssio = true && that.isSetSsio();
1006 if (this_present_ssio || that_present_ssio) {
1007 if (!(this_present_ssio && that_present_ssio))
1008 return false;
1009 if (!this.ssio.equals(that.ssio))
1010 return false;
1011 }
1012
1013 boolean this_present_authorizations = true && this.isSetAuthorizations();
1014 boolean that_present_authorizations = true && that.isSetAuthorizations();
1015 if (this_present_authorizations || that_present_authorizations) {
1016 if (!(this_present_authorizations && that_present_authorizations))
1017 return false;
1018 if (!this.authorizations.equals(that.authorizations))
1019 return false;
1020 }
1021
1022 return true;
1023 }
1024
1025 @Override
1026 public int hashCode() {
1027 return 0;
1028 }
1029
1030 public int compareTo(ActiveScan other) {
1031 if (!getClass().equals(other.getClass())) {
1032 return getClass().getName().compareTo(other.getClass().getName());
1033 }
1034
1035 int lastComparison = 0;
1036 ActiveScan typedOther = (ActiveScan)other;
1037
1038 lastComparison = Boolean.valueOf(isSetClient()).compareTo(typedOther.isSetClient());
1039 if (lastComparison != 0) {
1040 return lastComparison;
1041 }
1042 if (isSetClient()) {
1043 lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.client, typedOther.client);
1044 if (lastComparison != 0) {
1045 return lastComparison;
1046 }
1047 }
1048 lastComparison = Boolean.valueOf(isSetUser()).compareTo(typedOther.isSetUser());
1049 if (lastComparison != 0) {
1050 return lastComparison;
1051 }
1052 if (isSetUser()) {
1053 lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.user, typedOther.user);
1054 if (lastComparison != 0) {
1055 return lastComparison;
1056 }
1057 }
1058 lastComparison = Boolean.valueOf(isSetTableId()).compareTo(typedOther.isSetTableId());
1059 if (lastComparison != 0) {
1060 return lastComparison;
1061 }
1062 if (isSetTableId()) {
1063 lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.tableId, typedOther.tableId);
1064 if (lastComparison != 0) {
1065 return lastComparison;
1066 }
1067 }
1068 lastComparison = Boolean.valueOf(isSetAge()).compareTo(typedOther.isSetAge());
1069 if (lastComparison != 0) {
1070 return lastComparison;
1071 }
1072 if (isSetAge()) {
1073 lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.age, typedOther.age);
1074 if (lastComparison != 0) {
1075 return lastComparison;
1076 }
1077 }
1078 lastComparison = Boolean.valueOf(isSetIdleTime()).compareTo(typedOther.isSetIdleTime());
1079 if (lastComparison != 0) {
1080 return lastComparison;
1081 }
1082 if (isSetIdleTime()) {
1083 lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.idleTime, typedOther.idleTime);
1084 if (lastComparison != 0) {
1085 return lastComparison;
1086 }
1087 }
1088 lastComparison = Boolean.valueOf(isSetType()).compareTo(typedOther.isSetType());
1089 if (lastComparison != 0) {
1090 return lastComparison;
1091 }
1092 if (isSetType()) {
1093 lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.type, typedOther.type);
1094 if (lastComparison != 0) {
1095 return lastComparison;
1096 }
1097 }
1098 lastComparison = Boolean.valueOf(isSetState()).compareTo(typedOther.isSetState());
1099 if (lastComparison != 0) {
1100 return lastComparison;
1101 }
1102 if (isSetState()) {
1103 lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.state, typedOther.state);
1104 if (lastComparison != 0) {
1105 return lastComparison;
1106 }
1107 }
1108 lastComparison = Boolean.valueOf(isSetExtent()).compareTo(typedOther.isSetExtent());
1109 if (lastComparison != 0) {
1110 return lastComparison;
1111 }
1112 if (isSetExtent()) {
1113 lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.extent, typedOther.extent);
1114 if (lastComparison != 0) {
1115 return lastComparison;
1116 }
1117 }
1118 lastComparison = Boolean.valueOf(isSetColumns()).compareTo(typedOther.isSetColumns());
1119 if (lastComparison != 0) {
1120 return lastComparison;
1121 }
1122 if (isSetColumns()) {
1123 lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.columns, typedOther.columns);
1124 if (lastComparison != 0) {
1125 return lastComparison;
1126 }
1127 }
1128 lastComparison = Boolean.valueOf(isSetSsiList()).compareTo(typedOther.isSetSsiList());
1129 if (lastComparison != 0) {
1130 return lastComparison;
1131 }
1132 if (isSetSsiList()) {
1133 lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.ssiList, typedOther.ssiList);
1134 if (lastComparison != 0) {
1135 return lastComparison;
1136 }
1137 }
1138 lastComparison = Boolean.valueOf(isSetSsio()).compareTo(typedOther.isSetSsio());
1139 if (lastComparison != 0) {
1140 return lastComparison;
1141 }
1142 if (isSetSsio()) {
1143 lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.ssio, typedOther.ssio);
1144 if (lastComparison != 0) {
1145 return lastComparison;
1146 }
1147 }
1148 lastComparison = Boolean.valueOf(isSetAuthorizations()).compareTo(typedOther.isSetAuthorizations());
1149 if (lastComparison != 0) {
1150 return lastComparison;
1151 }
1152 if (isSetAuthorizations()) {
1153 lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.authorizations, typedOther.authorizations);
1154 if (lastComparison != 0) {
1155 return lastComparison;
1156 }
1157 }
1158 return 0;
1159 }
1160
1161 public _Fields fieldForId(int fieldId) {
1162 return _Fields.findByThriftId(fieldId);
1163 }
1164
1165 public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException {
1166 schemes.get(iprot.getScheme()).getScheme().read(iprot, this);
1167 }
1168
1169 public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
1170 schemes.get(oprot.getScheme()).getScheme().write(oprot, this);
1171 }
1172
1173 @Override
1174 public String toString() {
1175 StringBuilder sb = new StringBuilder("ActiveScan(");
1176 boolean first = true;
1177
1178 sb.append("client:");
1179 if (this.client == null) {
1180 sb.append("null");
1181 } else {
1182 sb.append(this.client);
1183 }
1184 first = false;
1185 if (!first) sb.append(", ");
1186 sb.append("user:");
1187 if (this.user == null) {
1188 sb.append("null");
1189 } else {
1190 sb.append(this.user);
1191 }
1192 first = false;
1193 if (!first) sb.append(", ");
1194 sb.append("tableId:");
1195 if (this.tableId == null) {
1196 sb.append("null");
1197 } else {
1198 sb.append(this.tableId);
1199 }
1200 first = false;
1201 if (!first) sb.append(", ");
1202 sb.append("age:");
1203 sb.append(this.age);
1204 first = false;
1205 if (!first) sb.append(", ");
1206 sb.append("idleTime:");
1207 sb.append(this.idleTime);
1208 first = false;
1209 if (!first) sb.append(", ");
1210 sb.append("type:");
1211 if (this.type == null) {
1212 sb.append("null");
1213 } else {
1214 sb.append(this.type);
1215 }
1216 first = false;
1217 if (!first) sb.append(", ");
1218 sb.append("state:");
1219 if (this.state == null) {
1220 sb.append("null");
1221 } else {
1222 sb.append(this.state);
1223 }
1224 first = false;
1225 if (!first) sb.append(", ");
1226 sb.append("extent:");
1227 if (this.extent == null) {
1228 sb.append("null");
1229 } else {
1230 sb.append(this.extent);
1231 }
1232 first = false;
1233 if (!first) sb.append(", ");
1234 sb.append("columns:");
1235 if (this.columns == null) {
1236 sb.append("null");
1237 } else {
1238 sb.append(this.columns);
1239 }
1240 first = false;
1241 if (!first) sb.append(", ");
1242 sb.append("ssiList:");
1243 if (this.ssiList == null) {
1244 sb.append("null");
1245 } else {
1246 sb.append(this.ssiList);
1247 }
1248 first = false;
1249 if (!first) sb.append(", ");
1250 sb.append("ssio:");
1251 if (this.ssio == null) {
1252 sb.append("null");
1253 } else {
1254 sb.append(this.ssio);
1255 }
1256 first = false;
1257 if (!first) sb.append(", ");
1258 sb.append("authorizations:");
1259 if (this.authorizations == null) {
1260 sb.append("null");
1261 } else {
1262 sb.append(this.authorizations);
1263 }
1264 first = false;
1265 sb.append(")");
1266 return sb.toString();
1267 }
1268
1269 public void validate() throws org.apache.thrift.TException {
1270
1271
1272 if (extent != null) {
1273 extent.validate();
1274 }
1275 }
1276
1277 private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
1278 try {
1279 write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out)));
1280 } catch (org.apache.thrift.TException te) {
1281 throw new java.io.IOException(te);
1282 }
1283 }
1284
1285 private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
1286 try {
1287
1288 __isset_bitfield = 0;
1289 read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
1290 } catch (org.apache.thrift.TException te) {
1291 throw new java.io.IOException(te);
1292 }
1293 }
1294
1295 private static class ActiveScanStandardSchemeFactory implements SchemeFactory {
1296 public ActiveScanStandardScheme getScheme() {
1297 return new ActiveScanStandardScheme();
1298 }
1299 }
1300
1301 private static class ActiveScanStandardScheme extends StandardScheme<ActiveScan> {
1302
1303 public void read(org.apache.thrift.protocol.TProtocol iprot, ActiveScan struct) throws org.apache.thrift.TException {
1304 org.apache.thrift.protocol.TField schemeField;
1305 iprot.readStructBegin();
1306 while (true)
1307 {
1308 schemeField = iprot.readFieldBegin();
1309 if (schemeField.type == org.apache.thrift.protocol.TType.STOP) {
1310 break;
1311 }
1312 switch (schemeField.id) {
1313 case 2:
1314 if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
1315 struct.client = iprot.readString();
1316 struct.setClientIsSet(true);
1317 } else {
1318 org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
1319 }
1320 break;
1321 case 3:
1322 if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
1323 struct.user = iprot.readString();
1324 struct.setUserIsSet(true);
1325 } else {
1326 org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
1327 }
1328 break;
1329 case 4:
1330 if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
1331 struct.tableId = iprot.readString();
1332 struct.setTableIdIsSet(true);
1333 } else {
1334 org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
1335 }
1336 break;
1337 case 5:
1338 if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
1339 struct.age = iprot.readI64();
1340 struct.setAgeIsSet(true);
1341 } else {
1342 org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
1343 }
1344 break;
1345 case 6:
1346 if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
1347 struct.idleTime = iprot.readI64();
1348 struct.setIdleTimeIsSet(true);
1349 } else {
1350 org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
1351 }
1352 break;
1353 case 7:
1354 if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
1355 struct.type = ScanType.findByValue(iprot.readI32());
1356 struct.setTypeIsSet(true);
1357 } else {
1358 org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
1359 }
1360 break;
1361 case 8:
1362 if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
1363 struct.state = ScanState.findByValue(iprot.readI32());
1364 struct.setStateIsSet(true);
1365 } else {
1366 org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
1367 }
1368 break;
1369 case 9:
1370 if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
1371 struct.extent = new org.apache.accumulo.core.data.thrift.TKeyExtent();
1372 struct.extent.read(iprot);
1373 struct.setExtentIsSet(true);
1374 } else {
1375 org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
1376 }
1377 break;
1378 case 10:
1379 if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
1380 {
1381 org.apache.thrift.protocol.TList _list8 = iprot.readListBegin();
1382 struct.columns = new ArrayList<org.apache.accumulo.core.data.thrift.TColumn>(_list8.size);
1383 for (int _i9 = 0; _i9 < _list8.size; ++_i9)
1384 {
1385 org.apache.accumulo.core.data.thrift.TColumn _elem10;
1386 _elem10 = new org.apache.accumulo.core.data.thrift.TColumn();
1387 _elem10.read(iprot);
1388 struct.columns.add(_elem10);
1389 }
1390 iprot.readListEnd();
1391 }
1392 struct.setColumnsIsSet(true);
1393 } else {
1394 org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
1395 }
1396 break;
1397 case 11:
1398 if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
1399 {
1400 org.apache.thrift.protocol.TList _list11 = iprot.readListBegin();
1401 struct.ssiList = new ArrayList<org.apache.accumulo.core.data.thrift.IterInfo>(_list11.size);
1402 for (int _i12 = 0; _i12 < _list11.size; ++_i12)
1403 {
1404 org.apache.accumulo.core.data.thrift.IterInfo _elem13;
1405 _elem13 = new org.apache.accumulo.core.data.thrift.IterInfo();
1406 _elem13.read(iprot);
1407 struct.ssiList.add(_elem13);
1408 }
1409 iprot.readListEnd();
1410 }
1411 struct.setSsiListIsSet(true);
1412 } else {
1413 org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
1414 }
1415 break;
1416 case 12:
1417 if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
1418 {
1419 org.apache.thrift.protocol.TMap _map14 = iprot.readMapBegin();
1420 struct.ssio = new HashMap<String,Map<String,String>>(2*_map14.size);
1421 for (int _i15 = 0; _i15 < _map14.size; ++_i15)
1422 {
1423 String _key16;
1424 Map<String,String> _val17;
1425 _key16 = iprot.readString();
1426 {
1427 org.apache.thrift.protocol.TMap _map18 = iprot.readMapBegin();
1428 _val17 = new HashMap<String,String>(2*_map18.size);
1429 for (int _i19 = 0; _i19 < _map18.size; ++_i19)
1430 {
1431 String _key20;
1432 String _val21;
1433 _key20 = iprot.readString();
1434 _val21 = iprot.readString();
1435 _val17.put(_key20, _val21);
1436 }
1437 iprot.readMapEnd();
1438 }
1439 struct.ssio.put(_key16, _val17);
1440 }
1441 iprot.readMapEnd();
1442 }
1443 struct.setSsioIsSet(true);
1444 } else {
1445 org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
1446 }
1447 break;
1448 case 13:
1449 if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
1450 {
1451 org.apache.thrift.protocol.TList _list22 = iprot.readListBegin();
1452 struct.authorizations = new ArrayList<ByteBuffer>(_list22.size);
1453 for (int _i23 = 0; _i23 < _list22.size; ++_i23)
1454 {
1455 ByteBuffer _elem24;
1456 _elem24 = iprot.readBinary();
1457 struct.authorizations.add(_elem24);
1458 }
1459 iprot.readListEnd();
1460 }
1461 struct.setAuthorizationsIsSet(true);
1462 } else {
1463 org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
1464 }
1465 break;
1466 default:
1467 org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
1468 }
1469 iprot.readFieldEnd();
1470 }
1471 iprot.readStructEnd();
1472
1473
1474 struct.validate();
1475 }
1476
1477 public void write(org.apache.thrift.protocol.TProtocol oprot, ActiveScan struct) throws org.apache.thrift.TException {
1478 struct.validate();
1479
1480 oprot.writeStructBegin(STRUCT_DESC);
1481 if (struct.client != null) {
1482 oprot.writeFieldBegin(CLIENT_FIELD_DESC);
1483 oprot.writeString(struct.client);
1484 oprot.writeFieldEnd();
1485 }
1486 if (struct.user != null) {
1487 oprot.writeFieldBegin(USER_FIELD_DESC);
1488 oprot.writeString(struct.user);
1489 oprot.writeFieldEnd();
1490 }
1491 if (struct.tableId != null) {
1492 oprot.writeFieldBegin(TABLE_ID_FIELD_DESC);
1493 oprot.writeString(struct.tableId);
1494 oprot.writeFieldEnd();
1495 }
1496 oprot.writeFieldBegin(AGE_FIELD_DESC);
1497 oprot.writeI64(struct.age);
1498 oprot.writeFieldEnd();
1499 oprot.writeFieldBegin(IDLE_TIME_FIELD_DESC);
1500 oprot.writeI64(struct.idleTime);
1501 oprot.writeFieldEnd();
1502 if (struct.type != null) {
1503 oprot.writeFieldBegin(TYPE_FIELD_DESC);
1504 oprot.writeI32(struct.type.getValue());
1505 oprot.writeFieldEnd();
1506 }
1507 if (struct.state != null) {
1508 oprot.writeFieldBegin(STATE_FIELD_DESC);
1509 oprot.writeI32(struct.state.getValue());
1510 oprot.writeFieldEnd();
1511 }
1512 if (struct.extent != null) {
1513 oprot.writeFieldBegin(EXTENT_FIELD_DESC);
1514 struct.extent.write(oprot);
1515 oprot.writeFieldEnd();
1516 }
1517 if (struct.columns != null) {
1518 oprot.writeFieldBegin(COLUMNS_FIELD_DESC);
1519 {
1520 oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.columns.size()));
1521 for (org.apache.accumulo.core.data.thrift.TColumn _iter25 : struct.columns)
1522 {
1523 _iter25.write(oprot);
1524 }
1525 oprot.writeListEnd();
1526 }
1527 oprot.writeFieldEnd();
1528 }
1529 if (struct.ssiList != null) {
1530 oprot.writeFieldBegin(SSI_LIST_FIELD_DESC);
1531 {
1532 oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.ssiList.size()));
1533 for (org.apache.accumulo.core.data.thrift.IterInfo _iter26 : struct.ssiList)
1534 {
1535 _iter26.write(oprot);
1536 }
1537 oprot.writeListEnd();
1538 }
1539 oprot.writeFieldEnd();
1540 }
1541 if (struct.ssio != null) {
1542 oprot.writeFieldBegin(SSIO_FIELD_DESC);
1543 {
1544 oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.MAP, struct.ssio.size()));
1545 for (Map.Entry<String, Map<String,String>> _iter27 : struct.ssio.entrySet())
1546 {
1547 oprot.writeString(_iter27.getKey());
1548 {
1549 oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, _iter27.getValue().size()));
1550 for (Map.Entry<String, String> _iter28 : _iter27.getValue().entrySet())
1551 {
1552 oprot.writeString(_iter28.getKey());
1553 oprot.writeString(_iter28.getValue());
1554 }
1555 oprot.writeMapEnd();
1556 }
1557 }
1558 oprot.writeMapEnd();
1559 }
1560 oprot.writeFieldEnd();
1561 }
1562 if (struct.authorizations != null) {
1563 oprot.writeFieldBegin(AUTHORIZATIONS_FIELD_DESC);
1564 {
1565 oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.authorizations.size()));
1566 for (ByteBuffer _iter29 : struct.authorizations)
1567 {
1568 oprot.writeBinary(_iter29);
1569 }
1570 oprot.writeListEnd();
1571 }
1572 oprot.writeFieldEnd();
1573 }
1574 oprot.writeFieldStop();
1575 oprot.writeStructEnd();
1576 }
1577
1578 }
1579
1580 private static class ActiveScanTupleSchemeFactory implements SchemeFactory {
1581 public ActiveScanTupleScheme getScheme() {
1582 return new ActiveScanTupleScheme();
1583 }
1584 }
1585
1586 private static class ActiveScanTupleScheme extends TupleScheme<ActiveScan> {
1587
1588 @Override
1589 public void write(org.apache.thrift.protocol.TProtocol prot, ActiveScan struct) throws org.apache.thrift.TException {
1590 TTupleProtocol oprot = (TTupleProtocol) prot;
1591 BitSet optionals = new BitSet();
1592 if (struct.isSetClient()) {
1593 optionals.set(0);
1594 }
1595 if (struct.isSetUser()) {
1596 optionals.set(1);
1597 }
1598 if (struct.isSetTableId()) {
1599 optionals.set(2);
1600 }
1601 if (struct.isSetAge()) {
1602 optionals.set(3);
1603 }
1604 if (struct.isSetIdleTime()) {
1605 optionals.set(4);
1606 }
1607 if (struct.isSetType()) {
1608 optionals.set(5);
1609 }
1610 if (struct.isSetState()) {
1611 optionals.set(6);
1612 }
1613 if (struct.isSetExtent()) {
1614 optionals.set(7);
1615 }
1616 if (struct.isSetColumns()) {
1617 optionals.set(8);
1618 }
1619 if (struct.isSetSsiList()) {
1620 optionals.set(9);
1621 }
1622 if (struct.isSetSsio()) {
1623 optionals.set(10);
1624 }
1625 if (struct.isSetAuthorizations()) {
1626 optionals.set(11);
1627 }
1628 oprot.writeBitSet(optionals, 12);
1629 if (struct.isSetClient()) {
1630 oprot.writeString(struct.client);
1631 }
1632 if (struct.isSetUser()) {
1633 oprot.writeString(struct.user);
1634 }
1635 if (struct.isSetTableId()) {
1636 oprot.writeString(struct.tableId);
1637 }
1638 if (struct.isSetAge()) {
1639 oprot.writeI64(struct.age);
1640 }
1641 if (struct.isSetIdleTime()) {
1642 oprot.writeI64(struct.idleTime);
1643 }
1644 if (struct.isSetType()) {
1645 oprot.writeI32(struct.type.getValue());
1646 }
1647 if (struct.isSetState()) {
1648 oprot.writeI32(struct.state.getValue());
1649 }
1650 if (struct.isSetExtent()) {
1651 struct.extent.write(oprot);
1652 }
1653 if (struct.isSetColumns()) {
1654 {
1655 oprot.writeI32(struct.columns.size());
1656 for (org.apache.accumulo.core.data.thrift.TColumn _iter30 : struct.columns)
1657 {
1658 _iter30.write(oprot);
1659 }
1660 }
1661 }
1662 if (struct.isSetSsiList()) {
1663 {
1664 oprot.writeI32(struct.ssiList.size());
1665 for (org.apache.accumulo.core.data.thrift.IterInfo _iter31 : struct.ssiList)
1666 {
1667 _iter31.write(oprot);
1668 }
1669 }
1670 }
1671 if (struct.isSetSsio()) {
1672 {
1673 oprot.writeI32(struct.ssio.size());
1674 for (Map.Entry<String, Map<String,String>> _iter32 : struct.ssio.entrySet())
1675 {
1676 oprot.writeString(_iter32.getKey());
1677 {
1678 oprot.writeI32(_iter32.getValue().size());
1679 for (Map.Entry<String, String> _iter33 : _iter32.getValue().entrySet())
1680 {
1681 oprot.writeString(_iter33.getKey());
1682 oprot.writeString(_iter33.getValue());
1683 }
1684 }
1685 }
1686 }
1687 }
1688 if (struct.isSetAuthorizations()) {
1689 {
1690 oprot.writeI32(struct.authorizations.size());
1691 for (ByteBuffer _iter34 : struct.authorizations)
1692 {
1693 oprot.writeBinary(_iter34);
1694 }
1695 }
1696 }
1697 }
1698
1699 @Override
1700 public void read(org.apache.thrift.protocol.TProtocol prot, ActiveScan struct) throws org.apache.thrift.TException {
1701 TTupleProtocol iprot = (TTupleProtocol) prot;
1702 BitSet incoming = iprot.readBitSet(12);
1703 if (incoming.get(0)) {
1704 struct.client = iprot.readString();
1705 struct.setClientIsSet(true);
1706 }
1707 if (incoming.get(1)) {
1708 struct.user = iprot.readString();
1709 struct.setUserIsSet(true);
1710 }
1711 if (incoming.get(2)) {
1712 struct.tableId = iprot.readString();
1713 struct.setTableIdIsSet(true);
1714 }
1715 if (incoming.get(3)) {
1716 struct.age = iprot.readI64();
1717 struct.setAgeIsSet(true);
1718 }
1719 if (incoming.get(4)) {
1720 struct.idleTime = iprot.readI64();
1721 struct.setIdleTimeIsSet(true);
1722 }
1723 if (incoming.get(5)) {
1724 struct.type = ScanType.findByValue(iprot.readI32());
1725 struct.setTypeIsSet(true);
1726 }
1727 if (incoming.get(6)) {
1728 struct.state = ScanState.findByValue(iprot.readI32());
1729 struct.setStateIsSet(true);
1730 }
1731 if (incoming.get(7)) {
1732 struct.extent = new org.apache.accumulo.core.data.thrift.TKeyExtent();
1733 struct.extent.read(iprot);
1734 struct.setExtentIsSet(true);
1735 }
1736 if (incoming.get(8)) {
1737 {
1738 org.apache.thrift.protocol.TList _list35 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
1739 struct.columns = new ArrayList<org.apache.accumulo.core.data.thrift.TColumn>(_list35.size);
1740 for (int _i36 = 0; _i36 < _list35.size; ++_i36)
1741 {
1742 org.apache.accumulo.core.data.thrift.TColumn _elem37;
1743 _elem37 = new org.apache.accumulo.core.data.thrift.TColumn();
1744 _elem37.read(iprot);
1745 struct.columns.add(_elem37);
1746 }
1747 }
1748 struct.setColumnsIsSet(true);
1749 }
1750 if (incoming.get(9)) {
1751 {
1752 org.apache.thrift.protocol.TList _list38 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
1753 struct.ssiList = new ArrayList<org.apache.accumulo.core.data.thrift.IterInfo>(_list38.size);
1754 for (int _i39 = 0; _i39 < _list38.size; ++_i39)
1755 {
1756 org.apache.accumulo.core.data.thrift.IterInfo _elem40;
1757 _elem40 = new org.apache.accumulo.core.data.thrift.IterInfo();
1758 _elem40.read(iprot);
1759 struct.ssiList.add(_elem40);
1760 }
1761 }
1762 struct.setSsiListIsSet(true);
1763 }
1764 if (incoming.get(10)) {
1765 {
1766 org.apache.thrift.protocol.TMap _map41 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.MAP, iprot.readI32());
1767 struct.ssio = new HashMap<String,Map<String,String>>(2*_map41.size);
1768 for (int _i42 = 0; _i42 < _map41.size; ++_i42)
1769 {
1770 String _key43;
1771 Map<String,String> _val44;
1772 _key43 = iprot.readString();
1773 {
1774 org.apache.thrift.protocol.TMap _map45 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, iprot.readI32());
1775 _val44 = new HashMap<String,String>(2*_map45.size);
1776 for (int _i46 = 0; _i46 < _map45.size; ++_i46)
1777 {
1778 String _key47;
1779 String _val48;
1780 _key47 = iprot.readString();
1781 _val48 = iprot.readString();
1782 _val44.put(_key47, _val48);
1783 }
1784 }
1785 struct.ssio.put(_key43, _val44);
1786 }
1787 }
1788 struct.setSsioIsSet(true);
1789 }
1790 if (incoming.get(11)) {
1791 {
1792 org.apache.thrift.protocol.TList _list49 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
1793 struct.authorizations = new ArrayList<ByteBuffer>(_list49.size);
1794 for (int _i50 = 0; _i50 < _list49.size; ++_i50)
1795 {
1796 ByteBuffer _elem51;
1797 _elem51 = iprot.readBinary();
1798 struct.authorizations.add(_elem51);
1799 }
1800 }
1801 struct.setAuthorizationsIsSet(true);
1802 }
1803 }
1804 }
1805
1806 }
1807