http://git-wip-us.apache.org/repos/asf/storm/blob/1fd1e17f/storm-client/src/jvm/org/apache/storm/generated/OwnerResourceSummary.java ---------------------------------------------------------------------- diff --git a/storm-client/src/jvm/org/apache/storm/generated/OwnerResourceSummary.java b/storm-client/src/jvm/org/apache/storm/generated/OwnerResourceSummary.java index be1c687..ee273d3 100644 --- a/storm-client/src/jvm/org/apache/storm/generated/OwnerResourceSummary.java +++ b/storm-client/src/jvm/org/apache/storm/generated/OwnerResourceSummary.java @@ -16,42 +16,15 @@ * limitations under the License. */ /** - * Autogenerated by Thrift Compiler (0.9.3) + * Autogenerated by Thrift Compiler (0.11.0) * * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING * @generated */ package org.apache.storm.generated; -import org.apache.thrift.scheme.IScheme; -import org.apache.thrift.scheme.SchemeFactory; -import org.apache.thrift.scheme.StandardScheme; - -import org.apache.thrift.scheme.TupleScheme; -import org.apache.thrift.protocol.TTupleProtocol; -import org.apache.thrift.protocol.TProtocolException; -import org.apache.thrift.EncodingUtils; -import org.apache.thrift.TException; -import org.apache.thrift.async.AsyncMethodCallback; -import org.apache.thrift.server.AbstractNonblockingServer.*; -import java.util.List; -import java.util.ArrayList; -import java.util.Map; -import java.util.HashMap; -import java.util.EnumMap; -import java.util.Set; -import java.util.HashSet; -import java.util.EnumSet; -import java.util.Collections; -import java.util.BitSet; -import java.nio.ByteBuffer; -import java.util.Arrays; -import javax.annotation.Generated; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - -@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) -@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)") +@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"}) [email protected](value = "Autogenerated by Thrift Compiler (0.11.0)") public class OwnerResourceSummary implements org.apache.thrift.TBase<OwnerResourceSummary, OwnerResourceSummary._Fields>, java.io.Serializable, Cloneable, Comparable<OwnerResourceSummary> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("OwnerResourceSummary"); @@ -74,13 +47,10 @@ public class OwnerResourceSummary implements org.apache.thrift.TBase<OwnerResour private static final org.apache.thrift.protocol.TField ASSIGNED_ON_HEAP_MEMORY_FIELD_DESC = new org.apache.thrift.protocol.TField("assigned_on_heap_memory", org.apache.thrift.protocol.TType.DOUBLE, (short)17); private static final org.apache.thrift.protocol.TField ASSIGNED_OFF_HEAP_MEMORY_FIELD_DESC = new org.apache.thrift.protocol.TField("assigned_off_heap_memory", org.apache.thrift.protocol.TType.DOUBLE, (short)18); - private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); - static { - schemes.put(StandardScheme.class, new OwnerResourceSummaryStandardSchemeFactory()); - schemes.put(TupleScheme.class, new OwnerResourceSummaryTupleSchemeFactory()); - } + private static final org.apache.thrift.scheme.SchemeFactory STANDARD_SCHEME_FACTORY = new OwnerResourceSummaryStandardSchemeFactory(); + private static final org.apache.thrift.scheme.SchemeFactory TUPLE_SCHEME_FACTORY = new OwnerResourceSummaryTupleSchemeFactory(); - private String owner; // required + private java.lang.String owner; // required private int total_topologies; // optional private int total_executors; // optional private int total_workers; // optional @@ -120,10 +90,10 @@ public class OwnerResourceSummary implements org.apache.thrift.TBase<OwnerResour ASSIGNED_ON_HEAP_MEMORY((short)17, "assigned_on_heap_memory"), ASSIGNED_OFF_HEAP_MEMORY((short)18, "assigned_off_heap_memory"); - private static final Map<String, _Fields> byName = new HashMap<String, _Fields>(); + private static final java.util.Map<java.lang.String, _Fields> byName = new java.util.HashMap<java.lang.String, _Fields>(); static { - for (_Fields field : EnumSet.allOf(_Fields.class)) { + for (_Fields field : java.util.EnumSet.allOf(_Fields.class)) { byName.put(field.getFieldName(), field); } } @@ -180,21 +150,21 @@ public class OwnerResourceSummary implements org.apache.thrift.TBase<OwnerResour */ public static _Fields findByThriftIdOrThrow(int fieldId) { _Fields fields = findByThriftId(fieldId); - if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!"); + if (fields == null) throw new java.lang.IllegalArgumentException("Field " + fieldId + " doesn't exist!"); return fields; } /** * Find the _Fields constant that matches name, or null if its not found. */ - public static _Fields findByName(String name) { + public static _Fields findByName(java.lang.String name) { return byName.get(name); } private final short _thriftId; - private final String _fieldName; + private final java.lang.String _fieldName; - _Fields(short thriftId, String fieldName) { + _Fields(short thriftId, java.lang.String fieldName) { _thriftId = thriftId; _fieldName = fieldName; } @@ -203,7 +173,7 @@ public class OwnerResourceSummary implements org.apache.thrift.TBase<OwnerResour return _thriftId; } - public String getFieldName() { + public java.lang.String getFieldName() { return _fieldName; } } @@ -228,9 +198,9 @@ public class OwnerResourceSummary implements org.apache.thrift.TBase<OwnerResour private static final int __ASSIGNED_OFF_HEAP_MEMORY_ISSET_ID = 16; private int __isset_bitfield = 0; private static final _Fields optionals[] = {_Fields.TOTAL_TOPOLOGIES,_Fields.TOTAL_EXECUTORS,_Fields.TOTAL_WORKERS,_Fields.MEMORY_USAGE,_Fields.CPU_USAGE,_Fields.MEMORY_GUARANTEE,_Fields.CPU_GUARANTEE,_Fields.MEMORY_GUARANTEE_REMAINING,_Fields.CPU_GUARANTEE_REMAINING,_Fields.ISOLATED_NODE_GUARANTEE,_Fields.TOTAL_TASKS,_Fields.REQUESTED_ON_HEAP_MEMORY,_Fields.REQUESTED_OFF_HEAP_MEMORY,_Fields.REQUESTED_TOTAL_MEMORY,_Fields.REQUESTED_CPU,_Fields.ASSIGNED_ON_HEAP_MEMORY,_Fields.ASSIGNED_OFF_HEAP_MEMORY}; - public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap; + public static final java.util.Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap; static { - Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class); + java.util.Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new java.util.EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class); tmpMap.put(_Fields.OWNER, new org.apache.thrift.meta_data.FieldMetaData("owner", org.apache.thrift.TFieldRequirementType.REQUIRED, new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); tmpMap.put(_Fields.TOTAL_TOPOLOGIES, new org.apache.thrift.meta_data.FieldMetaData("total_topologies", org.apache.thrift.TFieldRequirementType.OPTIONAL, @@ -267,7 +237,7 @@ public class OwnerResourceSummary implements org.apache.thrift.TBase<OwnerResour new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.DOUBLE))); tmpMap.put(_Fields.ASSIGNED_OFF_HEAP_MEMORY, new org.apache.thrift.meta_data.FieldMetaData("assigned_off_heap_memory", org.apache.thrift.TFieldRequirementType.OPTIONAL, new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.DOUBLE))); - metaDataMap = Collections.unmodifiableMap(tmpMap); + metaDataMap = java.util.Collections.unmodifiableMap(tmpMap); org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(OwnerResourceSummary.class, metaDataMap); } @@ -275,7 +245,7 @@ public class OwnerResourceSummary implements org.apache.thrift.TBase<OwnerResour } public OwnerResourceSummary( - String owner) + java.lang.String owner) { this(); this.owner = owner; @@ -351,11 +321,11 @@ public class OwnerResourceSummary implements org.apache.thrift.TBase<OwnerResour this.assigned_off_heap_memory = 0.0; } - public String get_owner() { + public java.lang.String get_owner() { return this.owner; } - public void set_owner(String owner) { + public void set_owner(java.lang.String owner) { this.owner = owner; } @@ -384,16 +354,16 @@ public class OwnerResourceSummary implements org.apache.thrift.TBase<OwnerResour } public void unset_total_topologies() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __TOTAL_TOPOLOGIES_ISSET_ID); + __isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __TOTAL_TOPOLOGIES_ISSET_ID); } /** Returns true if field total_topologies is set (has been assigned a value) and false otherwise */ public boolean is_set_total_topologies() { - return EncodingUtils.testBit(__isset_bitfield, __TOTAL_TOPOLOGIES_ISSET_ID); + return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __TOTAL_TOPOLOGIES_ISSET_ID); } public void set_total_topologies_isSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __TOTAL_TOPOLOGIES_ISSET_ID, value); + __isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __TOTAL_TOPOLOGIES_ISSET_ID, value); } public int get_total_executors() { @@ -406,16 +376,16 @@ public class OwnerResourceSummary implements org.apache.thrift.TBase<OwnerResour } public void unset_total_executors() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __TOTAL_EXECUTORS_ISSET_ID); + __isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __TOTAL_EXECUTORS_ISSET_ID); } /** Returns true if field total_executors is set (has been assigned a value) and false otherwise */ public boolean is_set_total_executors() { - return EncodingUtils.testBit(__isset_bitfield, __TOTAL_EXECUTORS_ISSET_ID); + return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __TOTAL_EXECUTORS_ISSET_ID); } public void set_total_executors_isSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __TOTAL_EXECUTORS_ISSET_ID, value); + __isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __TOTAL_EXECUTORS_ISSET_ID, value); } public int get_total_workers() { @@ -428,16 +398,16 @@ public class OwnerResourceSummary implements org.apache.thrift.TBase<OwnerResour } public void unset_total_workers() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __TOTAL_WORKERS_ISSET_ID); + __isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __TOTAL_WORKERS_ISSET_ID); } /** Returns true if field total_workers is set (has been assigned a value) and false otherwise */ public boolean is_set_total_workers() { - return EncodingUtils.testBit(__isset_bitfield, __TOTAL_WORKERS_ISSET_ID); + return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __TOTAL_WORKERS_ISSET_ID); } public void set_total_workers_isSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __TOTAL_WORKERS_ISSET_ID, value); + __isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __TOTAL_WORKERS_ISSET_ID, value); } public double get_memory_usage() { @@ -450,16 +420,16 @@ public class OwnerResourceSummary implements org.apache.thrift.TBase<OwnerResour } public void unset_memory_usage() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __MEMORY_USAGE_ISSET_ID); + __isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __MEMORY_USAGE_ISSET_ID); } /** Returns true if field memory_usage is set (has been assigned a value) and false otherwise */ public boolean is_set_memory_usage() { - return EncodingUtils.testBit(__isset_bitfield, __MEMORY_USAGE_ISSET_ID); + return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __MEMORY_USAGE_ISSET_ID); } public void set_memory_usage_isSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __MEMORY_USAGE_ISSET_ID, value); + __isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __MEMORY_USAGE_ISSET_ID, value); } public double get_cpu_usage() { @@ -472,16 +442,16 @@ public class OwnerResourceSummary implements org.apache.thrift.TBase<OwnerResour } public void unset_cpu_usage() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __CPU_USAGE_ISSET_ID); + __isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __CPU_USAGE_ISSET_ID); } /** Returns true if field cpu_usage is set (has been assigned a value) and false otherwise */ public boolean is_set_cpu_usage() { - return EncodingUtils.testBit(__isset_bitfield, __CPU_USAGE_ISSET_ID); + return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __CPU_USAGE_ISSET_ID); } public void set_cpu_usage_isSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __CPU_USAGE_ISSET_ID, value); + __isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __CPU_USAGE_ISSET_ID, value); } public double get_memory_guarantee() { @@ -494,16 +464,16 @@ public class OwnerResourceSummary implements org.apache.thrift.TBase<OwnerResour } public void unset_memory_guarantee() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __MEMORY_GUARANTEE_ISSET_ID); + __isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __MEMORY_GUARANTEE_ISSET_ID); } /** Returns true if field memory_guarantee is set (has been assigned a value) and false otherwise */ public boolean is_set_memory_guarantee() { - return EncodingUtils.testBit(__isset_bitfield, __MEMORY_GUARANTEE_ISSET_ID); + return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __MEMORY_GUARANTEE_ISSET_ID); } public void set_memory_guarantee_isSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __MEMORY_GUARANTEE_ISSET_ID, value); + __isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __MEMORY_GUARANTEE_ISSET_ID, value); } public double get_cpu_guarantee() { @@ -516,16 +486,16 @@ public class OwnerResourceSummary implements org.apache.thrift.TBase<OwnerResour } public void unset_cpu_guarantee() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __CPU_GUARANTEE_ISSET_ID); + __isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __CPU_GUARANTEE_ISSET_ID); } /** Returns true if field cpu_guarantee is set (has been assigned a value) and false otherwise */ public boolean is_set_cpu_guarantee() { - return EncodingUtils.testBit(__isset_bitfield, __CPU_GUARANTEE_ISSET_ID); + return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __CPU_GUARANTEE_ISSET_ID); } public void set_cpu_guarantee_isSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __CPU_GUARANTEE_ISSET_ID, value); + __isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __CPU_GUARANTEE_ISSET_ID, value); } public double get_memory_guarantee_remaining() { @@ -538,16 +508,16 @@ public class OwnerResourceSummary implements org.apache.thrift.TBase<OwnerResour } public void unset_memory_guarantee_remaining() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __MEMORY_GUARANTEE_REMAINING_ISSET_ID); + __isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __MEMORY_GUARANTEE_REMAINING_ISSET_ID); } /** Returns true if field memory_guarantee_remaining is set (has been assigned a value) and false otherwise */ public boolean is_set_memory_guarantee_remaining() { - return EncodingUtils.testBit(__isset_bitfield, __MEMORY_GUARANTEE_REMAINING_ISSET_ID); + return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __MEMORY_GUARANTEE_REMAINING_ISSET_ID); } public void set_memory_guarantee_remaining_isSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __MEMORY_GUARANTEE_REMAINING_ISSET_ID, value); + __isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __MEMORY_GUARANTEE_REMAINING_ISSET_ID, value); } public double get_cpu_guarantee_remaining() { @@ -560,16 +530,16 @@ public class OwnerResourceSummary implements org.apache.thrift.TBase<OwnerResour } public void unset_cpu_guarantee_remaining() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __CPU_GUARANTEE_REMAINING_ISSET_ID); + __isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __CPU_GUARANTEE_REMAINING_ISSET_ID); } /** Returns true if field cpu_guarantee_remaining is set (has been assigned a value) and false otherwise */ public boolean is_set_cpu_guarantee_remaining() { - return EncodingUtils.testBit(__isset_bitfield, __CPU_GUARANTEE_REMAINING_ISSET_ID); + return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __CPU_GUARANTEE_REMAINING_ISSET_ID); } public void set_cpu_guarantee_remaining_isSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __CPU_GUARANTEE_REMAINING_ISSET_ID, value); + __isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __CPU_GUARANTEE_REMAINING_ISSET_ID, value); } public int get_isolated_node_guarantee() { @@ -582,16 +552,16 @@ public class OwnerResourceSummary implements org.apache.thrift.TBase<OwnerResour } public void unset_isolated_node_guarantee() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __ISOLATED_NODE_GUARANTEE_ISSET_ID); + __isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __ISOLATED_NODE_GUARANTEE_ISSET_ID); } /** Returns true if field isolated_node_guarantee is set (has been assigned a value) and false otherwise */ public boolean is_set_isolated_node_guarantee() { - return EncodingUtils.testBit(__isset_bitfield, __ISOLATED_NODE_GUARANTEE_ISSET_ID); + return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __ISOLATED_NODE_GUARANTEE_ISSET_ID); } public void set_isolated_node_guarantee_isSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __ISOLATED_NODE_GUARANTEE_ISSET_ID, value); + __isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __ISOLATED_NODE_GUARANTEE_ISSET_ID, value); } public int get_total_tasks() { @@ -604,16 +574,16 @@ public class OwnerResourceSummary implements org.apache.thrift.TBase<OwnerResour } public void unset_total_tasks() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __TOTAL_TASKS_ISSET_ID); + __isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __TOTAL_TASKS_ISSET_ID); } /** Returns true if field total_tasks is set (has been assigned a value) and false otherwise */ public boolean is_set_total_tasks() { - return EncodingUtils.testBit(__isset_bitfield, __TOTAL_TASKS_ISSET_ID); + return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __TOTAL_TASKS_ISSET_ID); } public void set_total_tasks_isSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __TOTAL_TASKS_ISSET_ID, value); + __isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __TOTAL_TASKS_ISSET_ID, value); } public double get_requested_on_heap_memory() { @@ -626,16 +596,16 @@ public class OwnerResourceSummary implements org.apache.thrift.TBase<OwnerResour } public void unset_requested_on_heap_memory() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __REQUESTED_ON_HEAP_MEMORY_ISSET_ID); + __isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __REQUESTED_ON_HEAP_MEMORY_ISSET_ID); } /** Returns true if field requested_on_heap_memory is set (has been assigned a value) and false otherwise */ public boolean is_set_requested_on_heap_memory() { - return EncodingUtils.testBit(__isset_bitfield, __REQUESTED_ON_HEAP_MEMORY_ISSET_ID); + return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __REQUESTED_ON_HEAP_MEMORY_ISSET_ID); } public void set_requested_on_heap_memory_isSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __REQUESTED_ON_HEAP_MEMORY_ISSET_ID, value); + __isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __REQUESTED_ON_HEAP_MEMORY_ISSET_ID, value); } public double get_requested_off_heap_memory() { @@ -648,16 +618,16 @@ public class OwnerResourceSummary implements org.apache.thrift.TBase<OwnerResour } public void unset_requested_off_heap_memory() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __REQUESTED_OFF_HEAP_MEMORY_ISSET_ID); + __isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __REQUESTED_OFF_HEAP_MEMORY_ISSET_ID); } /** Returns true if field requested_off_heap_memory is set (has been assigned a value) and false otherwise */ public boolean is_set_requested_off_heap_memory() { - return EncodingUtils.testBit(__isset_bitfield, __REQUESTED_OFF_HEAP_MEMORY_ISSET_ID); + return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __REQUESTED_OFF_HEAP_MEMORY_ISSET_ID); } public void set_requested_off_heap_memory_isSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __REQUESTED_OFF_HEAP_MEMORY_ISSET_ID, value); + __isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __REQUESTED_OFF_HEAP_MEMORY_ISSET_ID, value); } public double get_requested_total_memory() { @@ -670,16 +640,16 @@ public class OwnerResourceSummary implements org.apache.thrift.TBase<OwnerResour } public void unset_requested_total_memory() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __REQUESTED_TOTAL_MEMORY_ISSET_ID); + __isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __REQUESTED_TOTAL_MEMORY_ISSET_ID); } /** Returns true if field requested_total_memory is set (has been assigned a value) and false otherwise */ public boolean is_set_requested_total_memory() { - return EncodingUtils.testBit(__isset_bitfield, __REQUESTED_TOTAL_MEMORY_ISSET_ID); + return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __REQUESTED_TOTAL_MEMORY_ISSET_ID); } public void set_requested_total_memory_isSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __REQUESTED_TOTAL_MEMORY_ISSET_ID, value); + __isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __REQUESTED_TOTAL_MEMORY_ISSET_ID, value); } public double get_requested_cpu() { @@ -692,16 +662,16 @@ public class OwnerResourceSummary implements org.apache.thrift.TBase<OwnerResour } public void unset_requested_cpu() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __REQUESTED_CPU_ISSET_ID); + __isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __REQUESTED_CPU_ISSET_ID); } /** Returns true if field requested_cpu is set (has been assigned a value) and false otherwise */ public boolean is_set_requested_cpu() { - return EncodingUtils.testBit(__isset_bitfield, __REQUESTED_CPU_ISSET_ID); + return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __REQUESTED_CPU_ISSET_ID); } public void set_requested_cpu_isSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __REQUESTED_CPU_ISSET_ID, value); + __isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __REQUESTED_CPU_ISSET_ID, value); } public double get_assigned_on_heap_memory() { @@ -714,16 +684,16 @@ public class OwnerResourceSummary implements org.apache.thrift.TBase<OwnerResour } public void unset_assigned_on_heap_memory() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __ASSIGNED_ON_HEAP_MEMORY_ISSET_ID); + __isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __ASSIGNED_ON_HEAP_MEMORY_ISSET_ID); } /** Returns true if field assigned_on_heap_memory is set (has been assigned a value) and false otherwise */ public boolean is_set_assigned_on_heap_memory() { - return EncodingUtils.testBit(__isset_bitfield, __ASSIGNED_ON_HEAP_MEMORY_ISSET_ID); + return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __ASSIGNED_ON_HEAP_MEMORY_ISSET_ID); } public void set_assigned_on_heap_memory_isSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __ASSIGNED_ON_HEAP_MEMORY_ISSET_ID, value); + __isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __ASSIGNED_ON_HEAP_MEMORY_ISSET_ID, value); } public double get_assigned_off_heap_memory() { @@ -736,25 +706,25 @@ public class OwnerResourceSummary implements org.apache.thrift.TBase<OwnerResour } public void unset_assigned_off_heap_memory() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __ASSIGNED_OFF_HEAP_MEMORY_ISSET_ID); + __isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __ASSIGNED_OFF_HEAP_MEMORY_ISSET_ID); } /** Returns true if field assigned_off_heap_memory is set (has been assigned a value) and false otherwise */ public boolean is_set_assigned_off_heap_memory() { - return EncodingUtils.testBit(__isset_bitfield, __ASSIGNED_OFF_HEAP_MEMORY_ISSET_ID); + return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __ASSIGNED_OFF_HEAP_MEMORY_ISSET_ID); } public void set_assigned_off_heap_memory_isSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __ASSIGNED_OFF_HEAP_MEMORY_ISSET_ID, value); + __isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __ASSIGNED_OFF_HEAP_MEMORY_ISSET_ID, value); } - public void setFieldValue(_Fields field, Object value) { + public void setFieldValue(_Fields field, java.lang.Object value) { switch (field) { case OWNER: if (value == null) { unset_owner(); } else { - set_owner((String)value); + set_owner((java.lang.String)value); } break; @@ -762,7 +732,7 @@ public class OwnerResourceSummary implements org.apache.thrift.TBase<OwnerResour if (value == null) { unset_total_topologies(); } else { - set_total_topologies((Integer)value); + set_total_topologies((java.lang.Integer)value); } break; @@ -770,7 +740,7 @@ public class OwnerResourceSummary implements org.apache.thrift.TBase<OwnerResour if (value == null) { unset_total_executors(); } else { - set_total_executors((Integer)value); + set_total_executors((java.lang.Integer)value); } break; @@ -778,7 +748,7 @@ public class OwnerResourceSummary implements org.apache.thrift.TBase<OwnerResour if (value == null) { unset_total_workers(); } else { - set_total_workers((Integer)value); + set_total_workers((java.lang.Integer)value); } break; @@ -786,7 +756,7 @@ public class OwnerResourceSummary implements org.apache.thrift.TBase<OwnerResour if (value == null) { unset_memory_usage(); } else { - set_memory_usage((Double)value); + set_memory_usage((java.lang.Double)value); } break; @@ -794,7 +764,7 @@ public class OwnerResourceSummary implements org.apache.thrift.TBase<OwnerResour if (value == null) { unset_cpu_usage(); } else { - set_cpu_usage((Double)value); + set_cpu_usage((java.lang.Double)value); } break; @@ -802,7 +772,7 @@ public class OwnerResourceSummary implements org.apache.thrift.TBase<OwnerResour if (value == null) { unset_memory_guarantee(); } else { - set_memory_guarantee((Double)value); + set_memory_guarantee((java.lang.Double)value); } break; @@ -810,7 +780,7 @@ public class OwnerResourceSummary implements org.apache.thrift.TBase<OwnerResour if (value == null) { unset_cpu_guarantee(); } else { - set_cpu_guarantee((Double)value); + set_cpu_guarantee((java.lang.Double)value); } break; @@ -818,7 +788,7 @@ public class OwnerResourceSummary implements org.apache.thrift.TBase<OwnerResour if (value == null) { unset_memory_guarantee_remaining(); } else { - set_memory_guarantee_remaining((Double)value); + set_memory_guarantee_remaining((java.lang.Double)value); } break; @@ -826,7 +796,7 @@ public class OwnerResourceSummary implements org.apache.thrift.TBase<OwnerResour if (value == null) { unset_cpu_guarantee_remaining(); } else { - set_cpu_guarantee_remaining((Double)value); + set_cpu_guarantee_remaining((java.lang.Double)value); } break; @@ -834,7 +804,7 @@ public class OwnerResourceSummary implements org.apache.thrift.TBase<OwnerResour if (value == null) { unset_isolated_node_guarantee(); } else { - set_isolated_node_guarantee((Integer)value); + set_isolated_node_guarantee((java.lang.Integer)value); } break; @@ -842,7 +812,7 @@ public class OwnerResourceSummary implements org.apache.thrift.TBase<OwnerResour if (value == null) { unset_total_tasks(); } else { - set_total_tasks((Integer)value); + set_total_tasks((java.lang.Integer)value); } break; @@ -850,7 +820,7 @@ public class OwnerResourceSummary implements org.apache.thrift.TBase<OwnerResour if (value == null) { unset_requested_on_heap_memory(); } else { - set_requested_on_heap_memory((Double)value); + set_requested_on_heap_memory((java.lang.Double)value); } break; @@ -858,7 +828,7 @@ public class OwnerResourceSummary implements org.apache.thrift.TBase<OwnerResour if (value == null) { unset_requested_off_heap_memory(); } else { - set_requested_off_heap_memory((Double)value); + set_requested_off_heap_memory((java.lang.Double)value); } break; @@ -866,7 +836,7 @@ public class OwnerResourceSummary implements org.apache.thrift.TBase<OwnerResour if (value == null) { unset_requested_total_memory(); } else { - set_requested_total_memory((Double)value); + set_requested_total_memory((java.lang.Double)value); } break; @@ -874,7 +844,7 @@ public class OwnerResourceSummary implements org.apache.thrift.TBase<OwnerResour if (value == null) { unset_requested_cpu(); } else { - set_requested_cpu((Double)value); + set_requested_cpu((java.lang.Double)value); } break; @@ -882,7 +852,7 @@ public class OwnerResourceSummary implements org.apache.thrift.TBase<OwnerResour if (value == null) { unset_assigned_on_heap_memory(); } else { - set_assigned_on_heap_memory((Double)value); + set_assigned_on_heap_memory((java.lang.Double)value); } break; @@ -890,14 +860,14 @@ public class OwnerResourceSummary implements org.apache.thrift.TBase<OwnerResour if (value == null) { unset_assigned_off_heap_memory(); } else { - set_assigned_off_heap_memory((Double)value); + set_assigned_off_heap_memory((java.lang.Double)value); } break; } } - public Object getFieldValue(_Fields field) { + public java.lang.Object getFieldValue(_Fields field) { switch (field) { case OWNER: return get_owner(); @@ -954,13 +924,13 @@ public class OwnerResourceSummary implements org.apache.thrift.TBase<OwnerResour return get_assigned_off_heap_memory(); } - throw new IllegalStateException(); + throw new java.lang.IllegalStateException(); } /** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */ public boolean isSet(_Fields field) { if (field == null) { - throw new IllegalArgumentException(); + throw new java.lang.IllegalArgumentException(); } switch (field) { @@ -1001,11 +971,11 @@ public class OwnerResourceSummary implements org.apache.thrift.TBase<OwnerResour case ASSIGNED_OFF_HEAP_MEMORY: return is_set_assigned_off_heap_memory(); } - throw new IllegalStateException(); + throw new java.lang.IllegalStateException(); } @Override - public boolean equals(Object that) { + public boolean equals(java.lang.Object that) { if (that == null) return false; if (that instanceof OwnerResourceSummary) @@ -1016,6 +986,8 @@ public class OwnerResourceSummary implements org.apache.thrift.TBase<OwnerResour public boolean equals(OwnerResourceSummary that) { if (that == null) return false; + if (this == that) + return true; boolean this_present_owner = true && this.is_set_owner(); boolean that_present_owner = true && that.is_set_owner(); @@ -1184,99 +1156,81 @@ public class OwnerResourceSummary implements org.apache.thrift.TBase<OwnerResour @Override public int hashCode() { - List<Object> list = new ArrayList<Object>(); - - boolean present_owner = true && (is_set_owner()); - list.add(present_owner); - if (present_owner) - list.add(owner); - - boolean present_total_topologies = true && (is_set_total_topologies()); - list.add(present_total_topologies); - if (present_total_topologies) - list.add(total_topologies); - - boolean present_total_executors = true && (is_set_total_executors()); - list.add(present_total_executors); - if (present_total_executors) - list.add(total_executors); - - boolean present_total_workers = true && (is_set_total_workers()); - list.add(present_total_workers); - if (present_total_workers) - list.add(total_workers); - - boolean present_memory_usage = true && (is_set_memory_usage()); - list.add(present_memory_usage); - if (present_memory_usage) - list.add(memory_usage); - - boolean present_cpu_usage = true && (is_set_cpu_usage()); - list.add(present_cpu_usage); - if (present_cpu_usage) - list.add(cpu_usage); - - boolean present_memory_guarantee = true && (is_set_memory_guarantee()); - list.add(present_memory_guarantee); - if (present_memory_guarantee) - list.add(memory_guarantee); - - boolean present_cpu_guarantee = true && (is_set_cpu_guarantee()); - list.add(present_cpu_guarantee); - if (present_cpu_guarantee) - list.add(cpu_guarantee); - - boolean present_memory_guarantee_remaining = true && (is_set_memory_guarantee_remaining()); - list.add(present_memory_guarantee_remaining); - if (present_memory_guarantee_remaining) - list.add(memory_guarantee_remaining); - - boolean present_cpu_guarantee_remaining = true && (is_set_cpu_guarantee_remaining()); - list.add(present_cpu_guarantee_remaining); - if (present_cpu_guarantee_remaining) - list.add(cpu_guarantee_remaining); - - boolean present_isolated_node_guarantee = true && (is_set_isolated_node_guarantee()); - list.add(present_isolated_node_guarantee); - if (present_isolated_node_guarantee) - list.add(isolated_node_guarantee); - - boolean present_total_tasks = true && (is_set_total_tasks()); - list.add(present_total_tasks); - if (present_total_tasks) - list.add(total_tasks); - - boolean present_requested_on_heap_memory = true && (is_set_requested_on_heap_memory()); - list.add(present_requested_on_heap_memory); - if (present_requested_on_heap_memory) - list.add(requested_on_heap_memory); - - boolean present_requested_off_heap_memory = true && (is_set_requested_off_heap_memory()); - list.add(present_requested_off_heap_memory); - if (present_requested_off_heap_memory) - list.add(requested_off_heap_memory); - - boolean present_requested_total_memory = true && (is_set_requested_total_memory()); - list.add(present_requested_total_memory); - if (present_requested_total_memory) - list.add(requested_total_memory); - - boolean present_requested_cpu = true && (is_set_requested_cpu()); - list.add(present_requested_cpu); - if (present_requested_cpu) - list.add(requested_cpu); - - boolean present_assigned_on_heap_memory = true && (is_set_assigned_on_heap_memory()); - list.add(present_assigned_on_heap_memory); - if (present_assigned_on_heap_memory) - list.add(assigned_on_heap_memory); - - boolean present_assigned_off_heap_memory = true && (is_set_assigned_off_heap_memory()); - list.add(present_assigned_off_heap_memory); - if (present_assigned_off_heap_memory) - list.add(assigned_off_heap_memory); - - return list.hashCode(); + int hashCode = 1; + + hashCode = hashCode * 8191 + ((is_set_owner()) ? 131071 : 524287); + if (is_set_owner()) + hashCode = hashCode * 8191 + owner.hashCode(); + + hashCode = hashCode * 8191 + ((is_set_total_topologies()) ? 131071 : 524287); + if (is_set_total_topologies()) + hashCode = hashCode * 8191 + total_topologies; + + hashCode = hashCode * 8191 + ((is_set_total_executors()) ? 131071 : 524287); + if (is_set_total_executors()) + hashCode = hashCode * 8191 + total_executors; + + hashCode = hashCode * 8191 + ((is_set_total_workers()) ? 131071 : 524287); + if (is_set_total_workers()) + hashCode = hashCode * 8191 + total_workers; + + hashCode = hashCode * 8191 + ((is_set_memory_usage()) ? 131071 : 524287); + if (is_set_memory_usage()) + hashCode = hashCode * 8191 + org.apache.thrift.TBaseHelper.hashCode(memory_usage); + + hashCode = hashCode * 8191 + ((is_set_cpu_usage()) ? 131071 : 524287); + if (is_set_cpu_usage()) + hashCode = hashCode * 8191 + org.apache.thrift.TBaseHelper.hashCode(cpu_usage); + + hashCode = hashCode * 8191 + ((is_set_memory_guarantee()) ? 131071 : 524287); + if (is_set_memory_guarantee()) + hashCode = hashCode * 8191 + org.apache.thrift.TBaseHelper.hashCode(memory_guarantee); + + hashCode = hashCode * 8191 + ((is_set_cpu_guarantee()) ? 131071 : 524287); + if (is_set_cpu_guarantee()) + hashCode = hashCode * 8191 + org.apache.thrift.TBaseHelper.hashCode(cpu_guarantee); + + hashCode = hashCode * 8191 + ((is_set_memory_guarantee_remaining()) ? 131071 : 524287); + if (is_set_memory_guarantee_remaining()) + hashCode = hashCode * 8191 + org.apache.thrift.TBaseHelper.hashCode(memory_guarantee_remaining); + + hashCode = hashCode * 8191 + ((is_set_cpu_guarantee_remaining()) ? 131071 : 524287); + if (is_set_cpu_guarantee_remaining()) + hashCode = hashCode * 8191 + org.apache.thrift.TBaseHelper.hashCode(cpu_guarantee_remaining); + + hashCode = hashCode * 8191 + ((is_set_isolated_node_guarantee()) ? 131071 : 524287); + if (is_set_isolated_node_guarantee()) + hashCode = hashCode * 8191 + isolated_node_guarantee; + + hashCode = hashCode * 8191 + ((is_set_total_tasks()) ? 131071 : 524287); + if (is_set_total_tasks()) + hashCode = hashCode * 8191 + total_tasks; + + hashCode = hashCode * 8191 + ((is_set_requested_on_heap_memory()) ? 131071 : 524287); + if (is_set_requested_on_heap_memory()) + hashCode = hashCode * 8191 + org.apache.thrift.TBaseHelper.hashCode(requested_on_heap_memory); + + hashCode = hashCode * 8191 + ((is_set_requested_off_heap_memory()) ? 131071 : 524287); + if (is_set_requested_off_heap_memory()) + hashCode = hashCode * 8191 + org.apache.thrift.TBaseHelper.hashCode(requested_off_heap_memory); + + hashCode = hashCode * 8191 + ((is_set_requested_total_memory()) ? 131071 : 524287); + if (is_set_requested_total_memory()) + hashCode = hashCode * 8191 + org.apache.thrift.TBaseHelper.hashCode(requested_total_memory); + + hashCode = hashCode * 8191 + ((is_set_requested_cpu()) ? 131071 : 524287); + if (is_set_requested_cpu()) + hashCode = hashCode * 8191 + org.apache.thrift.TBaseHelper.hashCode(requested_cpu); + + hashCode = hashCode * 8191 + ((is_set_assigned_on_heap_memory()) ? 131071 : 524287); + if (is_set_assigned_on_heap_memory()) + hashCode = hashCode * 8191 + org.apache.thrift.TBaseHelper.hashCode(assigned_on_heap_memory); + + hashCode = hashCode * 8191 + ((is_set_assigned_off_heap_memory()) ? 131071 : 524287); + if (is_set_assigned_off_heap_memory()) + hashCode = hashCode * 8191 + org.apache.thrift.TBaseHelper.hashCode(assigned_off_heap_memory); + + return hashCode; } @Override @@ -1287,7 +1241,7 @@ public class OwnerResourceSummary implements org.apache.thrift.TBase<OwnerResour int lastComparison = 0; - lastComparison = Boolean.valueOf(is_set_owner()).compareTo(other.is_set_owner()); + lastComparison = java.lang.Boolean.valueOf(is_set_owner()).compareTo(other.is_set_owner()); if (lastComparison != 0) { return lastComparison; } @@ -1297,7 +1251,7 @@ public class OwnerResourceSummary implements org.apache.thrift.TBase<OwnerResour return lastComparison; } } - lastComparison = Boolean.valueOf(is_set_total_topologies()).compareTo(other.is_set_total_topologies()); + lastComparison = java.lang.Boolean.valueOf(is_set_total_topologies()).compareTo(other.is_set_total_topologies()); if (lastComparison != 0) { return lastComparison; } @@ -1307,7 +1261,7 @@ public class OwnerResourceSummary implements org.apache.thrift.TBase<OwnerResour return lastComparison; } } - lastComparison = Boolean.valueOf(is_set_total_executors()).compareTo(other.is_set_total_executors()); + lastComparison = java.lang.Boolean.valueOf(is_set_total_executors()).compareTo(other.is_set_total_executors()); if (lastComparison != 0) { return lastComparison; } @@ -1317,7 +1271,7 @@ public class OwnerResourceSummary implements org.apache.thrift.TBase<OwnerResour return lastComparison; } } - lastComparison = Boolean.valueOf(is_set_total_workers()).compareTo(other.is_set_total_workers()); + lastComparison = java.lang.Boolean.valueOf(is_set_total_workers()).compareTo(other.is_set_total_workers()); if (lastComparison != 0) { return lastComparison; } @@ -1327,7 +1281,7 @@ public class OwnerResourceSummary implements org.apache.thrift.TBase<OwnerResour return lastComparison; } } - lastComparison = Boolean.valueOf(is_set_memory_usage()).compareTo(other.is_set_memory_usage()); + lastComparison = java.lang.Boolean.valueOf(is_set_memory_usage()).compareTo(other.is_set_memory_usage()); if (lastComparison != 0) { return lastComparison; } @@ -1337,7 +1291,7 @@ public class OwnerResourceSummary implements org.apache.thrift.TBase<OwnerResour return lastComparison; } } - lastComparison = Boolean.valueOf(is_set_cpu_usage()).compareTo(other.is_set_cpu_usage()); + lastComparison = java.lang.Boolean.valueOf(is_set_cpu_usage()).compareTo(other.is_set_cpu_usage()); if (lastComparison != 0) { return lastComparison; } @@ -1347,7 +1301,7 @@ public class OwnerResourceSummary implements org.apache.thrift.TBase<OwnerResour return lastComparison; } } - lastComparison = Boolean.valueOf(is_set_memory_guarantee()).compareTo(other.is_set_memory_guarantee()); + lastComparison = java.lang.Boolean.valueOf(is_set_memory_guarantee()).compareTo(other.is_set_memory_guarantee()); if (lastComparison != 0) { return lastComparison; } @@ -1357,7 +1311,7 @@ public class OwnerResourceSummary implements org.apache.thrift.TBase<OwnerResour return lastComparison; } } - lastComparison = Boolean.valueOf(is_set_cpu_guarantee()).compareTo(other.is_set_cpu_guarantee()); + lastComparison = java.lang.Boolean.valueOf(is_set_cpu_guarantee()).compareTo(other.is_set_cpu_guarantee()); if (lastComparison != 0) { return lastComparison; } @@ -1367,7 +1321,7 @@ public class OwnerResourceSummary implements org.apache.thrift.TBase<OwnerResour return lastComparison; } } - lastComparison = Boolean.valueOf(is_set_memory_guarantee_remaining()).compareTo(other.is_set_memory_guarantee_remaining()); + lastComparison = java.lang.Boolean.valueOf(is_set_memory_guarantee_remaining()).compareTo(other.is_set_memory_guarantee_remaining()); if (lastComparison != 0) { return lastComparison; } @@ -1377,7 +1331,7 @@ public class OwnerResourceSummary implements org.apache.thrift.TBase<OwnerResour return lastComparison; } } - lastComparison = Boolean.valueOf(is_set_cpu_guarantee_remaining()).compareTo(other.is_set_cpu_guarantee_remaining()); + lastComparison = java.lang.Boolean.valueOf(is_set_cpu_guarantee_remaining()).compareTo(other.is_set_cpu_guarantee_remaining()); if (lastComparison != 0) { return lastComparison; } @@ -1387,7 +1341,7 @@ public class OwnerResourceSummary implements org.apache.thrift.TBase<OwnerResour return lastComparison; } } - lastComparison = Boolean.valueOf(is_set_isolated_node_guarantee()).compareTo(other.is_set_isolated_node_guarantee()); + lastComparison = java.lang.Boolean.valueOf(is_set_isolated_node_guarantee()).compareTo(other.is_set_isolated_node_guarantee()); if (lastComparison != 0) { return lastComparison; } @@ -1397,7 +1351,7 @@ public class OwnerResourceSummary implements org.apache.thrift.TBase<OwnerResour return lastComparison; } } - lastComparison = Boolean.valueOf(is_set_total_tasks()).compareTo(other.is_set_total_tasks()); + lastComparison = java.lang.Boolean.valueOf(is_set_total_tasks()).compareTo(other.is_set_total_tasks()); if (lastComparison != 0) { return lastComparison; } @@ -1407,7 +1361,7 @@ public class OwnerResourceSummary implements org.apache.thrift.TBase<OwnerResour return lastComparison; } } - lastComparison = Boolean.valueOf(is_set_requested_on_heap_memory()).compareTo(other.is_set_requested_on_heap_memory()); + lastComparison = java.lang.Boolean.valueOf(is_set_requested_on_heap_memory()).compareTo(other.is_set_requested_on_heap_memory()); if (lastComparison != 0) { return lastComparison; } @@ -1417,7 +1371,7 @@ public class OwnerResourceSummary implements org.apache.thrift.TBase<OwnerResour return lastComparison; } } - lastComparison = Boolean.valueOf(is_set_requested_off_heap_memory()).compareTo(other.is_set_requested_off_heap_memory()); + lastComparison = java.lang.Boolean.valueOf(is_set_requested_off_heap_memory()).compareTo(other.is_set_requested_off_heap_memory()); if (lastComparison != 0) { return lastComparison; } @@ -1427,7 +1381,7 @@ public class OwnerResourceSummary implements org.apache.thrift.TBase<OwnerResour return lastComparison; } } - lastComparison = Boolean.valueOf(is_set_requested_total_memory()).compareTo(other.is_set_requested_total_memory()); + lastComparison = java.lang.Boolean.valueOf(is_set_requested_total_memory()).compareTo(other.is_set_requested_total_memory()); if (lastComparison != 0) { return lastComparison; } @@ -1437,7 +1391,7 @@ public class OwnerResourceSummary implements org.apache.thrift.TBase<OwnerResour return lastComparison; } } - lastComparison = Boolean.valueOf(is_set_requested_cpu()).compareTo(other.is_set_requested_cpu()); + lastComparison = java.lang.Boolean.valueOf(is_set_requested_cpu()).compareTo(other.is_set_requested_cpu()); if (lastComparison != 0) { return lastComparison; } @@ -1447,7 +1401,7 @@ public class OwnerResourceSummary implements org.apache.thrift.TBase<OwnerResour return lastComparison; } } - lastComparison = Boolean.valueOf(is_set_assigned_on_heap_memory()).compareTo(other.is_set_assigned_on_heap_memory()); + lastComparison = java.lang.Boolean.valueOf(is_set_assigned_on_heap_memory()).compareTo(other.is_set_assigned_on_heap_memory()); if (lastComparison != 0) { return lastComparison; } @@ -1457,7 +1411,7 @@ public class OwnerResourceSummary implements org.apache.thrift.TBase<OwnerResour return lastComparison; } } - lastComparison = Boolean.valueOf(is_set_assigned_off_heap_memory()).compareTo(other.is_set_assigned_off_heap_memory()); + lastComparison = java.lang.Boolean.valueOf(is_set_assigned_off_heap_memory()).compareTo(other.is_set_assigned_off_heap_memory()); if (lastComparison != 0) { return lastComparison; } @@ -1475,16 +1429,16 @@ public class OwnerResourceSummary implements org.apache.thrift.TBase<OwnerResour } public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException { - schemes.get(iprot.getScheme()).getScheme().read(iprot, this); + scheme(iprot).read(iprot, this); } public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException { - schemes.get(oprot.getScheme()).getScheme().write(oprot, this); + scheme(oprot).write(oprot, this); } @Override - public String toString() { - StringBuilder sb = new StringBuilder("OwnerResourceSummary("); + public java.lang.String toString() { + java.lang.StringBuilder sb = new java.lang.StringBuilder("OwnerResourceSummary("); boolean first = true; sb.append("owner:"); @@ -1617,7 +1571,7 @@ public class OwnerResourceSummary implements org.apache.thrift.TBase<OwnerResour } } - private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException { + private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, java.lang.ClassNotFoundException { try { // it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor. __isset_bitfield = 0; @@ -1627,13 +1581,13 @@ public class OwnerResourceSummary implements org.apache.thrift.TBase<OwnerResour } } - private static class OwnerResourceSummaryStandardSchemeFactory implements SchemeFactory { + private static class OwnerResourceSummaryStandardSchemeFactory implements org.apache.thrift.scheme.SchemeFactory { public OwnerResourceSummaryStandardScheme getScheme() { return new OwnerResourceSummaryStandardScheme(); } } - private static class OwnerResourceSummaryStandardScheme extends StandardScheme<OwnerResourceSummary> { + private static class OwnerResourceSummaryStandardScheme extends org.apache.thrift.scheme.StandardScheme<OwnerResourceSummary> { public void read(org.apache.thrift.protocol.TProtocol iprot, OwnerResourceSummary struct) throws org.apache.thrift.TException { org.apache.thrift.protocol.TField schemeField; @@ -1898,19 +1852,19 @@ public class OwnerResourceSummary implements org.apache.thrift.TBase<OwnerResour } - private static class OwnerResourceSummaryTupleSchemeFactory implements SchemeFactory { + private static class OwnerResourceSummaryTupleSchemeFactory implements org.apache.thrift.scheme.SchemeFactory { public OwnerResourceSummaryTupleScheme getScheme() { return new OwnerResourceSummaryTupleScheme(); } } - private static class OwnerResourceSummaryTupleScheme extends TupleScheme<OwnerResourceSummary> { + private static class OwnerResourceSummaryTupleScheme extends org.apache.thrift.scheme.TupleScheme<OwnerResourceSummary> { @Override public void write(org.apache.thrift.protocol.TProtocol prot, OwnerResourceSummary struct) throws org.apache.thrift.TException { - TTupleProtocol oprot = (TTupleProtocol) prot; + org.apache.thrift.protocol.TTupleProtocol oprot = (org.apache.thrift.protocol.TTupleProtocol) prot; oprot.writeString(struct.owner); - BitSet optionals = new BitSet(); + java.util.BitSet optionals = new java.util.BitSet(); if (struct.is_set_total_topologies()) { optionals.set(0); } @@ -2018,10 +1972,10 @@ public class OwnerResourceSummary implements org.apache.thrift.TBase<OwnerResour @Override public void read(org.apache.thrift.protocol.TProtocol prot, OwnerResourceSummary struct) throws org.apache.thrift.TException { - TTupleProtocol iprot = (TTupleProtocol) prot; + org.apache.thrift.protocol.TTupleProtocol iprot = (org.apache.thrift.protocol.TTupleProtocol) prot; struct.owner = iprot.readString(); struct.set_owner_isSet(true); - BitSet incoming = iprot.readBitSet(17); + java.util.BitSet incoming = iprot.readBitSet(17); if (incoming.get(0)) { struct.total_topologies = iprot.readI32(); struct.set_total_topologies_isSet(true); @@ -2093,5 +2047,8 @@ public class OwnerResourceSummary implements org.apache.thrift.TBase<OwnerResour } } + private static <S extends org.apache.thrift.scheme.IScheme> S scheme(org.apache.thrift.protocol.TProtocol proto) { + return (org.apache.thrift.scheme.StandardScheme.class.equals(proto.getScheme()) ? STANDARD_SCHEME_FACTORY : TUPLE_SCHEME_FACTORY).getScheme(); + } }
http://git-wip-us.apache.org/repos/asf/storm/blob/1fd1e17f/storm-client/src/jvm/org/apache/storm/generated/PrivateWorkerKey.java ---------------------------------------------------------------------- diff --git a/storm-client/src/jvm/org/apache/storm/generated/PrivateWorkerKey.java b/storm-client/src/jvm/org/apache/storm/generated/PrivateWorkerKey.java index 9884e09..27a22c2 100644 --- a/storm-client/src/jvm/org/apache/storm/generated/PrivateWorkerKey.java +++ b/storm-client/src/jvm/org/apache/storm/generated/PrivateWorkerKey.java @@ -16,42 +16,15 @@ * limitations under the License. */ /** - * Autogenerated by Thrift Compiler (0.9.3) + * Autogenerated by Thrift Compiler (0.11.0) * * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING * @generated */ package org.apache.storm.generated; -import org.apache.thrift.scheme.IScheme; -import org.apache.thrift.scheme.SchemeFactory; -import org.apache.thrift.scheme.StandardScheme; - -import org.apache.thrift.scheme.TupleScheme; -import org.apache.thrift.protocol.TTupleProtocol; -import org.apache.thrift.protocol.TProtocolException; -import org.apache.thrift.EncodingUtils; -import org.apache.thrift.TException; -import org.apache.thrift.async.AsyncMethodCallback; -import org.apache.thrift.server.AbstractNonblockingServer.*; -import java.util.List; -import java.util.ArrayList; -import java.util.Map; -import java.util.HashMap; -import java.util.EnumMap; -import java.util.Set; -import java.util.HashSet; -import java.util.EnumSet; -import java.util.Collections; -import java.util.BitSet; -import java.nio.ByteBuffer; -import java.util.Arrays; -import javax.annotation.Generated; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - -@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) -@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)") +@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"}) [email protected](value = "Autogenerated by Thrift Compiler (0.11.0)") public class PrivateWorkerKey implements org.apache.thrift.TBase<PrivateWorkerKey, PrivateWorkerKey._Fields>, java.io.Serializable, Cloneable, Comparable<PrivateWorkerKey> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("PrivateWorkerKey"); @@ -59,14 +32,11 @@ public class PrivateWorkerKey implements org.apache.thrift.TBase<PrivateWorkerKe private static final org.apache.thrift.protocol.TField USER_NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("userName", org.apache.thrift.protocol.TType.STRING, (short)2); private static final org.apache.thrift.protocol.TField EXPIRATION_TIME_MILLIS_FIELD_DESC = new org.apache.thrift.protocol.TField("expirationTimeMillis", org.apache.thrift.protocol.TType.I64, (short)3); - private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); - static { - schemes.put(StandardScheme.class, new PrivateWorkerKeyStandardSchemeFactory()); - schemes.put(TupleScheme.class, new PrivateWorkerKeyTupleSchemeFactory()); - } + private static final org.apache.thrift.scheme.SchemeFactory STANDARD_SCHEME_FACTORY = new PrivateWorkerKeyStandardSchemeFactory(); + private static final org.apache.thrift.scheme.SchemeFactory TUPLE_SCHEME_FACTORY = new PrivateWorkerKeyTupleSchemeFactory(); - private ByteBuffer key; // required - private String userName; // required + private java.nio.ByteBuffer key; // required + private java.lang.String userName; // required private long expirationTimeMillis; // required /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ @@ -75,10 +45,10 @@ public class PrivateWorkerKey implements org.apache.thrift.TBase<PrivateWorkerKe USER_NAME((short)2, "userName"), EXPIRATION_TIME_MILLIS((short)3, "expirationTimeMillis"); - private static final Map<String, _Fields> byName = new HashMap<String, _Fields>(); + private static final java.util.Map<java.lang.String, _Fields> byName = new java.util.HashMap<java.lang.String, _Fields>(); static { - for (_Fields field : EnumSet.allOf(_Fields.class)) { + for (_Fields field : java.util.EnumSet.allOf(_Fields.class)) { byName.put(field.getFieldName(), field); } } @@ -105,21 +75,21 @@ public class PrivateWorkerKey implements org.apache.thrift.TBase<PrivateWorkerKe */ public static _Fields findByThriftIdOrThrow(int fieldId) { _Fields fields = findByThriftId(fieldId); - if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!"); + if (fields == null) throw new java.lang.IllegalArgumentException("Field " + fieldId + " doesn't exist!"); return fields; } /** * Find the _Fields constant that matches name, or null if its not found. */ - public static _Fields findByName(String name) { + public static _Fields findByName(java.lang.String name) { return byName.get(name); } private final short _thriftId; - private final String _fieldName; + private final java.lang.String _fieldName; - _Fields(short thriftId, String fieldName) { + _Fields(short thriftId, java.lang.String fieldName) { _thriftId = thriftId; _fieldName = fieldName; } @@ -128,7 +98,7 @@ public class PrivateWorkerKey implements org.apache.thrift.TBase<PrivateWorkerKe return _thriftId; } - public String getFieldName() { + public java.lang.String getFieldName() { return _fieldName; } } @@ -136,16 +106,16 @@ public class PrivateWorkerKey implements org.apache.thrift.TBase<PrivateWorkerKe // isset id assignments private static final int __EXPIRATIONTIMEMILLIS_ISSET_ID = 0; private byte __isset_bitfield = 0; - public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap; + public static final java.util.Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap; static { - Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class); + java.util.Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new java.util.EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class); tmpMap.put(_Fields.KEY, new org.apache.thrift.meta_data.FieldMetaData("key", org.apache.thrift.TFieldRequirementType.REQUIRED, new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING , true))); tmpMap.put(_Fields.USER_NAME, new org.apache.thrift.meta_data.FieldMetaData("userName", org.apache.thrift.TFieldRequirementType.REQUIRED, new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); tmpMap.put(_Fields.EXPIRATION_TIME_MILLIS, new org.apache.thrift.meta_data.FieldMetaData("expirationTimeMillis", org.apache.thrift.TFieldRequirementType.REQUIRED, new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64))); - metaDataMap = Collections.unmodifiableMap(tmpMap); + metaDataMap = java.util.Collections.unmodifiableMap(tmpMap); org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(PrivateWorkerKey.class, metaDataMap); } @@ -153,8 +123,8 @@ public class PrivateWorkerKey implements org.apache.thrift.TBase<PrivateWorkerKe } public PrivateWorkerKey( - ByteBuffer key, - String userName, + java.nio.ByteBuffer key, + java.lang.String userName, long expirationTimeMillis) { this(); @@ -195,15 +165,15 @@ public class PrivateWorkerKey implements org.apache.thrift.TBase<PrivateWorkerKe return key == null ? null : key.array(); } - public ByteBuffer buffer_for_key() { + public java.nio.ByteBuffer buffer_for_key() { return org.apache.thrift.TBaseHelper.copyBinary(key); } public void set_key(byte[] key) { - this.key = key == null ? (ByteBuffer)null : ByteBuffer.wrap(Arrays.copyOf(key, key.length)); + this.key = key == null ? (java.nio.ByteBuffer)null : java.nio.ByteBuffer.wrap(key.clone()); } - public void set_key(ByteBuffer key) { + public void set_key(java.nio.ByteBuffer key) { this.key = org.apache.thrift.TBaseHelper.copyBinary(key); } @@ -222,11 +192,11 @@ public class PrivateWorkerKey implements org.apache.thrift.TBase<PrivateWorkerKe } } - public String get_userName() { + public java.lang.String get_userName() { return this.userName; } - public void set_userName(String userName) { + public void set_userName(java.lang.String userName) { this.userName = userName; } @@ -255,25 +225,29 @@ public class PrivateWorkerKey implements org.apache.thrift.TBase<PrivateWorkerKe } public void unset_expirationTimeMillis() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __EXPIRATIONTIMEMILLIS_ISSET_ID); + __isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __EXPIRATIONTIMEMILLIS_ISSET_ID); } /** Returns true if field expirationTimeMillis is set (has been assigned a value) and false otherwise */ public boolean is_set_expirationTimeMillis() { - return EncodingUtils.testBit(__isset_bitfield, __EXPIRATIONTIMEMILLIS_ISSET_ID); + return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __EXPIRATIONTIMEMILLIS_ISSET_ID); } public void set_expirationTimeMillis_isSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __EXPIRATIONTIMEMILLIS_ISSET_ID, value); + __isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __EXPIRATIONTIMEMILLIS_ISSET_ID, value); } - public void setFieldValue(_Fields field, Object value) { + public void setFieldValue(_Fields field, java.lang.Object value) { switch (field) { case KEY: if (value == null) { unset_key(); } else { - set_key((ByteBuffer)value); + if (value instanceof byte[]) { + set_key((byte[])value); + } else { + set_key((java.nio.ByteBuffer)value); + } } break; @@ -281,7 +255,7 @@ public class PrivateWorkerKey implements org.apache.thrift.TBase<PrivateWorkerKe if (value == null) { unset_userName(); } else { - set_userName((String)value); + set_userName((java.lang.String)value); } break; @@ -289,14 +263,14 @@ public class PrivateWorkerKey implements org.apache.thrift.TBase<PrivateWorkerKe if (value == null) { unset_expirationTimeMillis(); } else { - set_expirationTimeMillis((Long)value); + set_expirationTimeMillis((java.lang.Long)value); } break; } } - public Object getFieldValue(_Fields field) { + public java.lang.Object getFieldValue(_Fields field) { switch (field) { case KEY: return get_key(); @@ -308,13 +282,13 @@ public class PrivateWorkerKey implements org.apache.thrift.TBase<PrivateWorkerKe return get_expirationTimeMillis(); } - throw new IllegalStateException(); + throw new java.lang.IllegalStateException(); } /** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */ public boolean isSet(_Fields field) { if (field == null) { - throw new IllegalArgumentException(); + throw new java.lang.IllegalArgumentException(); } switch (field) { @@ -325,11 +299,11 @@ public class PrivateWorkerKey implements org.apache.thrift.TBase<PrivateWorkerKe case EXPIRATION_TIME_MILLIS: return is_set_expirationTimeMillis(); } - throw new IllegalStateException(); + throw new java.lang.IllegalStateException(); } @Override - public boolean equals(Object that) { + public boolean equals(java.lang.Object that) { if (that == null) return false; if (that instanceof PrivateWorkerKey) @@ -340,6 +314,8 @@ public class PrivateWorkerKey implements org.apache.thrift.TBase<PrivateWorkerKe public boolean equals(PrivateWorkerKey that) { if (that == null) return false; + if (this == that) + return true; boolean this_present_key = true && this.is_set_key(); boolean that_present_key = true && that.is_set_key(); @@ -373,24 +349,19 @@ public class PrivateWorkerKey implements org.apache.thrift.TBase<PrivateWorkerKe @Override public int hashCode() { - List<Object> list = new ArrayList<Object>(); + int hashCode = 1; - boolean present_key = true && (is_set_key()); - list.add(present_key); - if (present_key) - list.add(key); + hashCode = hashCode * 8191 + ((is_set_key()) ? 131071 : 524287); + if (is_set_key()) + hashCode = hashCode * 8191 + key.hashCode(); - boolean present_userName = true && (is_set_userName()); - list.add(present_userName); - if (present_userName) - list.add(userName); + hashCode = hashCode * 8191 + ((is_set_userName()) ? 131071 : 524287); + if (is_set_userName()) + hashCode = hashCode * 8191 + userName.hashCode(); - boolean present_expirationTimeMillis = true; - list.add(present_expirationTimeMillis); - if (present_expirationTimeMillis) - list.add(expirationTimeMillis); + hashCode = hashCode * 8191 + org.apache.thrift.TBaseHelper.hashCode(expirationTimeMillis); - return list.hashCode(); + return hashCode; } @Override @@ -401,7 +372,7 @@ public class PrivateWorkerKey implements org.apache.thrift.TBase<PrivateWorkerKe int lastComparison = 0; - lastComparison = Boolean.valueOf(is_set_key()).compareTo(other.is_set_key()); + lastComparison = java.lang.Boolean.valueOf(is_set_key()).compareTo(other.is_set_key()); if (lastComparison != 0) { return lastComparison; } @@ -411,7 +382,7 @@ public class PrivateWorkerKey implements org.apache.thrift.TBase<PrivateWorkerKe return lastComparison; } } - lastComparison = Boolean.valueOf(is_set_userName()).compareTo(other.is_set_userName()); + lastComparison = java.lang.Boolean.valueOf(is_set_userName()).compareTo(other.is_set_userName()); if (lastComparison != 0) { return lastComparison; } @@ -421,7 +392,7 @@ public class PrivateWorkerKey implements org.apache.thrift.TBase<PrivateWorkerKe return lastComparison; } } - lastComparison = Boolean.valueOf(is_set_expirationTimeMillis()).compareTo(other.is_set_expirationTimeMillis()); + lastComparison = java.lang.Boolean.valueOf(is_set_expirationTimeMillis()).compareTo(other.is_set_expirationTimeMillis()); if (lastComparison != 0) { return lastComparison; } @@ -439,16 +410,16 @@ public class PrivateWorkerKey implements org.apache.thrift.TBase<PrivateWorkerKe } public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException { - schemes.get(iprot.getScheme()).getScheme().read(iprot, this); + scheme(iprot).read(iprot, this); } public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException { - schemes.get(oprot.getScheme()).getScheme().write(oprot, this); + scheme(oprot).write(oprot, this); } @Override - public String toString() { - StringBuilder sb = new StringBuilder("PrivateWorkerKey("); + public java.lang.String toString() { + java.lang.StringBuilder sb = new java.lang.StringBuilder("PrivateWorkerKey("); boolean first = true; sb.append("key:"); @@ -499,7 +470,7 @@ public class PrivateWorkerKey implements org.apache.thrift.TBase<PrivateWorkerKe } } - private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException { + private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, java.lang.ClassNotFoundException { try { // it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor. __isset_bitfield = 0; @@ -509,13 +480,13 @@ public class PrivateWorkerKey implements org.apache.thrift.TBase<PrivateWorkerKe } } - private static class PrivateWorkerKeyStandardSchemeFactory implements SchemeFactory { + private static class PrivateWorkerKeyStandardSchemeFactory implements org.apache.thrift.scheme.SchemeFactory { public PrivateWorkerKeyStandardScheme getScheme() { return new PrivateWorkerKeyStandardScheme(); } } - private static class PrivateWorkerKeyStandardScheme extends StandardScheme<PrivateWorkerKey> { + private static class PrivateWorkerKeyStandardScheme extends org.apache.thrift.scheme.StandardScheme<PrivateWorkerKey> { public void read(org.apache.thrift.protocol.TProtocol iprot, PrivateWorkerKey struct) throws org.apache.thrift.TException { org.apache.thrift.protocol.TField schemeField; @@ -583,17 +554,17 @@ public class PrivateWorkerKey implements org.apache.thrift.TBase<PrivateWorkerKe } - private static class PrivateWorkerKeyTupleSchemeFactory implements SchemeFactory { + private static class PrivateWorkerKeyTupleSchemeFactory implements org.apache.thrift.scheme.SchemeFactory { public PrivateWorkerKeyTupleScheme getScheme() { return new PrivateWorkerKeyTupleScheme(); } } - private static class PrivateWorkerKeyTupleScheme extends TupleScheme<PrivateWorkerKey> { + private static class PrivateWorkerKeyTupleScheme extends org.apache.thrift.scheme.TupleScheme<PrivateWorkerKey> { @Override public void write(org.apache.thrift.protocol.TProtocol prot, PrivateWorkerKey struct) throws org.apache.thrift.TException { - TTupleProtocol oprot = (TTupleProtocol) prot; + org.apache.thrift.protocol.TTupleProtocol oprot = (org.apache.thrift.protocol.TTupleProtocol) prot; oprot.writeBinary(struct.key); oprot.writeString(struct.userName); oprot.writeI64(struct.expirationTimeMillis); @@ -601,7 +572,7 @@ public class PrivateWorkerKey implements org.apache.thrift.TBase<PrivateWorkerKe @Override public void read(org.apache.thrift.protocol.TProtocol prot, PrivateWorkerKey struct) throws org.apache.thrift.TException { - TTupleProtocol iprot = (TTupleProtocol) prot; + org.apache.thrift.protocol.TTupleProtocol iprot = (org.apache.thrift.protocol.TTupleProtocol) prot; struct.key = iprot.readBinary(); struct.set_key_isSet(true); struct.userName = iprot.readString(); @@ -611,5 +582,8 @@ public class PrivateWorkerKey implements org.apache.thrift.TBase<PrivateWorkerKe } } + private static <S extends org.apache.thrift.scheme.IScheme> S scheme(org.apache.thrift.protocol.TProtocol proto) { + return (org.apache.thrift.scheme.StandardScheme.class.equals(proto.getScheme()) ? STANDARD_SCHEME_FACTORY : TUPLE_SCHEME_FACTORY).getScheme(); + } } http://git-wip-us.apache.org/repos/asf/storm/blob/1fd1e17f/storm-client/src/jvm/org/apache/storm/generated/ProfileAction.java ---------------------------------------------------------------------- diff --git a/storm-client/src/jvm/org/apache/storm/generated/ProfileAction.java b/storm-client/src/jvm/org/apache/storm/generated/ProfileAction.java index f783c98..8581b8a 100644 --- a/storm-client/src/jvm/org/apache/storm/generated/ProfileAction.java +++ b/storm-client/src/jvm/org/apache/storm/generated/ProfileAction.java @@ -16,7 +16,7 @@ * limitations under the License. */ /** - * Autogenerated by Thrift Compiler (0.9.3) + * Autogenerated by Thrift Compiler (0.11.0) * * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING * @generated @@ -24,10 +24,6 @@ package org.apache.storm.generated; -import java.util.Map; -import java.util.HashMap; -import org.apache.thrift.TEnum; - public enum ProfileAction implements org.apache.thrift.TEnum { JPROFILE_STOP(0), JPROFILE_START(1),
