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