You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by bo...@apache.org on 2018/05/23 20:03:52 UTC
[22/43] storm git commit: STORM-3061: thrift 0.11
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"})
+@javax.annotation.Generated(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"})
+@javax.annotation.Generated(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),