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/06/07 15:55:00 UTC
[24/50] [abbrv] storm git commit: STORM-2882: thrift
http://git-wip-us.apache.org/repos/asf/storm/blob/91251c54/storm-client/src/jvm/org/apache/storm/generated/SettableBlobMeta.java
----------------------------------------------------------------------
diff --git a/storm-client/src/jvm/org/apache/storm/generated/SettableBlobMeta.java b/storm-client/src/jvm/org/apache/storm/generated/SettableBlobMeta.java
index f41d069..7298624 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/SettableBlobMeta.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/SettableBlobMeta.java
@@ -25,20 +25,20 @@ package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.11.0)")
-public class SettableBlobMeta implements org.apache.thrift.TBase<SettableBlobMeta, SettableBlobMeta._Fields>, java.io.Serializable, Cloneable, Comparable<SettableBlobMeta> {
- private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("SettableBlobMeta");
+public class SettableBlobMeta implements org.apache.storm.thrift.TBase<SettableBlobMeta, SettableBlobMeta._Fields>, java.io.Serializable, Cloneable, Comparable<SettableBlobMeta> {
+ private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC = new org.apache.storm.thrift.protocol.TStruct("SettableBlobMeta");
- private static final org.apache.thrift.protocol.TField ACL_FIELD_DESC = new org.apache.thrift.protocol.TField("acl", org.apache.thrift.protocol.TType.LIST, (short)1);
- private static final org.apache.thrift.protocol.TField REPLICATION_FACTOR_FIELD_DESC = new org.apache.thrift.protocol.TField("replication_factor", org.apache.thrift.protocol.TType.I32, (short)2);
+ private static final org.apache.storm.thrift.protocol.TField ACL_FIELD_DESC = new org.apache.storm.thrift.protocol.TField("acl", org.apache.storm.thrift.protocol.TType.LIST, (short)1);
+ private static final org.apache.storm.thrift.protocol.TField REPLICATION_FACTOR_FIELD_DESC = new org.apache.storm.thrift.protocol.TField("replication_factor", org.apache.storm.thrift.protocol.TType.I32, (short)2);
- private static final org.apache.thrift.scheme.SchemeFactory STANDARD_SCHEME_FACTORY = new SettableBlobMetaStandardSchemeFactory();
- private static final org.apache.thrift.scheme.SchemeFactory TUPLE_SCHEME_FACTORY = new SettableBlobMetaTupleSchemeFactory();
+ private static final org.apache.storm.thrift.scheme.SchemeFactory STANDARD_SCHEME_FACTORY = new SettableBlobMetaStandardSchemeFactory();
+ private static final org.apache.storm.thrift.scheme.SchemeFactory TUPLE_SCHEME_FACTORY = new SettableBlobMetaTupleSchemeFactory();
private java.util.List<AccessControl> acl; // required
private int replication_factor; // optional
/** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
- public enum _Fields implements org.apache.thrift.TFieldIdEnum {
+ public enum _Fields implements org.apache.storm.thrift.TFieldIdEnum {
ACL((short)1, "acl"),
REPLICATION_FACTOR((short)2, "replication_factor");
@@ -102,16 +102,16 @@ public class SettableBlobMeta implements org.apache.thrift.TBase<SettableBlobMet
private static final int __REPLICATION_FACTOR_ISSET_ID = 0;
private byte __isset_bitfield = 0;
private static final _Fields optionals[] = {_Fields.REPLICATION_FACTOR};
- public static final java.util.Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
+ public static final java.util.Map<_Fields, org.apache.storm.thrift.meta_data.FieldMetaData> metaDataMap;
static {
- 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.ACL, new org.apache.thrift.meta_data.FieldMetaData("acl", org.apache.thrift.TFieldRequirementType.REQUIRED,
- new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST,
- new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, AccessControl.class))));
- tmpMap.put(_Fields.REPLICATION_FACTOR, new org.apache.thrift.meta_data.FieldMetaData("replication_factor", org.apache.thrift.TFieldRequirementType.OPTIONAL,
- new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32)));
+ java.util.Map<_Fields, org.apache.storm.thrift.meta_data.FieldMetaData> tmpMap = new java.util.EnumMap<_Fields, org.apache.storm.thrift.meta_data.FieldMetaData>(_Fields.class);
+ tmpMap.put(_Fields.ACL, new org.apache.storm.thrift.meta_data.FieldMetaData("acl", org.apache.storm.thrift.TFieldRequirementType.REQUIRED,
+ new org.apache.storm.thrift.meta_data.ListMetaData(org.apache.storm.thrift.protocol.TType.LIST,
+ new org.apache.storm.thrift.meta_data.StructMetaData(org.apache.storm.thrift.protocol.TType.STRUCT, AccessControl.class))));
+ tmpMap.put(_Fields.REPLICATION_FACTOR, new org.apache.storm.thrift.meta_data.FieldMetaData("replication_factor", org.apache.storm.thrift.TFieldRequirementType.OPTIONAL,
+ new org.apache.storm.thrift.meta_data.FieldValueMetaData(org.apache.storm.thrift.protocol.TType.I32)));
metaDataMap = java.util.Collections.unmodifiableMap(tmpMap);
- org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(SettableBlobMeta.class, metaDataMap);
+ org.apache.storm.thrift.meta_data.FieldMetaData.addStructMetaDataMap(SettableBlobMeta.class, metaDataMap);
}
public SettableBlobMeta() {
@@ -198,16 +198,16 @@ public class SettableBlobMeta implements org.apache.thrift.TBase<SettableBlobMet
}
public void unset_replication_factor() {
- __isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __REPLICATION_FACTOR_ISSET_ID);
+ __isset_bitfield = org.apache.storm.thrift.EncodingUtils.clearBit(__isset_bitfield, __REPLICATION_FACTOR_ISSET_ID);
}
/** Returns true if field replication_factor is set (has been assigned a value) and false otherwise */
public boolean is_set_replication_factor() {
- return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __REPLICATION_FACTOR_ISSET_ID);
+ return org.apache.storm.thrift.EncodingUtils.testBit(__isset_bitfield, __REPLICATION_FACTOR_ISSET_ID);
}
public void set_replication_factor_isSet(boolean value) {
- __isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __REPLICATION_FACTOR_ISSET_ID, value);
+ __isset_bitfield = org.apache.storm.thrift.EncodingUtils.setBit(__isset_bitfield, __REPLICATION_FACTOR_ISSET_ID, value);
}
public void setFieldValue(_Fields field, java.lang.Object value) {
@@ -322,7 +322,7 @@ public class SettableBlobMeta implements org.apache.thrift.TBase<SettableBlobMet
return lastComparison;
}
if (is_set_acl()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.acl, other.acl);
+ lastComparison = org.apache.storm.thrift.TBaseHelper.compareTo(this.acl, other.acl);
if (lastComparison != 0) {
return lastComparison;
}
@@ -332,7 +332,7 @@ public class SettableBlobMeta implements org.apache.thrift.TBase<SettableBlobMet
return lastComparison;
}
if (is_set_replication_factor()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.replication_factor, other.replication_factor);
+ lastComparison = org.apache.storm.thrift.TBaseHelper.compareTo(this.replication_factor, other.replication_factor);
if (lastComparison != 0) {
return lastComparison;
}
@@ -344,11 +344,11 @@ public class SettableBlobMeta implements org.apache.thrift.TBase<SettableBlobMet
return _Fields.findByThriftId(fieldId);
}
- public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException {
+ public void read(org.apache.storm.thrift.protocol.TProtocol iprot) throws org.apache.storm.thrift.TException {
scheme(iprot).read(iprot, this);
}
- public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
+ public void write(org.apache.storm.thrift.protocol.TProtocol oprot) throws org.apache.storm.thrift.TException {
scheme(oprot).write(oprot, this);
}
@@ -374,10 +374,10 @@ public class SettableBlobMeta implements org.apache.thrift.TBase<SettableBlobMet
return sb.toString();
}
- public void validate() throws org.apache.thrift.TException {
+ public void validate() throws org.apache.storm.thrift.TException {
// check for required fields
if (!is_set_acl()) {
- throw new org.apache.thrift.protocol.TProtocolException("Required field 'acl' is unset! Struct:" + toString());
+ throw new org.apache.storm.thrift.protocol.TProtocolException("Required field 'acl' is unset! Struct:" + toString());
}
// check for sub-struct validity
@@ -385,8 +385,8 @@ public class SettableBlobMeta implements org.apache.thrift.TBase<SettableBlobMet
private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
try {
- write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out)));
- } catch (org.apache.thrift.TException te) {
+ write(new org.apache.storm.thrift.protocol.TCompactProtocol(new org.apache.storm.thrift.transport.TIOStreamTransport(out)));
+ } catch (org.apache.storm.thrift.TException te) {
throw new java.io.IOException(te);
}
}
@@ -395,34 +395,34 @@ public class SettableBlobMeta implements org.apache.thrift.TBase<SettableBlobMet
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;
- read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
- } catch (org.apache.thrift.TException te) {
+ read(new org.apache.storm.thrift.protocol.TCompactProtocol(new org.apache.storm.thrift.transport.TIOStreamTransport(in)));
+ } catch (org.apache.storm.thrift.TException te) {
throw new java.io.IOException(te);
}
}
- private static class SettableBlobMetaStandardSchemeFactory implements org.apache.thrift.scheme.SchemeFactory {
+ private static class SettableBlobMetaStandardSchemeFactory implements org.apache.storm.thrift.scheme.SchemeFactory {
public SettableBlobMetaStandardScheme getScheme() {
return new SettableBlobMetaStandardScheme();
}
}
- private static class SettableBlobMetaStandardScheme extends org.apache.thrift.scheme.StandardScheme<SettableBlobMeta> {
+ private static class SettableBlobMetaStandardScheme extends org.apache.storm.thrift.scheme.StandardScheme<SettableBlobMeta> {
- public void read(org.apache.thrift.protocol.TProtocol iprot, SettableBlobMeta struct) throws org.apache.thrift.TException {
- org.apache.thrift.protocol.TField schemeField;
+ public void read(org.apache.storm.thrift.protocol.TProtocol iprot, SettableBlobMeta struct) throws org.apache.storm.thrift.TException {
+ org.apache.storm.thrift.protocol.TField schemeField;
iprot.readStructBegin();
while (true)
{
schemeField = iprot.readFieldBegin();
- if (schemeField.type == org.apache.thrift.protocol.TType.STOP) {
+ if (schemeField.type == org.apache.storm.thrift.protocol.TType.STOP) {
break;
}
switch (schemeField.id) {
case 1: // ACL
- if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
+ if (schemeField.type == org.apache.storm.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list606 = iprot.readListBegin();
+ org.apache.storm.thrift.protocol.TList _list606 = iprot.readListBegin();
struct.acl = new java.util.ArrayList<AccessControl>(_list606.size);
AccessControl _elem607;
for (int _i608 = 0; _i608 < _list606.size; ++_i608)
@@ -435,19 +435,19 @@ public class SettableBlobMeta implements org.apache.thrift.TBase<SettableBlobMet
}
struct.set_acl_isSet(true);
} else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ org.apache.storm.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 2: // REPLICATION_FACTOR
- if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
+ if (schemeField.type == org.apache.storm.thrift.protocol.TType.I32) {
struct.replication_factor = iprot.readI32();
struct.set_replication_factor_isSet(true);
} else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ org.apache.storm.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
default:
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ org.apache.storm.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
iprot.readFieldEnd();
}
@@ -455,14 +455,14 @@ public class SettableBlobMeta implements org.apache.thrift.TBase<SettableBlobMet
struct.validate();
}
- public void write(org.apache.thrift.protocol.TProtocol oprot, SettableBlobMeta struct) throws org.apache.thrift.TException {
+ public void write(org.apache.storm.thrift.protocol.TProtocol oprot, SettableBlobMeta struct) throws org.apache.storm.thrift.TException {
struct.validate();
oprot.writeStructBegin(STRUCT_DESC);
if (struct.acl != null) {
oprot.writeFieldBegin(ACL_FIELD_DESC);
{
- oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.acl.size()));
+ oprot.writeListBegin(new org.apache.storm.thrift.protocol.TList(org.apache.storm.thrift.protocol.TType.STRUCT, struct.acl.size()));
for (AccessControl _iter609 : struct.acl)
{
_iter609.write(oprot);
@@ -482,17 +482,17 @@ public class SettableBlobMeta implements org.apache.thrift.TBase<SettableBlobMet
}
- private static class SettableBlobMetaTupleSchemeFactory implements org.apache.thrift.scheme.SchemeFactory {
+ private static class SettableBlobMetaTupleSchemeFactory implements org.apache.storm.thrift.scheme.SchemeFactory {
public SettableBlobMetaTupleScheme getScheme() {
return new SettableBlobMetaTupleScheme();
}
}
- private static class SettableBlobMetaTupleScheme extends org.apache.thrift.scheme.TupleScheme<SettableBlobMeta> {
+ private static class SettableBlobMetaTupleScheme extends org.apache.storm.thrift.scheme.TupleScheme<SettableBlobMeta> {
@Override
- public void write(org.apache.thrift.protocol.TProtocol prot, SettableBlobMeta struct) throws org.apache.thrift.TException {
- org.apache.thrift.protocol.TTupleProtocol oprot = (org.apache.thrift.protocol.TTupleProtocol) prot;
+ public void write(org.apache.storm.thrift.protocol.TProtocol prot, SettableBlobMeta struct) throws org.apache.storm.thrift.TException {
+ org.apache.storm.thrift.protocol.TTupleProtocol oprot = (org.apache.storm.thrift.protocol.TTupleProtocol) prot;
{
oprot.writeI32(struct.acl.size());
for (AccessControl _iter610 : struct.acl)
@@ -511,10 +511,10 @@ public class SettableBlobMeta implements org.apache.thrift.TBase<SettableBlobMet
}
@Override
- public void read(org.apache.thrift.protocol.TProtocol prot, SettableBlobMeta struct) throws org.apache.thrift.TException {
- org.apache.thrift.protocol.TTupleProtocol iprot = (org.apache.thrift.protocol.TTupleProtocol) prot;
+ public void read(org.apache.storm.thrift.protocol.TProtocol prot, SettableBlobMeta struct) throws org.apache.storm.thrift.TException {
+ org.apache.storm.thrift.protocol.TTupleProtocol iprot = (org.apache.storm.thrift.protocol.TTupleProtocol) prot;
{
- org.apache.thrift.protocol.TList _list611 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ org.apache.storm.thrift.protocol.TList _list611 = new org.apache.storm.thrift.protocol.TList(org.apache.storm.thrift.protocol.TType.STRUCT, iprot.readI32());
struct.acl = new java.util.ArrayList<AccessControl>(_list611.size);
AccessControl _elem612;
for (int _i613 = 0; _i613 < _list611.size; ++_i613)
@@ -533,8 +533,8 @@ public class SettableBlobMeta implements org.apache.thrift.TBase<SettableBlobMet
}
}
- 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();
+ private static <S extends org.apache.storm.thrift.scheme.IScheme> S scheme(org.apache.storm.thrift.protocol.TProtocol proto) {
+ return (org.apache.storm.thrift.scheme.StandardScheme.class.equals(proto.getScheme()) ? STANDARD_SCHEME_FACTORY : TUPLE_SCHEME_FACTORY).getScheme();
}
}
http://git-wip-us.apache.org/repos/asf/storm/blob/91251c54/storm-client/src/jvm/org/apache/storm/generated/SharedMemory.java
----------------------------------------------------------------------
diff --git a/storm-client/src/jvm/org/apache/storm/generated/SharedMemory.java b/storm-client/src/jvm/org/apache/storm/generated/SharedMemory.java
index 5efa346..70696a5 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/SharedMemory.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/SharedMemory.java
@@ -25,16 +25,16 @@ package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.11.0)")
-public class SharedMemory implements org.apache.thrift.TBase<SharedMemory, SharedMemory._Fields>, java.io.Serializable, Cloneable, Comparable<SharedMemory> {
- private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("SharedMemory");
+public class SharedMemory implements org.apache.storm.thrift.TBase<SharedMemory, SharedMemory._Fields>, java.io.Serializable, Cloneable, Comparable<SharedMemory> {
+ private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC = new org.apache.storm.thrift.protocol.TStruct("SharedMemory");
- private static final org.apache.thrift.protocol.TField NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("name", org.apache.thrift.protocol.TType.STRING, (short)1);
- private static final org.apache.thrift.protocol.TField ON_HEAP_FIELD_DESC = new org.apache.thrift.protocol.TField("on_heap", org.apache.thrift.protocol.TType.DOUBLE, (short)2);
- private static final org.apache.thrift.protocol.TField OFF_HEAP_WORKER_FIELD_DESC = new org.apache.thrift.protocol.TField("off_heap_worker", org.apache.thrift.protocol.TType.DOUBLE, (short)3);
- private static final org.apache.thrift.protocol.TField OFF_HEAP_NODE_FIELD_DESC = new org.apache.thrift.protocol.TField("off_heap_node", org.apache.thrift.protocol.TType.DOUBLE, (short)4);
+ private static final org.apache.storm.thrift.protocol.TField NAME_FIELD_DESC = new org.apache.storm.thrift.protocol.TField("name", org.apache.storm.thrift.protocol.TType.STRING, (short)1);
+ private static final org.apache.storm.thrift.protocol.TField ON_HEAP_FIELD_DESC = new org.apache.storm.thrift.protocol.TField("on_heap", org.apache.storm.thrift.protocol.TType.DOUBLE, (short)2);
+ private static final org.apache.storm.thrift.protocol.TField OFF_HEAP_WORKER_FIELD_DESC = new org.apache.storm.thrift.protocol.TField("off_heap_worker", org.apache.storm.thrift.protocol.TType.DOUBLE, (short)3);
+ private static final org.apache.storm.thrift.protocol.TField OFF_HEAP_NODE_FIELD_DESC = new org.apache.storm.thrift.protocol.TField("off_heap_node", org.apache.storm.thrift.protocol.TType.DOUBLE, (short)4);
- private static final org.apache.thrift.scheme.SchemeFactory STANDARD_SCHEME_FACTORY = new SharedMemoryStandardSchemeFactory();
- private static final org.apache.thrift.scheme.SchemeFactory TUPLE_SCHEME_FACTORY = new SharedMemoryTupleSchemeFactory();
+ private static final org.apache.storm.thrift.scheme.SchemeFactory STANDARD_SCHEME_FACTORY = new SharedMemoryStandardSchemeFactory();
+ private static final org.apache.storm.thrift.scheme.SchemeFactory TUPLE_SCHEME_FACTORY = new SharedMemoryTupleSchemeFactory();
private java.lang.String name; // required
private double on_heap; // optional
@@ -42,7 +42,7 @@ public class SharedMemory implements org.apache.thrift.TBase<SharedMemory, Share
private double off_heap_node; // optional
/** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
- public enum _Fields implements org.apache.thrift.TFieldIdEnum {
+ public enum _Fields implements org.apache.storm.thrift.TFieldIdEnum {
NAME((short)1, "name"),
ON_HEAP((short)2, "on_heap"),
OFF_HEAP_WORKER((short)3, "off_heap_worker"),
@@ -114,19 +114,19 @@ public class SharedMemory implements org.apache.thrift.TBase<SharedMemory, Share
private static final int __OFF_HEAP_NODE_ISSET_ID = 2;
private byte __isset_bitfield = 0;
private static final _Fields optionals[] = {_Fields.ON_HEAP,_Fields.OFF_HEAP_WORKER,_Fields.OFF_HEAP_NODE};
- public static final java.util.Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
+ public static final java.util.Map<_Fields, org.apache.storm.thrift.meta_data.FieldMetaData> metaDataMap;
static {
- 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.NAME, new org.apache.thrift.meta_data.FieldMetaData("name", org.apache.thrift.TFieldRequirementType.REQUIRED,
- new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
- tmpMap.put(_Fields.ON_HEAP, new org.apache.thrift.meta_data.FieldMetaData("on_heap", org.apache.thrift.TFieldRequirementType.OPTIONAL,
- new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.DOUBLE)));
- tmpMap.put(_Fields.OFF_HEAP_WORKER, new org.apache.thrift.meta_data.FieldMetaData("off_heap_worker", org.apache.thrift.TFieldRequirementType.OPTIONAL,
- new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.DOUBLE)));
- tmpMap.put(_Fields.OFF_HEAP_NODE, new org.apache.thrift.meta_data.FieldMetaData("off_heap_node", org.apache.thrift.TFieldRequirementType.OPTIONAL,
- new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.DOUBLE)));
+ java.util.Map<_Fields, org.apache.storm.thrift.meta_data.FieldMetaData> tmpMap = new java.util.EnumMap<_Fields, org.apache.storm.thrift.meta_data.FieldMetaData>(_Fields.class);
+ tmpMap.put(_Fields.NAME, new org.apache.storm.thrift.meta_data.FieldMetaData("name", org.apache.storm.thrift.TFieldRequirementType.REQUIRED,
+ new org.apache.storm.thrift.meta_data.FieldValueMetaData(org.apache.storm.thrift.protocol.TType.STRING)));
+ tmpMap.put(_Fields.ON_HEAP, new org.apache.storm.thrift.meta_data.FieldMetaData("on_heap", org.apache.storm.thrift.TFieldRequirementType.OPTIONAL,
+ new org.apache.storm.thrift.meta_data.FieldValueMetaData(org.apache.storm.thrift.protocol.TType.DOUBLE)));
+ tmpMap.put(_Fields.OFF_HEAP_WORKER, new org.apache.storm.thrift.meta_data.FieldMetaData("off_heap_worker", org.apache.storm.thrift.TFieldRequirementType.OPTIONAL,
+ new org.apache.storm.thrift.meta_data.FieldValueMetaData(org.apache.storm.thrift.protocol.TType.DOUBLE)));
+ tmpMap.put(_Fields.OFF_HEAP_NODE, new org.apache.storm.thrift.meta_data.FieldMetaData("off_heap_node", org.apache.storm.thrift.TFieldRequirementType.OPTIONAL,
+ new org.apache.storm.thrift.meta_data.FieldValueMetaData(org.apache.storm.thrift.protocol.TType.DOUBLE)));
metaDataMap = java.util.Collections.unmodifiableMap(tmpMap);
- org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(SharedMemory.class, metaDataMap);
+ org.apache.storm.thrift.meta_data.FieldMetaData.addStructMetaDataMap(SharedMemory.class, metaDataMap);
}
public SharedMemory() {
@@ -200,16 +200,16 @@ public class SharedMemory implements org.apache.thrift.TBase<SharedMemory, Share
}
public void unset_on_heap() {
- __isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __ON_HEAP_ISSET_ID);
+ __isset_bitfield = org.apache.storm.thrift.EncodingUtils.clearBit(__isset_bitfield, __ON_HEAP_ISSET_ID);
}
/** Returns true if field on_heap is set (has been assigned a value) and false otherwise */
public boolean is_set_on_heap() {
- return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __ON_HEAP_ISSET_ID);
+ return org.apache.storm.thrift.EncodingUtils.testBit(__isset_bitfield, __ON_HEAP_ISSET_ID);
}
public void set_on_heap_isSet(boolean value) {
- __isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __ON_HEAP_ISSET_ID, value);
+ __isset_bitfield = org.apache.storm.thrift.EncodingUtils.setBit(__isset_bitfield, __ON_HEAP_ISSET_ID, value);
}
public double get_off_heap_worker() {
@@ -222,16 +222,16 @@ public class SharedMemory implements org.apache.thrift.TBase<SharedMemory, Share
}
public void unset_off_heap_worker() {
- __isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __OFF_HEAP_WORKER_ISSET_ID);
+ __isset_bitfield = org.apache.storm.thrift.EncodingUtils.clearBit(__isset_bitfield, __OFF_HEAP_WORKER_ISSET_ID);
}
/** Returns true if field off_heap_worker is set (has been assigned a value) and false otherwise */
public boolean is_set_off_heap_worker() {
- return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __OFF_HEAP_WORKER_ISSET_ID);
+ return org.apache.storm.thrift.EncodingUtils.testBit(__isset_bitfield, __OFF_HEAP_WORKER_ISSET_ID);
}
public void set_off_heap_worker_isSet(boolean value) {
- __isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __OFF_HEAP_WORKER_ISSET_ID, value);
+ __isset_bitfield = org.apache.storm.thrift.EncodingUtils.setBit(__isset_bitfield, __OFF_HEAP_WORKER_ISSET_ID, value);
}
public double get_off_heap_node() {
@@ -244,16 +244,16 @@ public class SharedMemory implements org.apache.thrift.TBase<SharedMemory, Share
}
public void unset_off_heap_node() {
- __isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __OFF_HEAP_NODE_ISSET_ID);
+ __isset_bitfield = org.apache.storm.thrift.EncodingUtils.clearBit(__isset_bitfield, __OFF_HEAP_NODE_ISSET_ID);
}
/** Returns true if field off_heap_node is set (has been assigned a value) and false otherwise */
public boolean is_set_off_heap_node() {
- return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __OFF_HEAP_NODE_ISSET_ID);
+ return org.apache.storm.thrift.EncodingUtils.testBit(__isset_bitfield, __OFF_HEAP_NODE_ISSET_ID);
}
public void set_off_heap_node_isSet(boolean value) {
- __isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __OFF_HEAP_NODE_ISSET_ID, value);
+ __isset_bitfield = org.apache.storm.thrift.EncodingUtils.setBit(__isset_bitfield, __OFF_HEAP_NODE_ISSET_ID, value);
}
public void setFieldValue(_Fields field, java.lang.Object value) {
@@ -394,15 +394,15 @@ public class SharedMemory implements org.apache.thrift.TBase<SharedMemory, Share
hashCode = hashCode * 8191 + ((is_set_on_heap()) ? 131071 : 524287);
if (is_set_on_heap())
- hashCode = hashCode * 8191 + org.apache.thrift.TBaseHelper.hashCode(on_heap);
+ hashCode = hashCode * 8191 + org.apache.storm.thrift.TBaseHelper.hashCode(on_heap);
hashCode = hashCode * 8191 + ((is_set_off_heap_worker()) ? 131071 : 524287);
if (is_set_off_heap_worker())
- hashCode = hashCode * 8191 + org.apache.thrift.TBaseHelper.hashCode(off_heap_worker);
+ hashCode = hashCode * 8191 + org.apache.storm.thrift.TBaseHelper.hashCode(off_heap_worker);
hashCode = hashCode * 8191 + ((is_set_off_heap_node()) ? 131071 : 524287);
if (is_set_off_heap_node())
- hashCode = hashCode * 8191 + org.apache.thrift.TBaseHelper.hashCode(off_heap_node);
+ hashCode = hashCode * 8191 + org.apache.storm.thrift.TBaseHelper.hashCode(off_heap_node);
return hashCode;
}
@@ -420,7 +420,7 @@ public class SharedMemory implements org.apache.thrift.TBase<SharedMemory, Share
return lastComparison;
}
if (is_set_name()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.name, other.name);
+ lastComparison = org.apache.storm.thrift.TBaseHelper.compareTo(this.name, other.name);
if (lastComparison != 0) {
return lastComparison;
}
@@ -430,7 +430,7 @@ public class SharedMemory implements org.apache.thrift.TBase<SharedMemory, Share
return lastComparison;
}
if (is_set_on_heap()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.on_heap, other.on_heap);
+ lastComparison = org.apache.storm.thrift.TBaseHelper.compareTo(this.on_heap, other.on_heap);
if (lastComparison != 0) {
return lastComparison;
}
@@ -440,7 +440,7 @@ public class SharedMemory implements org.apache.thrift.TBase<SharedMemory, Share
return lastComparison;
}
if (is_set_off_heap_worker()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.off_heap_worker, other.off_heap_worker);
+ lastComparison = org.apache.storm.thrift.TBaseHelper.compareTo(this.off_heap_worker, other.off_heap_worker);
if (lastComparison != 0) {
return lastComparison;
}
@@ -450,7 +450,7 @@ public class SharedMemory implements org.apache.thrift.TBase<SharedMemory, Share
return lastComparison;
}
if (is_set_off_heap_node()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.off_heap_node, other.off_heap_node);
+ lastComparison = org.apache.storm.thrift.TBaseHelper.compareTo(this.off_heap_node, other.off_heap_node);
if (lastComparison != 0) {
return lastComparison;
}
@@ -462,11 +462,11 @@ public class SharedMemory implements org.apache.thrift.TBase<SharedMemory, Share
return _Fields.findByThriftId(fieldId);
}
- public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException {
+ public void read(org.apache.storm.thrift.protocol.TProtocol iprot) throws org.apache.storm.thrift.TException {
scheme(iprot).read(iprot, this);
}
- public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
+ public void write(org.apache.storm.thrift.protocol.TProtocol oprot) throws org.apache.storm.thrift.TException {
scheme(oprot).write(oprot, this);
}
@@ -504,10 +504,10 @@ public class SharedMemory implements org.apache.thrift.TBase<SharedMemory, Share
return sb.toString();
}
- public void validate() throws org.apache.thrift.TException {
+ public void validate() throws org.apache.storm.thrift.TException {
// check for required fields
if (!is_set_name()) {
- throw new org.apache.thrift.protocol.TProtocolException("Required field 'name' is unset! Struct:" + toString());
+ throw new org.apache.storm.thrift.protocol.TProtocolException("Required field 'name' is unset! Struct:" + toString());
}
// check for sub-struct validity
@@ -515,8 +515,8 @@ public class SharedMemory implements org.apache.thrift.TBase<SharedMemory, Share
private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
try {
- write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out)));
- } catch (org.apache.thrift.TException te) {
+ write(new org.apache.storm.thrift.protocol.TCompactProtocol(new org.apache.storm.thrift.transport.TIOStreamTransport(out)));
+ } catch (org.apache.storm.thrift.TException te) {
throw new java.io.IOException(te);
}
}
@@ -525,64 +525,64 @@ public class SharedMemory implements org.apache.thrift.TBase<SharedMemory, Share
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;
- read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
- } catch (org.apache.thrift.TException te) {
+ read(new org.apache.storm.thrift.protocol.TCompactProtocol(new org.apache.storm.thrift.transport.TIOStreamTransport(in)));
+ } catch (org.apache.storm.thrift.TException te) {
throw new java.io.IOException(te);
}
}
- private static class SharedMemoryStandardSchemeFactory implements org.apache.thrift.scheme.SchemeFactory {
+ private static class SharedMemoryStandardSchemeFactory implements org.apache.storm.thrift.scheme.SchemeFactory {
public SharedMemoryStandardScheme getScheme() {
return new SharedMemoryStandardScheme();
}
}
- private static class SharedMemoryStandardScheme extends org.apache.thrift.scheme.StandardScheme<SharedMemory> {
+ private static class SharedMemoryStandardScheme extends org.apache.storm.thrift.scheme.StandardScheme<SharedMemory> {
- public void read(org.apache.thrift.protocol.TProtocol iprot, SharedMemory struct) throws org.apache.thrift.TException {
- org.apache.thrift.protocol.TField schemeField;
+ public void read(org.apache.storm.thrift.protocol.TProtocol iprot, SharedMemory struct) throws org.apache.storm.thrift.TException {
+ org.apache.storm.thrift.protocol.TField schemeField;
iprot.readStructBegin();
while (true)
{
schemeField = iprot.readFieldBegin();
- if (schemeField.type == org.apache.thrift.protocol.TType.STOP) {
+ if (schemeField.type == org.apache.storm.thrift.protocol.TType.STOP) {
break;
}
switch (schemeField.id) {
case 1: // NAME
- if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
+ if (schemeField.type == org.apache.storm.thrift.protocol.TType.STRING) {
struct.name = iprot.readString();
struct.set_name_isSet(true);
} else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ org.apache.storm.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 2: // ON_HEAP
- if (schemeField.type == org.apache.thrift.protocol.TType.DOUBLE) {
+ if (schemeField.type == org.apache.storm.thrift.protocol.TType.DOUBLE) {
struct.on_heap = iprot.readDouble();
struct.set_on_heap_isSet(true);
} else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ org.apache.storm.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 3: // OFF_HEAP_WORKER
- if (schemeField.type == org.apache.thrift.protocol.TType.DOUBLE) {
+ if (schemeField.type == org.apache.storm.thrift.protocol.TType.DOUBLE) {
struct.off_heap_worker = iprot.readDouble();
struct.set_off_heap_worker_isSet(true);
} else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ org.apache.storm.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 4: // OFF_HEAP_NODE
- if (schemeField.type == org.apache.thrift.protocol.TType.DOUBLE) {
+ if (schemeField.type == org.apache.storm.thrift.protocol.TType.DOUBLE) {
struct.off_heap_node = iprot.readDouble();
struct.set_off_heap_node_isSet(true);
} else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ org.apache.storm.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
default:
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ org.apache.storm.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
iprot.readFieldEnd();
}
@@ -590,7 +590,7 @@ public class SharedMemory implements org.apache.thrift.TBase<SharedMemory, Share
struct.validate();
}
- public void write(org.apache.thrift.protocol.TProtocol oprot, SharedMemory struct) throws org.apache.thrift.TException {
+ public void write(org.apache.storm.thrift.protocol.TProtocol oprot, SharedMemory struct) throws org.apache.storm.thrift.TException {
struct.validate();
oprot.writeStructBegin(STRUCT_DESC);
@@ -620,17 +620,17 @@ public class SharedMemory implements org.apache.thrift.TBase<SharedMemory, Share
}
- private static class SharedMemoryTupleSchemeFactory implements org.apache.thrift.scheme.SchemeFactory {
+ private static class SharedMemoryTupleSchemeFactory implements org.apache.storm.thrift.scheme.SchemeFactory {
public SharedMemoryTupleScheme getScheme() {
return new SharedMemoryTupleScheme();
}
}
- private static class SharedMemoryTupleScheme extends org.apache.thrift.scheme.TupleScheme<SharedMemory> {
+ private static class SharedMemoryTupleScheme extends org.apache.storm.thrift.scheme.TupleScheme<SharedMemory> {
@Override
- public void write(org.apache.thrift.protocol.TProtocol prot, SharedMemory struct) throws org.apache.thrift.TException {
- org.apache.thrift.protocol.TTupleProtocol oprot = (org.apache.thrift.protocol.TTupleProtocol) prot;
+ public void write(org.apache.storm.thrift.protocol.TProtocol prot, SharedMemory struct) throws org.apache.storm.thrift.TException {
+ org.apache.storm.thrift.protocol.TTupleProtocol oprot = (org.apache.storm.thrift.protocol.TTupleProtocol) prot;
oprot.writeString(struct.name);
java.util.BitSet optionals = new java.util.BitSet();
if (struct.is_set_on_heap()) {
@@ -655,8 +655,8 @@ public class SharedMemory implements org.apache.thrift.TBase<SharedMemory, Share
}
@Override
- public void read(org.apache.thrift.protocol.TProtocol prot, SharedMemory struct) throws org.apache.thrift.TException {
- org.apache.thrift.protocol.TTupleProtocol iprot = (org.apache.thrift.protocol.TTupleProtocol) prot;
+ public void read(org.apache.storm.thrift.protocol.TProtocol prot, SharedMemory struct) throws org.apache.storm.thrift.TException {
+ org.apache.storm.thrift.protocol.TTupleProtocol iprot = (org.apache.storm.thrift.protocol.TTupleProtocol) prot;
struct.name = iprot.readString();
struct.set_name_isSet(true);
java.util.BitSet incoming = iprot.readBitSet(3);
@@ -675,8 +675,8 @@ public class SharedMemory implements org.apache.thrift.TBase<SharedMemory, Share
}
}
- 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();
+ private static <S extends org.apache.storm.thrift.scheme.IScheme> S scheme(org.apache.storm.thrift.protocol.TProtocol proto) {
+ return (org.apache.storm.thrift.scheme.StandardScheme.class.equals(proto.getScheme()) ? STANDARD_SCHEME_FACTORY : TUPLE_SCHEME_FACTORY).getScheme();
}
}
http://git-wip-us.apache.org/repos/asf/storm/blob/91251c54/storm-client/src/jvm/org/apache/storm/generated/ShellComponent.java
----------------------------------------------------------------------
diff --git a/storm-client/src/jvm/org/apache/storm/generated/ShellComponent.java b/storm-client/src/jvm/org/apache/storm/generated/ShellComponent.java
index 1d9ac63..1b96095 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/ShellComponent.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/ShellComponent.java
@@ -25,20 +25,20 @@ package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.11.0)")
-public class ShellComponent implements org.apache.thrift.TBase<ShellComponent, ShellComponent._Fields>, java.io.Serializable, Cloneable, Comparable<ShellComponent> {
- private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("ShellComponent");
+public class ShellComponent implements org.apache.storm.thrift.TBase<ShellComponent, ShellComponent._Fields>, java.io.Serializable, Cloneable, Comparable<ShellComponent> {
+ private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC = new org.apache.storm.thrift.protocol.TStruct("ShellComponent");
- private static final org.apache.thrift.protocol.TField EXECUTION_COMMAND_FIELD_DESC = new org.apache.thrift.protocol.TField("execution_command", org.apache.thrift.protocol.TType.STRING, (short)1);
- private static final org.apache.thrift.protocol.TField SCRIPT_FIELD_DESC = new org.apache.thrift.protocol.TField("script", org.apache.thrift.protocol.TType.STRING, (short)2);
+ private static final org.apache.storm.thrift.protocol.TField EXECUTION_COMMAND_FIELD_DESC = new org.apache.storm.thrift.protocol.TField("execution_command", org.apache.storm.thrift.protocol.TType.STRING, (short)1);
+ private static final org.apache.storm.thrift.protocol.TField SCRIPT_FIELD_DESC = new org.apache.storm.thrift.protocol.TField("script", org.apache.storm.thrift.protocol.TType.STRING, (short)2);
- private static final org.apache.thrift.scheme.SchemeFactory STANDARD_SCHEME_FACTORY = new ShellComponentStandardSchemeFactory();
- private static final org.apache.thrift.scheme.SchemeFactory TUPLE_SCHEME_FACTORY = new ShellComponentTupleSchemeFactory();
+ private static final org.apache.storm.thrift.scheme.SchemeFactory STANDARD_SCHEME_FACTORY = new ShellComponentStandardSchemeFactory();
+ private static final org.apache.storm.thrift.scheme.SchemeFactory TUPLE_SCHEME_FACTORY = new ShellComponentTupleSchemeFactory();
private java.lang.String execution_command; // required
private java.lang.String script; // required
/** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
- public enum _Fields implements org.apache.thrift.TFieldIdEnum {
+ public enum _Fields implements org.apache.storm.thrift.TFieldIdEnum {
EXECUTION_COMMAND((short)1, "execution_command"),
SCRIPT((short)2, "script");
@@ -99,15 +99,15 @@ public class ShellComponent implements org.apache.thrift.TBase<ShellComponent, S
}
// isset id assignments
- public static final java.util.Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
+ public static final java.util.Map<_Fields, org.apache.storm.thrift.meta_data.FieldMetaData> metaDataMap;
static {
- 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.EXECUTION_COMMAND, new org.apache.thrift.meta_data.FieldMetaData("execution_command", org.apache.thrift.TFieldRequirementType.DEFAULT,
- new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
- tmpMap.put(_Fields.SCRIPT, new org.apache.thrift.meta_data.FieldMetaData("script", org.apache.thrift.TFieldRequirementType.DEFAULT,
- new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
+ java.util.Map<_Fields, org.apache.storm.thrift.meta_data.FieldMetaData> tmpMap = new java.util.EnumMap<_Fields, org.apache.storm.thrift.meta_data.FieldMetaData>(_Fields.class);
+ tmpMap.put(_Fields.EXECUTION_COMMAND, new org.apache.storm.thrift.meta_data.FieldMetaData("execution_command", org.apache.storm.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.storm.thrift.meta_data.FieldValueMetaData(org.apache.storm.thrift.protocol.TType.STRING)));
+ tmpMap.put(_Fields.SCRIPT, new org.apache.storm.thrift.meta_data.FieldMetaData("script", org.apache.storm.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.storm.thrift.meta_data.FieldValueMetaData(org.apache.storm.thrift.protocol.TType.STRING)));
metaDataMap = java.util.Collections.unmodifiableMap(tmpMap);
- org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(ShellComponent.class, metaDataMap);
+ org.apache.storm.thrift.meta_data.FieldMetaData.addStructMetaDataMap(ShellComponent.class, metaDataMap);
}
public ShellComponent() {
@@ -302,7 +302,7 @@ public class ShellComponent implements org.apache.thrift.TBase<ShellComponent, S
return lastComparison;
}
if (is_set_execution_command()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.execution_command, other.execution_command);
+ lastComparison = org.apache.storm.thrift.TBaseHelper.compareTo(this.execution_command, other.execution_command);
if (lastComparison != 0) {
return lastComparison;
}
@@ -312,7 +312,7 @@ public class ShellComponent implements org.apache.thrift.TBase<ShellComponent, S
return lastComparison;
}
if (is_set_script()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.script, other.script);
+ lastComparison = org.apache.storm.thrift.TBaseHelper.compareTo(this.script, other.script);
if (lastComparison != 0) {
return lastComparison;
}
@@ -324,11 +324,11 @@ public class ShellComponent implements org.apache.thrift.TBase<ShellComponent, S
return _Fields.findByThriftId(fieldId);
}
- public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException {
+ public void read(org.apache.storm.thrift.protocol.TProtocol iprot) throws org.apache.storm.thrift.TException {
scheme(iprot).read(iprot, this);
}
- public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
+ public void write(org.apache.storm.thrift.protocol.TProtocol oprot) throws org.apache.storm.thrift.TException {
scheme(oprot).write(oprot, this);
}
@@ -356,63 +356,63 @@ public class ShellComponent implements org.apache.thrift.TBase<ShellComponent, S
return sb.toString();
}
- public void validate() throws org.apache.thrift.TException {
+ public void validate() throws org.apache.storm.thrift.TException {
// check for required fields
// check for sub-struct validity
}
private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
try {
- write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out)));
- } catch (org.apache.thrift.TException te) {
+ write(new org.apache.storm.thrift.protocol.TCompactProtocol(new org.apache.storm.thrift.transport.TIOStreamTransport(out)));
+ } catch (org.apache.storm.thrift.TException te) {
throw new java.io.IOException(te);
}
}
private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, java.lang.ClassNotFoundException {
try {
- read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
- } catch (org.apache.thrift.TException te) {
+ read(new org.apache.storm.thrift.protocol.TCompactProtocol(new org.apache.storm.thrift.transport.TIOStreamTransport(in)));
+ } catch (org.apache.storm.thrift.TException te) {
throw new java.io.IOException(te);
}
}
- private static class ShellComponentStandardSchemeFactory implements org.apache.thrift.scheme.SchemeFactory {
+ private static class ShellComponentStandardSchemeFactory implements org.apache.storm.thrift.scheme.SchemeFactory {
public ShellComponentStandardScheme getScheme() {
return new ShellComponentStandardScheme();
}
}
- private static class ShellComponentStandardScheme extends org.apache.thrift.scheme.StandardScheme<ShellComponent> {
+ private static class ShellComponentStandardScheme extends org.apache.storm.thrift.scheme.StandardScheme<ShellComponent> {
- public void read(org.apache.thrift.protocol.TProtocol iprot, ShellComponent struct) throws org.apache.thrift.TException {
- org.apache.thrift.protocol.TField schemeField;
+ public void read(org.apache.storm.thrift.protocol.TProtocol iprot, ShellComponent struct) throws org.apache.storm.thrift.TException {
+ org.apache.storm.thrift.protocol.TField schemeField;
iprot.readStructBegin();
while (true)
{
schemeField = iprot.readFieldBegin();
- if (schemeField.type == org.apache.thrift.protocol.TType.STOP) {
+ if (schemeField.type == org.apache.storm.thrift.protocol.TType.STOP) {
break;
}
switch (schemeField.id) {
case 1: // EXECUTION_COMMAND
- if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
+ if (schemeField.type == org.apache.storm.thrift.protocol.TType.STRING) {
struct.execution_command = iprot.readString();
struct.set_execution_command_isSet(true);
} else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ org.apache.storm.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 2: // SCRIPT
- if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
+ if (schemeField.type == org.apache.storm.thrift.protocol.TType.STRING) {
struct.script = iprot.readString();
struct.set_script_isSet(true);
} else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ org.apache.storm.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
default:
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ org.apache.storm.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
iprot.readFieldEnd();
}
@@ -420,7 +420,7 @@ public class ShellComponent implements org.apache.thrift.TBase<ShellComponent, S
struct.validate();
}
- public void write(org.apache.thrift.protocol.TProtocol oprot, ShellComponent struct) throws org.apache.thrift.TException {
+ public void write(org.apache.storm.thrift.protocol.TProtocol oprot, ShellComponent struct) throws org.apache.storm.thrift.TException {
struct.validate();
oprot.writeStructBegin(STRUCT_DESC);
@@ -440,17 +440,17 @@ public class ShellComponent implements org.apache.thrift.TBase<ShellComponent, S
}
- private static class ShellComponentTupleSchemeFactory implements org.apache.thrift.scheme.SchemeFactory {
+ private static class ShellComponentTupleSchemeFactory implements org.apache.storm.thrift.scheme.SchemeFactory {
public ShellComponentTupleScheme getScheme() {
return new ShellComponentTupleScheme();
}
}
- private static class ShellComponentTupleScheme extends org.apache.thrift.scheme.TupleScheme<ShellComponent> {
+ private static class ShellComponentTupleScheme extends org.apache.storm.thrift.scheme.TupleScheme<ShellComponent> {
@Override
- public void write(org.apache.thrift.protocol.TProtocol prot, ShellComponent struct) throws org.apache.thrift.TException {
- org.apache.thrift.protocol.TTupleProtocol oprot = (org.apache.thrift.protocol.TTupleProtocol) prot;
+ public void write(org.apache.storm.thrift.protocol.TProtocol prot, ShellComponent struct) throws org.apache.storm.thrift.TException {
+ org.apache.storm.thrift.protocol.TTupleProtocol oprot = (org.apache.storm.thrift.protocol.TTupleProtocol) prot;
java.util.BitSet optionals = new java.util.BitSet();
if (struct.is_set_execution_command()) {
optionals.set(0);
@@ -468,8 +468,8 @@ public class ShellComponent implements org.apache.thrift.TBase<ShellComponent, S
}
@Override
- public void read(org.apache.thrift.protocol.TProtocol prot, ShellComponent struct) throws org.apache.thrift.TException {
- org.apache.thrift.protocol.TTupleProtocol iprot = (org.apache.thrift.protocol.TTupleProtocol) prot;
+ public void read(org.apache.storm.thrift.protocol.TProtocol prot, ShellComponent struct) throws org.apache.storm.thrift.TException {
+ org.apache.storm.thrift.protocol.TTupleProtocol iprot = (org.apache.storm.thrift.protocol.TTupleProtocol) prot;
java.util.BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
struct.execution_command = iprot.readString();
@@ -482,8 +482,8 @@ public class ShellComponent implements org.apache.thrift.TBase<ShellComponent, S
}
}
- 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();
+ private static <S extends org.apache.storm.thrift.scheme.IScheme> S scheme(org.apache.storm.thrift.protocol.TProtocol proto) {
+ return (org.apache.storm.thrift.scheme.StandardScheme.class.equals(proto.getScheme()) ? STANDARD_SCHEME_FACTORY : TUPLE_SCHEME_FACTORY).getScheme();
}
}
http://git-wip-us.apache.org/repos/asf/storm/blob/91251c54/storm-client/src/jvm/org/apache/storm/generated/SpecificAggregateStats.java
----------------------------------------------------------------------
diff --git a/storm-client/src/jvm/org/apache/storm/generated/SpecificAggregateStats.java b/storm-client/src/jvm/org/apache/storm/generated/SpecificAggregateStats.java
index 293004b..aa90abe 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/SpecificAggregateStats.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/SpecificAggregateStats.java
@@ -24,13 +24,13 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
-public class SpecificAggregateStats extends org.apache.thrift.TUnion<SpecificAggregateStats, SpecificAggregateStats._Fields> {
- private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("SpecificAggregateStats");
- private static final org.apache.thrift.protocol.TField BOLT_FIELD_DESC = new org.apache.thrift.protocol.TField("bolt", org.apache.thrift.protocol.TType.STRUCT, (short)1);
- private static final org.apache.thrift.protocol.TField SPOUT_FIELD_DESC = new org.apache.thrift.protocol.TField("spout", org.apache.thrift.protocol.TType.STRUCT, (short)2);
+public class SpecificAggregateStats extends org.apache.storm.thrift.TUnion<SpecificAggregateStats, SpecificAggregateStats._Fields> {
+ private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC = new org.apache.storm.thrift.protocol.TStruct("SpecificAggregateStats");
+ private static final org.apache.storm.thrift.protocol.TField BOLT_FIELD_DESC = new org.apache.storm.thrift.protocol.TField("bolt", org.apache.storm.thrift.protocol.TType.STRUCT, (short)1);
+ private static final org.apache.storm.thrift.protocol.TField SPOUT_FIELD_DESC = new org.apache.storm.thrift.protocol.TField("spout", org.apache.storm.thrift.protocol.TType.STRUCT, (short)2);
/** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
- public enum _Fields implements org.apache.thrift.TFieldIdEnum {
+ public enum _Fields implements org.apache.storm.thrift.TFieldIdEnum {
BOLT((short)1, "bolt"),
SPOUT((short)2, "spout");
@@ -90,15 +90,15 @@ public class SpecificAggregateStats extends org.apache.thrift.TUnion<SpecificAgg
}
}
- public static final java.util.Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
+ public static final java.util.Map<_Fields, org.apache.storm.thrift.meta_data.FieldMetaData> metaDataMap;
static {
- 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.BOLT, new org.apache.thrift.meta_data.FieldMetaData("bolt", org.apache.thrift.TFieldRequirementType.OPTIONAL,
- new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, BoltAggregateStats.class)));
- tmpMap.put(_Fields.SPOUT, new org.apache.thrift.meta_data.FieldMetaData("spout", org.apache.thrift.TFieldRequirementType.OPTIONAL,
- new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, SpoutAggregateStats.class)));
+ java.util.Map<_Fields, org.apache.storm.thrift.meta_data.FieldMetaData> tmpMap = new java.util.EnumMap<_Fields, org.apache.storm.thrift.meta_data.FieldMetaData>(_Fields.class);
+ tmpMap.put(_Fields.BOLT, new org.apache.storm.thrift.meta_data.FieldMetaData("bolt", org.apache.storm.thrift.TFieldRequirementType.OPTIONAL,
+ new org.apache.storm.thrift.meta_data.StructMetaData(org.apache.storm.thrift.protocol.TType.STRUCT, BoltAggregateStats.class)));
+ tmpMap.put(_Fields.SPOUT, new org.apache.storm.thrift.meta_data.FieldMetaData("spout", org.apache.storm.thrift.TFieldRequirementType.OPTIONAL,
+ new org.apache.storm.thrift.meta_data.StructMetaData(org.apache.storm.thrift.protocol.TType.STRUCT, SpoutAggregateStats.class)));
metaDataMap = java.util.Collections.unmodifiableMap(tmpMap);
- org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(SpecificAggregateStats.class, metaDataMap);
+ org.apache.storm.thrift.meta_data.FieldMetaData.addStructMetaDataMap(SpecificAggregateStats.class, metaDataMap);
}
public SpecificAggregateStats() {
@@ -148,7 +148,7 @@ public class SpecificAggregateStats extends org.apache.thrift.TUnion<SpecificAgg
}
@Override
- protected java.lang.Object standardSchemeReadValue(org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TField field) throws org.apache.thrift.TException {
+ protected java.lang.Object standardSchemeReadValue(org.apache.storm.thrift.protocol.TProtocol iprot, org.apache.storm.thrift.protocol.TField field) throws org.apache.storm.thrift.TException {
_Fields setField = _Fields.findByThriftId(field.id);
if (setField != null) {
switch (setField) {
@@ -159,7 +159,7 @@ public class SpecificAggregateStats extends org.apache.thrift.TUnion<SpecificAgg
bolt.read(iprot);
return bolt;
} else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
+ org.apache.storm.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
return null;
}
case SPOUT:
@@ -169,20 +169,20 @@ public class SpecificAggregateStats extends org.apache.thrift.TUnion<SpecificAgg
spout.read(iprot);
return spout;
} else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
+ org.apache.storm.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
return null;
}
default:
throw new java.lang.IllegalStateException("setField wasn't null, but didn't match any of the case statements!");
}
} else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
+ org.apache.storm.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
return null;
}
}
@Override
- protected void standardSchemeWriteValue(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
+ protected void standardSchemeWriteValue(org.apache.storm.thrift.protocol.TProtocol oprot) throws org.apache.storm.thrift.TException {
switch (setField_) {
case BOLT:
BoltAggregateStats bolt = (BoltAggregateStats)value_;
@@ -198,7 +198,7 @@ public class SpecificAggregateStats extends org.apache.thrift.TUnion<SpecificAgg
}
@Override
- protected java.lang.Object tupleSchemeReadValue(org.apache.thrift.protocol.TProtocol iprot, short fieldID) throws org.apache.thrift.TException {
+ protected java.lang.Object tupleSchemeReadValue(org.apache.storm.thrift.protocol.TProtocol iprot, short fieldID) throws org.apache.storm.thrift.TException {
_Fields setField = _Fields.findByThriftId(fieldID);
if (setField != null) {
switch (setField) {
@@ -216,12 +216,12 @@ public class SpecificAggregateStats extends org.apache.thrift.TUnion<SpecificAgg
throw new java.lang.IllegalStateException("setField wasn't null, but didn't match any of the case statements!");
}
} else {
- throw new org.apache.thrift.protocol.TProtocolException("Couldn't find a field with field id " + fieldID);
+ throw new org.apache.storm.thrift.protocol.TProtocolException("Couldn't find a field with field id " + fieldID);
}
}
@Override
- protected void tupleSchemeWriteValue(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
+ protected void tupleSchemeWriteValue(org.apache.storm.thrift.protocol.TProtocol oprot) throws org.apache.storm.thrift.TException {
switch (setField_) {
case BOLT:
BoltAggregateStats bolt = (BoltAggregateStats)value_;
@@ -237,7 +237,7 @@ public class SpecificAggregateStats extends org.apache.thrift.TUnion<SpecificAgg
}
@Override
- protected org.apache.thrift.protocol.TField getFieldDesc(_Fields setField) {
+ protected org.apache.storm.thrift.protocol.TField getFieldDesc(_Fields setField) {
switch (setField) {
case BOLT:
return BOLT_FIELD_DESC;
@@ -249,7 +249,7 @@ public class SpecificAggregateStats extends org.apache.thrift.TUnion<SpecificAgg
}
@Override
- protected org.apache.thrift.protocol.TStruct getStructDesc() {
+ protected org.apache.storm.thrift.protocol.TStruct getStructDesc() {
return STRUCT_DESC;
}
@@ -315,9 +315,9 @@ public class SpecificAggregateStats extends org.apache.thrift.TUnion<SpecificAgg
@Override
public int compareTo(SpecificAggregateStats other) {
- int lastComparison = org.apache.thrift.TBaseHelper.compareTo(getSetField(), other.getSetField());
+ int lastComparison = org.apache.storm.thrift.TBaseHelper.compareTo(getSetField(), other.getSetField());
if (lastComparison == 0) {
- return org.apache.thrift.TBaseHelper.compareTo(getFieldValue(), other.getFieldValue());
+ return org.apache.storm.thrift.TBaseHelper.compareTo(getFieldValue(), other.getFieldValue());
}
return lastComparison;
}
@@ -327,12 +327,12 @@ public class SpecificAggregateStats extends org.apache.thrift.TUnion<SpecificAgg
public int hashCode() {
java.util.List<java.lang.Object> list = new java.util.ArrayList<java.lang.Object>();
list.add(this.getClass().getName());
- org.apache.thrift.TFieldIdEnum setField = getSetField();
+ org.apache.storm.thrift.TFieldIdEnum setField = getSetField();
if (setField != null) {
list.add(setField.getThriftFieldId());
java.lang.Object value = getFieldValue();
- if (value instanceof org.apache.thrift.TEnum) {
- list.add(((org.apache.thrift.TEnum)getFieldValue()).getValue());
+ if (value instanceof org.apache.storm.thrift.TEnum) {
+ list.add(((org.apache.storm.thrift.TEnum)getFieldValue()).getValue());
} else {
list.add(value);
}
@@ -341,8 +341,8 @@ public class SpecificAggregateStats extends org.apache.thrift.TUnion<SpecificAgg
}
private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
try {
- write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out)));
- } catch (org.apache.thrift.TException te) {
+ write(new org.apache.storm.thrift.protocol.TCompactProtocol(new org.apache.storm.thrift.transport.TIOStreamTransport(out)));
+ } catch (org.apache.storm.thrift.TException te) {
throw new java.io.IOException(te);
}
}
@@ -350,8 +350,8 @@ public class SpecificAggregateStats extends org.apache.thrift.TUnion<SpecificAgg
private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, java.lang.ClassNotFoundException {
try {
- read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
- } catch (org.apache.thrift.TException te) {
+ read(new org.apache.storm.thrift.protocol.TCompactProtocol(new org.apache.storm.thrift.transport.TIOStreamTransport(in)));
+ } catch (org.apache.storm.thrift.TException te) {
throw new java.io.IOException(te);
}
}
http://git-wip-us.apache.org/repos/asf/storm/blob/91251c54/storm-client/src/jvm/org/apache/storm/generated/SpoutAggregateStats.java
----------------------------------------------------------------------
diff --git a/storm-client/src/jvm/org/apache/storm/generated/SpoutAggregateStats.java b/storm-client/src/jvm/org/apache/storm/generated/SpoutAggregateStats.java
index 796f6ad..eccf8c3 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/SpoutAggregateStats.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/SpoutAggregateStats.java
@@ -25,18 +25,18 @@ package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.11.0)")
-public class SpoutAggregateStats implements org.apache.thrift.TBase<SpoutAggregateStats, SpoutAggregateStats._Fields>, java.io.Serializable, Cloneable, Comparable<SpoutAggregateStats> {
- private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("SpoutAggregateStats");
+public class SpoutAggregateStats implements org.apache.storm.thrift.TBase<SpoutAggregateStats, SpoutAggregateStats._Fields>, java.io.Serializable, Cloneable, Comparable<SpoutAggregateStats> {
+ private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC = new org.apache.storm.thrift.protocol.TStruct("SpoutAggregateStats");
- private static final org.apache.thrift.protocol.TField COMPLETE_LATENCY_MS_FIELD_DESC = new org.apache.thrift.protocol.TField("complete_latency_ms", org.apache.thrift.protocol.TType.DOUBLE, (short)1);
+ private static final org.apache.storm.thrift.protocol.TField COMPLETE_LATENCY_MS_FIELD_DESC = new org.apache.storm.thrift.protocol.TField("complete_latency_ms", org.apache.storm.thrift.protocol.TType.DOUBLE, (short)1);
- private static final org.apache.thrift.scheme.SchemeFactory STANDARD_SCHEME_FACTORY = new SpoutAggregateStatsStandardSchemeFactory();
- private static final org.apache.thrift.scheme.SchemeFactory TUPLE_SCHEME_FACTORY = new SpoutAggregateStatsTupleSchemeFactory();
+ private static final org.apache.storm.thrift.scheme.SchemeFactory STANDARD_SCHEME_FACTORY = new SpoutAggregateStatsStandardSchemeFactory();
+ private static final org.apache.storm.thrift.scheme.SchemeFactory TUPLE_SCHEME_FACTORY = new SpoutAggregateStatsTupleSchemeFactory();
private double complete_latency_ms; // optional
/** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
- public enum _Fields implements org.apache.thrift.TFieldIdEnum {
+ public enum _Fields implements org.apache.storm.thrift.TFieldIdEnum {
COMPLETE_LATENCY_MS((short)1, "complete_latency_ms");
private static final java.util.Map<java.lang.String, _Fields> byName = new java.util.HashMap<java.lang.String, _Fields>();
@@ -97,13 +97,13 @@ public class SpoutAggregateStats implements org.apache.thrift.TBase<SpoutAggrega
private static final int __COMPLETE_LATENCY_MS_ISSET_ID = 0;
private byte __isset_bitfield = 0;
private static final _Fields optionals[] = {_Fields.COMPLETE_LATENCY_MS};
- public static final java.util.Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
+ public static final java.util.Map<_Fields, org.apache.storm.thrift.meta_data.FieldMetaData> metaDataMap;
static {
- 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.COMPLETE_LATENCY_MS, new org.apache.thrift.meta_data.FieldMetaData("complete_latency_ms", org.apache.thrift.TFieldRequirementType.OPTIONAL,
- new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.DOUBLE)));
+ java.util.Map<_Fields, org.apache.storm.thrift.meta_data.FieldMetaData> tmpMap = new java.util.EnumMap<_Fields, org.apache.storm.thrift.meta_data.FieldMetaData>(_Fields.class);
+ tmpMap.put(_Fields.COMPLETE_LATENCY_MS, new org.apache.storm.thrift.meta_data.FieldMetaData("complete_latency_ms", org.apache.storm.thrift.TFieldRequirementType.OPTIONAL,
+ new org.apache.storm.thrift.meta_data.FieldValueMetaData(org.apache.storm.thrift.protocol.TType.DOUBLE)));
metaDataMap = java.util.Collections.unmodifiableMap(tmpMap);
- org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(SpoutAggregateStats.class, metaDataMap);
+ org.apache.storm.thrift.meta_data.FieldMetaData.addStructMetaDataMap(SpoutAggregateStats.class, metaDataMap);
}
public SpoutAggregateStats() {
@@ -137,16 +137,16 @@ public class SpoutAggregateStats implements org.apache.thrift.TBase<SpoutAggrega
}
public void unset_complete_latency_ms() {
- __isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __COMPLETE_LATENCY_MS_ISSET_ID);
+ __isset_bitfield = org.apache.storm.thrift.EncodingUtils.clearBit(__isset_bitfield, __COMPLETE_LATENCY_MS_ISSET_ID);
}
/** Returns true if field complete_latency_ms is set (has been assigned a value) and false otherwise */
public boolean is_set_complete_latency_ms() {
- return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __COMPLETE_LATENCY_MS_ISSET_ID);
+ return org.apache.storm.thrift.EncodingUtils.testBit(__isset_bitfield, __COMPLETE_LATENCY_MS_ISSET_ID);
}
public void set_complete_latency_ms_isSet(boolean value) {
- __isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __COMPLETE_LATENCY_MS_ISSET_ID, value);
+ __isset_bitfield = org.apache.storm.thrift.EncodingUtils.setBit(__isset_bitfield, __COMPLETE_LATENCY_MS_ISSET_ID, value);
}
public void setFieldValue(_Fields field, java.lang.Object value) {
@@ -217,7 +217,7 @@ public class SpoutAggregateStats implements org.apache.thrift.TBase<SpoutAggrega
hashCode = hashCode * 8191 + ((is_set_complete_latency_ms()) ? 131071 : 524287);
if (is_set_complete_latency_ms())
- hashCode = hashCode * 8191 + org.apache.thrift.TBaseHelper.hashCode(complete_latency_ms);
+ hashCode = hashCode * 8191 + org.apache.storm.thrift.TBaseHelper.hashCode(complete_latency_ms);
return hashCode;
}
@@ -235,7 +235,7 @@ public class SpoutAggregateStats implements org.apache.thrift.TBase<SpoutAggrega
return lastComparison;
}
if (is_set_complete_latency_ms()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.complete_latency_ms, other.complete_latency_ms);
+ lastComparison = org.apache.storm.thrift.TBaseHelper.compareTo(this.complete_latency_ms, other.complete_latency_ms);
if (lastComparison != 0) {
return lastComparison;
}
@@ -247,11 +247,11 @@ public class SpoutAggregateStats implements org.apache.thrift.TBase<SpoutAggrega
return _Fields.findByThriftId(fieldId);
}
- public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException {
+ public void read(org.apache.storm.thrift.protocol.TProtocol iprot) throws org.apache.storm.thrift.TException {
scheme(iprot).read(iprot, this);
}
- public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
+ public void write(org.apache.storm.thrift.protocol.TProtocol oprot) throws org.apache.storm.thrift.TException {
scheme(oprot).write(oprot, this);
}
@@ -269,15 +269,15 @@ public class SpoutAggregateStats implements org.apache.thrift.TBase<SpoutAggrega
return sb.toString();
}
- public void validate() throws org.apache.thrift.TException {
+ public void validate() throws org.apache.storm.thrift.TException {
// check for required fields
// check for sub-struct validity
}
private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
try {
- write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out)));
- } catch (org.apache.thrift.TException te) {
+ write(new org.apache.storm.thrift.protocol.TCompactProtocol(new org.apache.storm.thrift.transport.TIOStreamTransport(out)));
+ } catch (org.apache.storm.thrift.TException te) {
throw new java.io.IOException(te);
}
}
@@ -286,40 +286,40 @@ public class SpoutAggregateStats implements org.apache.thrift.TBase<SpoutAggrega
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;
- read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
- } catch (org.apache.thrift.TException te) {
+ read(new org.apache.storm.thrift.protocol.TCompactProtocol(new org.apache.storm.thrift.transport.TIOStreamTransport(in)));
+ } catch (org.apache.storm.thrift.TException te) {
throw new java.io.IOException(te);
}
}
- private static class SpoutAggregateStatsStandardSchemeFactory implements org.apache.thrift.scheme.SchemeFactory {
+ private static class SpoutAggregateStatsStandardSchemeFactory implements org.apache.storm.thrift.scheme.SchemeFactory {
public SpoutAggregateStatsStandardScheme getScheme() {
return new SpoutAggregateStatsStandardScheme();
}
}
- private static class SpoutAggregateStatsStandardScheme extends org.apache.thrift.scheme.StandardScheme<SpoutAggregateStats> {
+ private static class SpoutAggregateStatsStandardScheme extends org.apache.storm.thrift.scheme.StandardScheme<SpoutAggregateStats> {
- public void read(org.apache.thrift.protocol.TProtocol iprot, SpoutAggregateStats struct) throws org.apache.thrift.TException {
- org.apache.thrift.protocol.TField schemeField;
+ public void read(org.apache.storm.thrift.protocol.TProtocol iprot, SpoutAggregateStats struct) throws org.apache.storm.thrift.TException {
+ org.apache.storm.thrift.protocol.TField schemeField;
iprot.readStructBegin();
while (true)
{
schemeField = iprot.readFieldBegin();
- if (schemeField.type == org.apache.thrift.protocol.TType.STOP) {
+ if (schemeField.type == org.apache.storm.thrift.protocol.TType.STOP) {
break;
}
switch (schemeField.id) {
case 1: // COMPLETE_LATENCY_MS
- if (schemeField.type == org.apache.thrift.protocol.TType.DOUBLE) {
+ if (schemeField.type == org.apache.storm.thrift.protocol.TType.DOUBLE) {
struct.complete_latency_ms = iprot.readDouble();
struct.set_complete_latency_ms_isSet(true);
} else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ org.apache.storm.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
default:
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ org.apache.storm.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
iprot.readFieldEnd();
}
@@ -327,7 +327,7 @@ public class SpoutAggregateStats implements org.apache.thrift.TBase<SpoutAggrega
struct.validate();
}
- public void write(org.apache.thrift.protocol.TProtocol oprot, SpoutAggregateStats struct) throws org.apache.thrift.TException {
+ public void write(org.apache.storm.thrift.protocol.TProtocol oprot, SpoutAggregateStats struct) throws org.apache.storm.thrift.TException {
struct.validate();
oprot.writeStructBegin(STRUCT_DESC);
@@ -342,17 +342,17 @@ public class SpoutAggregateStats implements org.apache.thrift.TBase<SpoutAggrega
}
- private static class SpoutAggregateStatsTupleSchemeFactory implements org.apache.thrift.scheme.SchemeFactory {
+ private static class SpoutAggregateStatsTupleSchemeFactory implements org.apache.storm.thrift.scheme.SchemeFactory {
public SpoutAggregateStatsTupleScheme getScheme() {
return new SpoutAggregateStatsTupleScheme();
}
}
- private static class SpoutAggregateStatsTupleScheme extends org.apache.thrift.scheme.TupleScheme<SpoutAggregateStats> {
+ private static class SpoutAggregateStatsTupleScheme extends org.apache.storm.thrift.scheme.TupleScheme<SpoutAggregateStats> {
@Override
- public void write(org.apache.thrift.protocol.TProtocol prot, SpoutAggregateStats struct) throws org.apache.thrift.TException {
- org.apache.thrift.protocol.TTupleProtocol oprot = (org.apache.thrift.protocol.TTupleProtocol) prot;
+ public void write(org.apache.storm.thrift.protocol.TProtocol prot, SpoutAggregateStats struct) throws org.apache.storm.thrift.TException {
+ org.apache.storm.thrift.protocol.TTupleProtocol oprot = (org.apache.storm.thrift.protocol.TTupleProtocol) prot;
java.util.BitSet optionals = new java.util.BitSet();
if (struct.is_set_complete_latency_ms()) {
optionals.set(0);
@@ -364,8 +364,8 @@ public class SpoutAggregateStats implements org.apache.thrift.TBase<SpoutAggrega
}
@Override
- public void read(org.apache.thrift.protocol.TProtocol prot, SpoutAggregateStats struct) throws org.apache.thrift.TException {
- org.apache.thrift.protocol.TTupleProtocol iprot = (org.apache.thrift.protocol.TTupleProtocol) prot;
+ public void read(org.apache.storm.thrift.protocol.TProtocol prot, SpoutAggregateStats struct) throws org.apache.storm.thrift.TException {
+ org.apache.storm.thrift.protocol.TTupleProtocol iprot = (org.apache.storm.thrift.protocol.TTupleProtocol) prot;
java.util.BitSet incoming = iprot.readBitSet(1);
if (incoming.get(0)) {
struct.complete_latency_ms = iprot.readDouble();
@@ -374,8 +374,8 @@ public class SpoutAggregateStats implements org.apache.thrift.TBase<SpoutAggrega
}
}
- 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();
+ private static <S extends org.apache.storm.thrift.scheme.IScheme> S scheme(org.apache.storm.thrift.protocol.TProtocol proto) {
+ return (org.apache.storm.thrift.scheme.StandardScheme.class.equals(proto.getScheme()) ? STANDARD_SCHEME_FACTORY : TUPLE_SCHEME_FACTORY).getScheme();
}
}