You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by ka...@apache.org on 2016/10/11 23:51:03 UTC
[25/59] [abbrv] [partial] storm git commit: Ported successfully.
http://git-wip-us.apache.org/repos/asf/storm/blob/a6171bd6/storm-core/src/jvm/backtype/storm/generated/ErrorInfo.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/ErrorInfo.java b/storm-core/src/jvm/backtype/storm/generated/ErrorInfo.java
deleted file mode 100644
index 2ab536d..0000000
--- a/storm-core/src/jvm/backtype/storm/generated/ErrorInfo.java
+++ /dev/null
@@ -1,714 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-/**
- * Autogenerated by Thrift Compiler (0.9.3)
- *
- * 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)")
-public class ErrorInfo implements org.apache.thrift.TBase<ErrorInfo, ErrorInfo._Fields>, java.io.Serializable, Cloneable, Comparable<ErrorInfo> {
- private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("ErrorInfo");
-
- private static final org.apache.thrift.protocol.TField ERROR_FIELD_DESC = new org.apache.thrift.protocol.TField("error", org.apache.thrift.protocol.TType.STRING, (short)1);
- private static final org.apache.thrift.protocol.TField ERROR_TIME_SECS_FIELD_DESC = new org.apache.thrift.protocol.TField("error_time_secs", org.apache.thrift.protocol.TType.I32, (short)2);
- private static final org.apache.thrift.protocol.TField HOST_FIELD_DESC = new org.apache.thrift.protocol.TField("host", org.apache.thrift.protocol.TType.STRING, (short)3);
- private static final org.apache.thrift.protocol.TField PORT_FIELD_DESC = new org.apache.thrift.protocol.TField("port", org.apache.thrift.protocol.TType.I32, (short)4);
-
- private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
- static {
- schemes.put(StandardScheme.class, new ErrorInfoStandardSchemeFactory());
- schemes.put(TupleScheme.class, new ErrorInfoTupleSchemeFactory());
- }
-
- private String error; // required
- private int error_time_secs; // required
- private String host; // optional
- private int port; // 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 {
- ERROR((short)1, "error"),
- ERROR_TIME_SECS((short)2, "error_time_secs"),
- HOST((short)3, "host"),
- PORT((short)4, "port");
-
- private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
-
- static {
- for (_Fields field : EnumSet.allOf(_Fields.class)) {
- byName.put(field.getFieldName(), field);
- }
- }
-
- /**
- * Find the _Fields constant that matches fieldId, or null if its not found.
- */
- public static _Fields findByThriftId(int fieldId) {
- switch(fieldId) {
- case 1: // ERROR
- return ERROR;
- case 2: // ERROR_TIME_SECS
- return ERROR_TIME_SECS;
- case 3: // HOST
- return HOST;
- case 4: // PORT
- return PORT;
- default:
- return null;
- }
- }
-
- /**
- * Find the _Fields constant that matches fieldId, throwing an exception
- * if it is not found.
- */
- public static _Fields findByThriftIdOrThrow(int fieldId) {
- _Fields fields = findByThriftId(fieldId);
- if (fields == null) throw new 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) {
- return byName.get(name);
- }
-
- private final short _thriftId;
- private final String _fieldName;
-
- _Fields(short thriftId, String fieldName) {
- _thriftId = thriftId;
- _fieldName = fieldName;
- }
-
- public short getThriftFieldId() {
- return _thriftId;
- }
-
- public String getFieldName() {
- return _fieldName;
- }
- }
-
- // isset id assignments
- private static final int __ERROR_TIME_SECS_ISSET_ID = 0;
- private static final int __PORT_ISSET_ID = 1;
- private byte __isset_bitfield = 0;
- private static final _Fields optionals[] = {_Fields.HOST,_Fields.PORT};
- public static final 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);
- tmpMap.put(_Fields.ERROR, new org.apache.thrift.meta_data.FieldMetaData("error", org.apache.thrift.TFieldRequirementType.REQUIRED,
- new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
- tmpMap.put(_Fields.ERROR_TIME_SECS, new org.apache.thrift.meta_data.FieldMetaData("error_time_secs", org.apache.thrift.TFieldRequirementType.REQUIRED,
- new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32)));
- tmpMap.put(_Fields.HOST, new org.apache.thrift.meta_data.FieldMetaData("host", org.apache.thrift.TFieldRequirementType.OPTIONAL,
- new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
- tmpMap.put(_Fields.PORT, new org.apache.thrift.meta_data.FieldMetaData("port", org.apache.thrift.TFieldRequirementType.OPTIONAL,
- new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32)));
- metaDataMap = Collections.unmodifiableMap(tmpMap);
- org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(ErrorInfo.class, metaDataMap);
- }
-
- public ErrorInfo() {
- }
-
- public ErrorInfo(
- String error,
- int error_time_secs)
- {
- this();
- this.error = error;
- this.error_time_secs = error_time_secs;
- set_error_time_secs_isSet(true);
- }
-
- /**
- * Performs a deep copy on <i>other</i>.
- */
- public ErrorInfo(ErrorInfo other) {
- __isset_bitfield = other.__isset_bitfield;
- if (other.is_set_error()) {
- this.error = other.error;
- }
- this.error_time_secs = other.error_time_secs;
- if (other.is_set_host()) {
- this.host = other.host;
- }
- this.port = other.port;
- }
-
- public ErrorInfo deepCopy() {
- return new ErrorInfo(this);
- }
-
- @Override
- public void clear() {
- this.error = null;
- set_error_time_secs_isSet(false);
- this.error_time_secs = 0;
- this.host = null;
- set_port_isSet(false);
- this.port = 0;
- }
-
- public String get_error() {
- return this.error;
- }
-
- public void set_error(String error) {
- this.error = error;
- }
-
- public void unset_error() {
- this.error = null;
- }
-
- /** Returns true if field error is set (has been assigned a value) and false otherwise */
- public boolean is_set_error() {
- return this.error != null;
- }
-
- public void set_error_isSet(boolean value) {
- if (!value) {
- this.error = null;
- }
- }
-
- public int get_error_time_secs() {
- return this.error_time_secs;
- }
-
- public void set_error_time_secs(int error_time_secs) {
- this.error_time_secs = error_time_secs;
- set_error_time_secs_isSet(true);
- }
-
- public void unset_error_time_secs() {
- __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __ERROR_TIME_SECS_ISSET_ID);
- }
-
- /** Returns true if field error_time_secs is set (has been assigned a value) and false otherwise */
- public boolean is_set_error_time_secs() {
- return EncodingUtils.testBit(__isset_bitfield, __ERROR_TIME_SECS_ISSET_ID);
- }
-
- public void set_error_time_secs_isSet(boolean value) {
- __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __ERROR_TIME_SECS_ISSET_ID, value);
- }
-
- public String get_host() {
- return this.host;
- }
-
- public void set_host(String host) {
- this.host = host;
- }
-
- public void unset_host() {
- this.host = null;
- }
-
- /** Returns true if field host is set (has been assigned a value) and false otherwise */
- public boolean is_set_host() {
- return this.host != null;
- }
-
- public void set_host_isSet(boolean value) {
- if (!value) {
- this.host = null;
- }
- }
-
- public int get_port() {
- return this.port;
- }
-
- public void set_port(int port) {
- this.port = port;
- set_port_isSet(true);
- }
-
- public void unset_port() {
- __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __PORT_ISSET_ID);
- }
-
- /** Returns true if field port is set (has been assigned a value) and false otherwise */
- public boolean is_set_port() {
- return EncodingUtils.testBit(__isset_bitfield, __PORT_ISSET_ID);
- }
-
- public void set_port_isSet(boolean value) {
- __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __PORT_ISSET_ID, value);
- }
-
- public void setFieldValue(_Fields field, Object value) {
- switch (field) {
- case ERROR:
- if (value == null) {
- unset_error();
- } else {
- set_error((String)value);
- }
- break;
-
- case ERROR_TIME_SECS:
- if (value == null) {
- unset_error_time_secs();
- } else {
- set_error_time_secs((Integer)value);
- }
- break;
-
- case HOST:
- if (value == null) {
- unset_host();
- } else {
- set_host((String)value);
- }
- break;
-
- case PORT:
- if (value == null) {
- unset_port();
- } else {
- set_port((Integer)value);
- }
- break;
-
- }
- }
-
- public Object getFieldValue(_Fields field) {
- switch (field) {
- case ERROR:
- return get_error();
-
- case ERROR_TIME_SECS:
- return get_error_time_secs();
-
- case HOST:
- return get_host();
-
- case PORT:
- return get_port();
-
- }
- throw new 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();
- }
-
- switch (field) {
- case ERROR:
- return is_set_error();
- case ERROR_TIME_SECS:
- return is_set_error_time_secs();
- case HOST:
- return is_set_host();
- case PORT:
- return is_set_port();
- }
- throw new IllegalStateException();
- }
-
- @Override
- public boolean equals(Object that) {
- if (that == null)
- return false;
- if (that instanceof ErrorInfo)
- return this.equals((ErrorInfo)that);
- return false;
- }
-
- public boolean equals(ErrorInfo that) {
- if (that == null)
- return false;
-
- boolean this_present_error = true && this.is_set_error();
- boolean that_present_error = true && that.is_set_error();
- if (this_present_error || that_present_error) {
- if (!(this_present_error && that_present_error))
- return false;
- if (!this.error.equals(that.error))
- return false;
- }
-
- boolean this_present_error_time_secs = true;
- boolean that_present_error_time_secs = true;
- if (this_present_error_time_secs || that_present_error_time_secs) {
- if (!(this_present_error_time_secs && that_present_error_time_secs))
- return false;
- if (this.error_time_secs != that.error_time_secs)
- return false;
- }
-
- boolean this_present_host = true && this.is_set_host();
- boolean that_present_host = true && that.is_set_host();
- if (this_present_host || that_present_host) {
- if (!(this_present_host && that_present_host))
- return false;
- if (!this.host.equals(that.host))
- return false;
- }
-
- boolean this_present_port = true && this.is_set_port();
- boolean that_present_port = true && that.is_set_port();
- if (this_present_port || that_present_port) {
- if (!(this_present_port && that_present_port))
- return false;
- if (this.port != that.port)
- return false;
- }
-
- return true;
- }
-
- @Override
- public int hashCode() {
- List<Object> list = new ArrayList<Object>();
-
- boolean present_error = true && (is_set_error());
- list.add(present_error);
- if (present_error)
- list.add(error);
-
- boolean present_error_time_secs = true;
- list.add(present_error_time_secs);
- if (present_error_time_secs)
- list.add(error_time_secs);
-
- boolean present_host = true && (is_set_host());
- list.add(present_host);
- if (present_host)
- list.add(host);
-
- boolean present_port = true && (is_set_port());
- list.add(present_port);
- if (present_port)
- list.add(port);
-
- return list.hashCode();
- }
-
- @Override
- public int compareTo(ErrorInfo other) {
- if (!getClass().equals(other.getClass())) {
- return getClass().getName().compareTo(other.getClass().getName());
- }
-
- int lastComparison = 0;
-
- lastComparison = Boolean.valueOf(is_set_error()).compareTo(other.is_set_error());
- if (lastComparison != 0) {
- return lastComparison;
- }
- if (is_set_error()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.error, other.error);
- if (lastComparison != 0) {
- return lastComparison;
- }
- }
- lastComparison = Boolean.valueOf(is_set_error_time_secs()).compareTo(other.is_set_error_time_secs());
- if (lastComparison != 0) {
- return lastComparison;
- }
- if (is_set_error_time_secs()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.error_time_secs, other.error_time_secs);
- if (lastComparison != 0) {
- return lastComparison;
- }
- }
- lastComparison = Boolean.valueOf(is_set_host()).compareTo(other.is_set_host());
- if (lastComparison != 0) {
- return lastComparison;
- }
- if (is_set_host()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.host, other.host);
- if (lastComparison != 0) {
- return lastComparison;
- }
- }
- lastComparison = Boolean.valueOf(is_set_port()).compareTo(other.is_set_port());
- if (lastComparison != 0) {
- return lastComparison;
- }
- if (is_set_port()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.port, other.port);
- if (lastComparison != 0) {
- return lastComparison;
- }
- }
- return 0;
- }
-
- public _Fields fieldForId(int fieldId) {
- return _Fields.findByThriftId(fieldId);
- }
-
- public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException {
- schemes.get(iprot.getScheme()).getScheme().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);
- }
-
- @Override
- public String toString() {
- StringBuilder sb = new StringBuilder("ErrorInfo(");
- boolean first = true;
-
- sb.append("error:");
- if (this.error == null) {
- sb.append("null");
- } else {
- sb.append(this.error);
- }
- first = false;
- if (!first) sb.append(", ");
- sb.append("error_time_secs:");
- sb.append(this.error_time_secs);
- first = false;
- if (is_set_host()) {
- if (!first) sb.append(", ");
- sb.append("host:");
- if (this.host == null) {
- sb.append("null");
- } else {
- sb.append(this.host);
- }
- first = false;
- }
- if (is_set_port()) {
- if (!first) sb.append(", ");
- sb.append("port:");
- sb.append(this.port);
- first = false;
- }
- sb.append(")");
- return sb.toString();
- }
-
- public void validate() throws org.apache.thrift.TException {
- // check for required fields
- if (!is_set_error()) {
- throw new org.apache.thrift.protocol.TProtocolException("Required field 'error' is unset! Struct:" + toString());
- }
-
- if (!is_set_error_time_secs()) {
- throw new org.apache.thrift.protocol.TProtocolException("Required field 'error_time_secs' is unset! Struct:" + toString());
- }
-
- // 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) {
- throw new java.io.IOException(te);
- }
- }
-
- private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, 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;
- read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
- } catch (org.apache.thrift.TException te) {
- throw new java.io.IOException(te);
- }
- }
-
- private static class ErrorInfoStandardSchemeFactory implements SchemeFactory {
- public ErrorInfoStandardScheme getScheme() {
- return new ErrorInfoStandardScheme();
- }
- }
-
- private static class ErrorInfoStandardScheme extends StandardScheme<ErrorInfo> {
-
- public void read(org.apache.thrift.protocol.TProtocol iprot, ErrorInfo struct) throws org.apache.thrift.TException {
- org.apache.thrift.protocol.TField schemeField;
- iprot.readStructBegin();
- while (true)
- {
- schemeField = iprot.readFieldBegin();
- if (schemeField.type == org.apache.thrift.protocol.TType.STOP) {
- break;
- }
- switch (schemeField.id) {
- case 1: // ERROR
- if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
- struct.error = iprot.readString();
- struct.set_error_isSet(true);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
- }
- break;
- case 2: // ERROR_TIME_SECS
- if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
- struct.error_time_secs = iprot.readI32();
- struct.set_error_time_secs_isSet(true);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
- }
- break;
- case 3: // HOST
- if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
- struct.host = iprot.readString();
- struct.set_host_isSet(true);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
- }
- break;
- case 4: // PORT
- if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
- struct.port = iprot.readI32();
- struct.set_port_isSet(true);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
- }
- break;
- default:
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
- }
- iprot.readFieldEnd();
- }
- iprot.readStructEnd();
- struct.validate();
- }
-
- public void write(org.apache.thrift.protocol.TProtocol oprot, ErrorInfo struct) throws org.apache.thrift.TException {
- struct.validate();
-
- oprot.writeStructBegin(STRUCT_DESC);
- if (struct.error != null) {
- oprot.writeFieldBegin(ERROR_FIELD_DESC);
- oprot.writeString(struct.error);
- oprot.writeFieldEnd();
- }
- oprot.writeFieldBegin(ERROR_TIME_SECS_FIELD_DESC);
- oprot.writeI32(struct.error_time_secs);
- oprot.writeFieldEnd();
- if (struct.host != null) {
- if (struct.is_set_host()) {
- oprot.writeFieldBegin(HOST_FIELD_DESC);
- oprot.writeString(struct.host);
- oprot.writeFieldEnd();
- }
- }
- if (struct.is_set_port()) {
- oprot.writeFieldBegin(PORT_FIELD_DESC);
- oprot.writeI32(struct.port);
- oprot.writeFieldEnd();
- }
- oprot.writeFieldStop();
- oprot.writeStructEnd();
- }
-
- }
-
- private static class ErrorInfoTupleSchemeFactory implements SchemeFactory {
- public ErrorInfoTupleScheme getScheme() {
- return new ErrorInfoTupleScheme();
- }
- }
-
- private static class ErrorInfoTupleScheme extends TupleScheme<ErrorInfo> {
-
- @Override
- public void write(org.apache.thrift.protocol.TProtocol prot, ErrorInfo struct) throws org.apache.thrift.TException {
- TTupleProtocol oprot = (TTupleProtocol) prot;
- oprot.writeString(struct.error);
- oprot.writeI32(struct.error_time_secs);
- BitSet optionals = new BitSet();
- if (struct.is_set_host()) {
- optionals.set(0);
- }
- if (struct.is_set_port()) {
- optionals.set(1);
- }
- oprot.writeBitSet(optionals, 2);
- if (struct.is_set_host()) {
- oprot.writeString(struct.host);
- }
- if (struct.is_set_port()) {
- oprot.writeI32(struct.port);
- }
- }
-
- @Override
- public void read(org.apache.thrift.protocol.TProtocol prot, ErrorInfo struct) throws org.apache.thrift.TException {
- TTupleProtocol iprot = (TTupleProtocol) prot;
- struct.error = iprot.readString();
- struct.set_error_isSet(true);
- struct.error_time_secs = iprot.readI32();
- struct.set_error_time_secs_isSet(true);
- BitSet incoming = iprot.readBitSet(2);
- if (incoming.get(0)) {
- struct.host = iprot.readString();
- struct.set_host_isSet(true);
- }
- if (incoming.get(1)) {
- struct.port = iprot.readI32();
- struct.set_port_isSet(true);
- }
- }
- }
-
-}
-
http://git-wip-us.apache.org/repos/asf/storm/blob/a6171bd6/storm-core/src/jvm/backtype/storm/generated/ExecutorAggregateStats.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/ExecutorAggregateStats.java b/storm-core/src/jvm/backtype/storm/generated/ExecutorAggregateStats.java
deleted file mode 100644
index 5bc85e0..0000000
--- a/storm-core/src/jvm/backtype/storm/generated/ExecutorAggregateStats.java
+++ /dev/null
@@ -1,526 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-/**
- * Autogenerated by Thrift Compiler (0.9.3)
- *
- * 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)")
-public class ExecutorAggregateStats implements org.apache.thrift.TBase<ExecutorAggregateStats, ExecutorAggregateStats._Fields>, java.io.Serializable, Cloneable, Comparable<ExecutorAggregateStats> {
- private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("ExecutorAggregateStats");
-
- private static final org.apache.thrift.protocol.TField EXEC_SUMMARY_FIELD_DESC = new org.apache.thrift.protocol.TField("exec_summary", org.apache.thrift.protocol.TType.STRUCT, (short)1);
- private static final org.apache.thrift.protocol.TField STATS_FIELD_DESC = new org.apache.thrift.protocol.TField("stats", org.apache.thrift.protocol.TType.STRUCT, (short)2);
-
- private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
- static {
- schemes.put(StandardScheme.class, new ExecutorAggregateStatsStandardSchemeFactory());
- schemes.put(TupleScheme.class, new ExecutorAggregateStatsTupleSchemeFactory());
- }
-
- private ExecutorSummary exec_summary; // optional
- private ComponentAggregateStats stats; // 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 {
- EXEC_SUMMARY((short)1, "exec_summary"),
- STATS((short)2, "stats");
-
- private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
-
- static {
- for (_Fields field : EnumSet.allOf(_Fields.class)) {
- byName.put(field.getFieldName(), field);
- }
- }
-
- /**
- * Find the _Fields constant that matches fieldId, or null if its not found.
- */
- public static _Fields findByThriftId(int fieldId) {
- switch(fieldId) {
- case 1: // EXEC_SUMMARY
- return EXEC_SUMMARY;
- case 2: // STATS
- return STATS;
- default:
- return null;
- }
- }
-
- /**
- * Find the _Fields constant that matches fieldId, throwing an exception
- * if it is not found.
- */
- public static _Fields findByThriftIdOrThrow(int fieldId) {
- _Fields fields = findByThriftId(fieldId);
- if (fields == null) throw new 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) {
- return byName.get(name);
- }
-
- private final short _thriftId;
- private final String _fieldName;
-
- _Fields(short thriftId, String fieldName) {
- _thriftId = thriftId;
- _fieldName = fieldName;
- }
-
- public short getThriftFieldId() {
- return _thriftId;
- }
-
- public String getFieldName() {
- return _fieldName;
- }
- }
-
- // isset id assignments
- private static final _Fields optionals[] = {_Fields.EXEC_SUMMARY,_Fields.STATS};
- public static final 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);
- tmpMap.put(_Fields.EXEC_SUMMARY, new org.apache.thrift.meta_data.FieldMetaData("exec_summary", org.apache.thrift.TFieldRequirementType.OPTIONAL,
- new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, ExecutorSummary.class)));
- tmpMap.put(_Fields.STATS, new org.apache.thrift.meta_data.FieldMetaData("stats", org.apache.thrift.TFieldRequirementType.OPTIONAL,
- new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, ComponentAggregateStats.class)));
- metaDataMap = Collections.unmodifiableMap(tmpMap);
- org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(ExecutorAggregateStats.class, metaDataMap);
- }
-
- public ExecutorAggregateStats() {
- }
-
- /**
- * Performs a deep copy on <i>other</i>.
- */
- public ExecutorAggregateStats(ExecutorAggregateStats other) {
- if (other.is_set_exec_summary()) {
- this.exec_summary = new ExecutorSummary(other.exec_summary);
- }
- if (other.is_set_stats()) {
- this.stats = new ComponentAggregateStats(other.stats);
- }
- }
-
- public ExecutorAggregateStats deepCopy() {
- return new ExecutorAggregateStats(this);
- }
-
- @Override
- public void clear() {
- this.exec_summary = null;
- this.stats = null;
- }
-
- public ExecutorSummary get_exec_summary() {
- return this.exec_summary;
- }
-
- public void set_exec_summary(ExecutorSummary exec_summary) {
- this.exec_summary = exec_summary;
- }
-
- public void unset_exec_summary() {
- this.exec_summary = null;
- }
-
- /** Returns true if field exec_summary is set (has been assigned a value) and false otherwise */
- public boolean is_set_exec_summary() {
- return this.exec_summary != null;
- }
-
- public void set_exec_summary_isSet(boolean value) {
- if (!value) {
- this.exec_summary = null;
- }
- }
-
- public ComponentAggregateStats get_stats() {
- return this.stats;
- }
-
- public void set_stats(ComponentAggregateStats stats) {
- this.stats = stats;
- }
-
- public void unset_stats() {
- this.stats = null;
- }
-
- /** Returns true if field stats is set (has been assigned a value) and false otherwise */
- public boolean is_set_stats() {
- return this.stats != null;
- }
-
- public void set_stats_isSet(boolean value) {
- if (!value) {
- this.stats = null;
- }
- }
-
- public void setFieldValue(_Fields field, Object value) {
- switch (field) {
- case EXEC_SUMMARY:
- if (value == null) {
- unset_exec_summary();
- } else {
- set_exec_summary((ExecutorSummary)value);
- }
- break;
-
- case STATS:
- if (value == null) {
- unset_stats();
- } else {
- set_stats((ComponentAggregateStats)value);
- }
- break;
-
- }
- }
-
- public Object getFieldValue(_Fields field) {
- switch (field) {
- case EXEC_SUMMARY:
- return get_exec_summary();
-
- case STATS:
- return get_stats();
-
- }
- throw new 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();
- }
-
- switch (field) {
- case EXEC_SUMMARY:
- return is_set_exec_summary();
- case STATS:
- return is_set_stats();
- }
- throw new IllegalStateException();
- }
-
- @Override
- public boolean equals(Object that) {
- if (that == null)
- return false;
- if (that instanceof ExecutorAggregateStats)
- return this.equals((ExecutorAggregateStats)that);
- return false;
- }
-
- public boolean equals(ExecutorAggregateStats that) {
- if (that == null)
- return false;
-
- boolean this_present_exec_summary = true && this.is_set_exec_summary();
- boolean that_present_exec_summary = true && that.is_set_exec_summary();
- if (this_present_exec_summary || that_present_exec_summary) {
- if (!(this_present_exec_summary && that_present_exec_summary))
- return false;
- if (!this.exec_summary.equals(that.exec_summary))
- return false;
- }
-
- boolean this_present_stats = true && this.is_set_stats();
- boolean that_present_stats = true && that.is_set_stats();
- if (this_present_stats || that_present_stats) {
- if (!(this_present_stats && that_present_stats))
- return false;
- if (!this.stats.equals(that.stats))
- return false;
- }
-
- return true;
- }
-
- @Override
- public int hashCode() {
- List<Object> list = new ArrayList<Object>();
-
- boolean present_exec_summary = true && (is_set_exec_summary());
- list.add(present_exec_summary);
- if (present_exec_summary)
- list.add(exec_summary);
-
- boolean present_stats = true && (is_set_stats());
- list.add(present_stats);
- if (present_stats)
- list.add(stats);
-
- return list.hashCode();
- }
-
- @Override
- public int compareTo(ExecutorAggregateStats other) {
- if (!getClass().equals(other.getClass())) {
- return getClass().getName().compareTo(other.getClass().getName());
- }
-
- int lastComparison = 0;
-
- lastComparison = Boolean.valueOf(is_set_exec_summary()).compareTo(other.is_set_exec_summary());
- if (lastComparison != 0) {
- return lastComparison;
- }
- if (is_set_exec_summary()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.exec_summary, other.exec_summary);
- if (lastComparison != 0) {
- return lastComparison;
- }
- }
- lastComparison = Boolean.valueOf(is_set_stats()).compareTo(other.is_set_stats());
- if (lastComparison != 0) {
- return lastComparison;
- }
- if (is_set_stats()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.stats, other.stats);
- if (lastComparison != 0) {
- return lastComparison;
- }
- }
- return 0;
- }
-
- public _Fields fieldForId(int fieldId) {
- return _Fields.findByThriftId(fieldId);
- }
-
- public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException {
- schemes.get(iprot.getScheme()).getScheme().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);
- }
-
- @Override
- public String toString() {
- StringBuilder sb = new StringBuilder("ExecutorAggregateStats(");
- boolean first = true;
-
- if (is_set_exec_summary()) {
- sb.append("exec_summary:");
- if (this.exec_summary == null) {
- sb.append("null");
- } else {
- sb.append(this.exec_summary);
- }
- first = false;
- }
- if (is_set_stats()) {
- if (!first) sb.append(", ");
- sb.append("stats:");
- if (this.stats == null) {
- sb.append("null");
- } else {
- sb.append(this.stats);
- }
- first = false;
- }
- sb.append(")");
- return sb.toString();
- }
-
- public void validate() throws org.apache.thrift.TException {
- // check for required fields
- // check for sub-struct validity
- if (exec_summary != null) {
- exec_summary.validate();
- }
- if (stats != null) {
- stats.validate();
- }
- }
-
- 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) {
- throw new java.io.IOException(te);
- }
- }
-
- private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
- try {
- read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
- } catch (org.apache.thrift.TException te) {
- throw new java.io.IOException(te);
- }
- }
-
- private static class ExecutorAggregateStatsStandardSchemeFactory implements SchemeFactory {
- public ExecutorAggregateStatsStandardScheme getScheme() {
- return new ExecutorAggregateStatsStandardScheme();
- }
- }
-
- private static class ExecutorAggregateStatsStandardScheme extends StandardScheme<ExecutorAggregateStats> {
-
- public void read(org.apache.thrift.protocol.TProtocol iprot, ExecutorAggregateStats struct) throws org.apache.thrift.TException {
- org.apache.thrift.protocol.TField schemeField;
- iprot.readStructBegin();
- while (true)
- {
- schemeField = iprot.readFieldBegin();
- if (schemeField.type == org.apache.thrift.protocol.TType.STOP) {
- break;
- }
- switch (schemeField.id) {
- case 1: // EXEC_SUMMARY
- if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
- struct.exec_summary = new ExecutorSummary();
- struct.exec_summary.read(iprot);
- struct.set_exec_summary_isSet(true);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
- }
- break;
- case 2: // STATS
- if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
- struct.stats = new ComponentAggregateStats();
- struct.stats.read(iprot);
- struct.set_stats_isSet(true);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
- }
- break;
- default:
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
- }
- iprot.readFieldEnd();
- }
- iprot.readStructEnd();
- struct.validate();
- }
-
- public void write(org.apache.thrift.protocol.TProtocol oprot, ExecutorAggregateStats struct) throws org.apache.thrift.TException {
- struct.validate();
-
- oprot.writeStructBegin(STRUCT_DESC);
- if (struct.exec_summary != null) {
- if (struct.is_set_exec_summary()) {
- oprot.writeFieldBegin(EXEC_SUMMARY_FIELD_DESC);
- struct.exec_summary.write(oprot);
- oprot.writeFieldEnd();
- }
- }
- if (struct.stats != null) {
- if (struct.is_set_stats()) {
- oprot.writeFieldBegin(STATS_FIELD_DESC);
- struct.stats.write(oprot);
- oprot.writeFieldEnd();
- }
- }
- oprot.writeFieldStop();
- oprot.writeStructEnd();
- }
-
- }
-
- private static class ExecutorAggregateStatsTupleSchemeFactory implements SchemeFactory {
- public ExecutorAggregateStatsTupleScheme getScheme() {
- return new ExecutorAggregateStatsTupleScheme();
- }
- }
-
- private static class ExecutorAggregateStatsTupleScheme extends TupleScheme<ExecutorAggregateStats> {
-
- @Override
- public void write(org.apache.thrift.protocol.TProtocol prot, ExecutorAggregateStats struct) throws org.apache.thrift.TException {
- TTupleProtocol oprot = (TTupleProtocol) prot;
- BitSet optionals = new BitSet();
- if (struct.is_set_exec_summary()) {
- optionals.set(0);
- }
- if (struct.is_set_stats()) {
- optionals.set(1);
- }
- oprot.writeBitSet(optionals, 2);
- if (struct.is_set_exec_summary()) {
- struct.exec_summary.write(oprot);
- }
- if (struct.is_set_stats()) {
- struct.stats.write(oprot);
- }
- }
-
- @Override
- public void read(org.apache.thrift.protocol.TProtocol prot, ExecutorAggregateStats struct) throws org.apache.thrift.TException {
- TTupleProtocol iprot = (TTupleProtocol) prot;
- BitSet incoming = iprot.readBitSet(2);
- if (incoming.get(0)) {
- struct.exec_summary = new ExecutorSummary();
- struct.exec_summary.read(iprot);
- struct.set_exec_summary_isSet(true);
- }
- if (incoming.get(1)) {
- struct.stats = new ComponentAggregateStats();
- struct.stats.read(iprot);
- struct.set_stats_isSet(true);
- }
- }
- }
-
-}
-
http://git-wip-us.apache.org/repos/asf/storm/blob/a6171bd6/storm-core/src/jvm/backtype/storm/generated/ExecutorInfo.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/ExecutorInfo.java b/storm-core/src/jvm/backtype/storm/generated/ExecutorInfo.java
deleted file mode 100644
index b3d7bab..0000000
--- a/storm-core/src/jvm/backtype/storm/generated/ExecutorInfo.java
+++ /dev/null
@@ -1,499 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-/**
- * Autogenerated by Thrift Compiler (0.9.3)
- *
- * 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)")
-public class ExecutorInfo implements org.apache.thrift.TBase<ExecutorInfo, ExecutorInfo._Fields>, java.io.Serializable, Cloneable, Comparable<ExecutorInfo> {
- private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("ExecutorInfo");
-
- private static final org.apache.thrift.protocol.TField TASK_START_FIELD_DESC = new org.apache.thrift.protocol.TField("task_start", org.apache.thrift.protocol.TType.I32, (short)1);
- private static final org.apache.thrift.protocol.TField TASK_END_FIELD_DESC = new org.apache.thrift.protocol.TField("task_end", org.apache.thrift.protocol.TType.I32, (short)2);
-
- private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
- static {
- schemes.put(StandardScheme.class, new ExecutorInfoStandardSchemeFactory());
- schemes.put(TupleScheme.class, new ExecutorInfoTupleSchemeFactory());
- }
-
- private int task_start; // required
- private int task_end; // 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 {
- TASK_START((short)1, "task_start"),
- TASK_END((short)2, "task_end");
-
- private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
-
- static {
- for (_Fields field : EnumSet.allOf(_Fields.class)) {
- byName.put(field.getFieldName(), field);
- }
- }
-
- /**
- * Find the _Fields constant that matches fieldId, or null if its not found.
- */
- public static _Fields findByThriftId(int fieldId) {
- switch(fieldId) {
- case 1: // TASK_START
- return TASK_START;
- case 2: // TASK_END
- return TASK_END;
- default:
- return null;
- }
- }
-
- /**
- * Find the _Fields constant that matches fieldId, throwing an exception
- * if it is not found.
- */
- public static _Fields findByThriftIdOrThrow(int fieldId) {
- _Fields fields = findByThriftId(fieldId);
- if (fields == null) throw new 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) {
- return byName.get(name);
- }
-
- private final short _thriftId;
- private final String _fieldName;
-
- _Fields(short thriftId, String fieldName) {
- _thriftId = thriftId;
- _fieldName = fieldName;
- }
-
- public short getThriftFieldId() {
- return _thriftId;
- }
-
- public String getFieldName() {
- return _fieldName;
- }
- }
-
- // isset id assignments
- private static final int __TASK_START_ISSET_ID = 0;
- private static final int __TASK_END_ISSET_ID = 1;
- private byte __isset_bitfield = 0;
- public static final 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);
- tmpMap.put(_Fields.TASK_START, new org.apache.thrift.meta_data.FieldMetaData("task_start", org.apache.thrift.TFieldRequirementType.REQUIRED,
- new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32)));
- tmpMap.put(_Fields.TASK_END, new org.apache.thrift.meta_data.FieldMetaData("task_end", org.apache.thrift.TFieldRequirementType.REQUIRED,
- new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32)));
- metaDataMap = Collections.unmodifiableMap(tmpMap);
- org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(ExecutorInfo.class, metaDataMap);
- }
-
- public ExecutorInfo() {
- }
-
- public ExecutorInfo(
- int task_start,
- int task_end)
- {
- this();
- this.task_start = task_start;
- set_task_start_isSet(true);
- this.task_end = task_end;
- set_task_end_isSet(true);
- }
-
- /**
- * Performs a deep copy on <i>other</i>.
- */
- public ExecutorInfo(ExecutorInfo other) {
- __isset_bitfield = other.__isset_bitfield;
- this.task_start = other.task_start;
- this.task_end = other.task_end;
- }
-
- public ExecutorInfo deepCopy() {
- return new ExecutorInfo(this);
- }
-
- @Override
- public void clear() {
- set_task_start_isSet(false);
- this.task_start = 0;
- set_task_end_isSet(false);
- this.task_end = 0;
- }
-
- public int get_task_start() {
- return this.task_start;
- }
-
- public void set_task_start(int task_start) {
- this.task_start = task_start;
- set_task_start_isSet(true);
- }
-
- public void unset_task_start() {
- __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __TASK_START_ISSET_ID);
- }
-
- /** Returns true if field task_start is set (has been assigned a value) and false otherwise */
- public boolean is_set_task_start() {
- return EncodingUtils.testBit(__isset_bitfield, __TASK_START_ISSET_ID);
- }
-
- public void set_task_start_isSet(boolean value) {
- __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __TASK_START_ISSET_ID, value);
- }
-
- public int get_task_end() {
- return this.task_end;
- }
-
- public void set_task_end(int task_end) {
- this.task_end = task_end;
- set_task_end_isSet(true);
- }
-
- public void unset_task_end() {
- __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __TASK_END_ISSET_ID);
- }
-
- /** Returns true if field task_end is set (has been assigned a value) and false otherwise */
- public boolean is_set_task_end() {
- return EncodingUtils.testBit(__isset_bitfield, __TASK_END_ISSET_ID);
- }
-
- public void set_task_end_isSet(boolean value) {
- __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __TASK_END_ISSET_ID, value);
- }
-
- public void setFieldValue(_Fields field, Object value) {
- switch (field) {
- case TASK_START:
- if (value == null) {
- unset_task_start();
- } else {
- set_task_start((Integer)value);
- }
- break;
-
- case TASK_END:
- if (value == null) {
- unset_task_end();
- } else {
- set_task_end((Integer)value);
- }
- break;
-
- }
- }
-
- public Object getFieldValue(_Fields field) {
- switch (field) {
- case TASK_START:
- return get_task_start();
-
- case TASK_END:
- return get_task_end();
-
- }
- throw new 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();
- }
-
- switch (field) {
- case TASK_START:
- return is_set_task_start();
- case TASK_END:
- return is_set_task_end();
- }
- throw new IllegalStateException();
- }
-
- @Override
- public boolean equals(Object that) {
- if (that == null)
- return false;
- if (that instanceof ExecutorInfo)
- return this.equals((ExecutorInfo)that);
- return false;
- }
-
- public boolean equals(ExecutorInfo that) {
- if (that == null)
- return false;
-
- boolean this_present_task_start = true;
- boolean that_present_task_start = true;
- if (this_present_task_start || that_present_task_start) {
- if (!(this_present_task_start && that_present_task_start))
- return false;
- if (this.task_start != that.task_start)
- return false;
- }
-
- boolean this_present_task_end = true;
- boolean that_present_task_end = true;
- if (this_present_task_end || that_present_task_end) {
- if (!(this_present_task_end && that_present_task_end))
- return false;
- if (this.task_end != that.task_end)
- return false;
- }
-
- return true;
- }
-
- @Override
- public int hashCode() {
- List<Object> list = new ArrayList<Object>();
-
- boolean present_task_start = true;
- list.add(present_task_start);
- if (present_task_start)
- list.add(task_start);
-
- boolean present_task_end = true;
- list.add(present_task_end);
- if (present_task_end)
- list.add(task_end);
-
- return list.hashCode();
- }
-
- @Override
- public int compareTo(ExecutorInfo other) {
- if (!getClass().equals(other.getClass())) {
- return getClass().getName().compareTo(other.getClass().getName());
- }
-
- int lastComparison = 0;
-
- lastComparison = Boolean.valueOf(is_set_task_start()).compareTo(other.is_set_task_start());
- if (lastComparison != 0) {
- return lastComparison;
- }
- if (is_set_task_start()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.task_start, other.task_start);
- if (lastComparison != 0) {
- return lastComparison;
- }
- }
- lastComparison = Boolean.valueOf(is_set_task_end()).compareTo(other.is_set_task_end());
- if (lastComparison != 0) {
- return lastComparison;
- }
- if (is_set_task_end()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.task_end, other.task_end);
- if (lastComparison != 0) {
- return lastComparison;
- }
- }
- return 0;
- }
-
- public _Fields fieldForId(int fieldId) {
- return _Fields.findByThriftId(fieldId);
- }
-
- public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException {
- schemes.get(iprot.getScheme()).getScheme().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);
- }
-
- @Override
- public String toString() {
- StringBuilder sb = new StringBuilder("ExecutorInfo(");
- boolean first = true;
-
- sb.append("task_start:");
- sb.append(this.task_start);
- first = false;
- if (!first) sb.append(", ");
- sb.append("task_end:");
- sb.append(this.task_end);
- first = false;
- sb.append(")");
- return sb.toString();
- }
-
- public void validate() throws org.apache.thrift.TException {
- // check for required fields
- if (!is_set_task_start()) {
- throw new org.apache.thrift.protocol.TProtocolException("Required field 'task_start' is unset! Struct:" + toString());
- }
-
- if (!is_set_task_end()) {
- throw new org.apache.thrift.protocol.TProtocolException("Required field 'task_end' is unset! Struct:" + toString());
- }
-
- // 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) {
- throw new java.io.IOException(te);
- }
- }
-
- private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, 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;
- read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
- } catch (org.apache.thrift.TException te) {
- throw new java.io.IOException(te);
- }
- }
-
- private static class ExecutorInfoStandardSchemeFactory implements SchemeFactory {
- public ExecutorInfoStandardScheme getScheme() {
- return new ExecutorInfoStandardScheme();
- }
- }
-
- private static class ExecutorInfoStandardScheme extends StandardScheme<ExecutorInfo> {
-
- public void read(org.apache.thrift.protocol.TProtocol iprot, ExecutorInfo struct) throws org.apache.thrift.TException {
- org.apache.thrift.protocol.TField schemeField;
- iprot.readStructBegin();
- while (true)
- {
- schemeField = iprot.readFieldBegin();
- if (schemeField.type == org.apache.thrift.protocol.TType.STOP) {
- break;
- }
- switch (schemeField.id) {
- case 1: // TASK_START
- if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
- struct.task_start = iprot.readI32();
- struct.set_task_start_isSet(true);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
- }
- break;
- case 2: // TASK_END
- if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
- struct.task_end = iprot.readI32();
- struct.set_task_end_isSet(true);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
- }
- break;
- default:
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
- }
- iprot.readFieldEnd();
- }
- iprot.readStructEnd();
- struct.validate();
- }
-
- public void write(org.apache.thrift.protocol.TProtocol oprot, ExecutorInfo struct) throws org.apache.thrift.TException {
- struct.validate();
-
- oprot.writeStructBegin(STRUCT_DESC);
- oprot.writeFieldBegin(TASK_START_FIELD_DESC);
- oprot.writeI32(struct.task_start);
- oprot.writeFieldEnd();
- oprot.writeFieldBegin(TASK_END_FIELD_DESC);
- oprot.writeI32(struct.task_end);
- oprot.writeFieldEnd();
- oprot.writeFieldStop();
- oprot.writeStructEnd();
- }
-
- }
-
- private static class ExecutorInfoTupleSchemeFactory implements SchemeFactory {
- public ExecutorInfoTupleScheme getScheme() {
- return new ExecutorInfoTupleScheme();
- }
- }
-
- private static class ExecutorInfoTupleScheme extends TupleScheme<ExecutorInfo> {
-
- @Override
- public void write(org.apache.thrift.protocol.TProtocol prot, ExecutorInfo struct) throws org.apache.thrift.TException {
- TTupleProtocol oprot = (TTupleProtocol) prot;
- oprot.writeI32(struct.task_start);
- oprot.writeI32(struct.task_end);
- }
-
- @Override
- public void read(org.apache.thrift.protocol.TProtocol prot, ExecutorInfo struct) throws org.apache.thrift.TException {
- TTupleProtocol iprot = (TTupleProtocol) prot;
- struct.task_start = iprot.readI32();
- struct.set_task_start_isSet(true);
- struct.task_end = iprot.readI32();
- struct.set_task_end_isSet(true);
- }
- }
-
-}
-
http://git-wip-us.apache.org/repos/asf/storm/blob/a6171bd6/storm-core/src/jvm/backtype/storm/generated/ExecutorSpecificStats.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/ExecutorSpecificStats.java b/storm-core/src/jvm/backtype/storm/generated/ExecutorSpecificStats.java
deleted file mode 100644
index d91f197..0000000
--- a/storm-core/src/jvm/backtype/storm/generated/ExecutorSpecificStats.java
+++ /dev/null
@@ -1,387 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-/**
- * Autogenerated by Thrift Compiler (0.9.3)
- *
- * 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"})
-public class ExecutorSpecificStats extends org.apache.thrift.TUnion<ExecutorSpecificStats, ExecutorSpecificStats._Fields> {
- private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("ExecutorSpecificStats");
- 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);
-
- /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
- public enum _Fields implements org.apache.thrift.TFieldIdEnum {
- BOLT((short)1, "bolt"),
- SPOUT((short)2, "spout");
-
- private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
-
- static {
- for (_Fields field : EnumSet.allOf(_Fields.class)) {
- byName.put(field.getFieldName(), field);
- }
- }
-
- /**
- * Find the _Fields constant that matches fieldId, or null if its not found.
- */
- public static _Fields findByThriftId(int fieldId) {
- switch(fieldId) {
- case 1: // BOLT
- return BOLT;
- case 2: // SPOUT
- return SPOUT;
- default:
- return null;
- }
- }
-
- /**
- * Find the _Fields constant that matches fieldId, throwing an exception
- * if it is not found.
- */
- public static _Fields findByThriftIdOrThrow(int fieldId) {
- _Fields fields = findByThriftId(fieldId);
- if (fields == null) throw new 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) {
- return byName.get(name);
- }
-
- private final short _thriftId;
- private final String _fieldName;
-
- _Fields(short thriftId, String fieldName) {
- _thriftId = thriftId;
- _fieldName = fieldName;
- }
-
- public short getThriftFieldId() {
- return _thriftId;
- }
-
- public String getFieldName() {
- return _fieldName;
- }
- }
-
- public static final 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);
- tmpMap.put(_Fields.BOLT, new org.apache.thrift.meta_data.FieldMetaData("bolt", org.apache.thrift.TFieldRequirementType.DEFAULT,
- new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, BoltStats.class)));
- tmpMap.put(_Fields.SPOUT, new org.apache.thrift.meta_data.FieldMetaData("spout", org.apache.thrift.TFieldRequirementType.DEFAULT,
- new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, SpoutStats.class)));
- metaDataMap = Collections.unmodifiableMap(tmpMap);
- org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(ExecutorSpecificStats.class, metaDataMap);
- }
-
- public ExecutorSpecificStats() {
- super();
- }
-
- public ExecutorSpecificStats(_Fields setField, Object value) {
- super(setField, value);
- }
-
- public ExecutorSpecificStats(ExecutorSpecificStats other) {
- super(other);
- }
- public ExecutorSpecificStats deepCopy() {
- return new ExecutorSpecificStats(this);
- }
-
- public static ExecutorSpecificStats bolt(BoltStats value) {
- ExecutorSpecificStats x = new ExecutorSpecificStats();
- x.set_bolt(value);
- return x;
- }
-
- public static ExecutorSpecificStats spout(SpoutStats value) {
- ExecutorSpecificStats x = new ExecutorSpecificStats();
- x.set_spout(value);
- return x;
- }
-
-
- @Override
- protected void checkType(_Fields setField, Object value) throws ClassCastException {
- switch (setField) {
- case BOLT:
- if (value instanceof BoltStats) {
- break;
- }
- throw new ClassCastException("Was expecting value of type BoltStats for field 'bolt', but got " + value.getClass().getSimpleName());
- case SPOUT:
- if (value instanceof SpoutStats) {
- break;
- }
- throw new ClassCastException("Was expecting value of type SpoutStats for field 'spout', but got " + value.getClass().getSimpleName());
- default:
- throw new IllegalArgumentException("Unknown field id " + setField);
- }
- }
-
- @Override
- protected Object standardSchemeReadValue(org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TField field) throws org.apache.thrift.TException {
- _Fields setField = _Fields.findByThriftId(field.id);
- if (setField != null) {
- switch (setField) {
- case BOLT:
- if (field.type == BOLT_FIELD_DESC.type) {
- BoltStats bolt;
- bolt = new BoltStats();
- bolt.read(iprot);
- return bolt;
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- return null;
- }
- case SPOUT:
- if (field.type == SPOUT_FIELD_DESC.type) {
- SpoutStats spout;
- spout = new SpoutStats();
- spout.read(iprot);
- return spout;
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- return null;
- }
- default:
- throw new IllegalStateException("setField wasn't null, but didn't match any of the case statements!");
- }
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- return null;
- }
- }
-
- @Override
- protected void standardSchemeWriteValue(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
- switch (setField_) {
- case BOLT:
- BoltStats bolt = (BoltStats)value_;
- bolt.write(oprot);
- return;
- case SPOUT:
- SpoutStats spout = (SpoutStats)value_;
- spout.write(oprot);
- return;
- default:
- throw new IllegalStateException("Cannot write union with unknown field " + setField_);
- }
- }
-
- @Override
- protected Object tupleSchemeReadValue(org.apache.thrift.protocol.TProtocol iprot, short fieldID) throws org.apache.thrift.TException {
- _Fields setField = _Fields.findByThriftId(fieldID);
- if (setField != null) {
- switch (setField) {
- case BOLT:
- BoltStats bolt;
- bolt = new BoltStats();
- bolt.read(iprot);
- return bolt;
- case SPOUT:
- SpoutStats spout;
- spout = new SpoutStats();
- spout.read(iprot);
- return spout;
- default:
- throw new IllegalStateException("setField wasn't null, but didn't match any of the case statements!");
- }
- } else {
- throw new 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 {
- switch (setField_) {
- case BOLT:
- BoltStats bolt = (BoltStats)value_;
- bolt.write(oprot);
- return;
- case SPOUT:
- SpoutStats spout = (SpoutStats)value_;
- spout.write(oprot);
- return;
- default:
- throw new IllegalStateException("Cannot write union with unknown field " + setField_);
- }
- }
-
- @Override
- protected org.apache.thrift.protocol.TField getFieldDesc(_Fields setField) {
- switch (setField) {
- case BOLT:
- return BOLT_FIELD_DESC;
- case SPOUT:
- return SPOUT_FIELD_DESC;
- default:
- throw new IllegalArgumentException("Unknown field id " + setField);
- }
- }
-
- @Override
- protected org.apache.thrift.protocol.TStruct getStructDesc() {
- return STRUCT_DESC;
- }
-
- @Override
- protected _Fields enumForId(short id) {
- return _Fields.findByThriftIdOrThrow(id);
- }
-
- public _Fields fieldForId(int fieldId) {
- return _Fields.findByThriftId(fieldId);
- }
-
-
- public BoltStats get_bolt() {
- if (getSetField() == _Fields.BOLT) {
- return (BoltStats)getFieldValue();
- } else {
- throw new RuntimeException("Cannot get field 'bolt' because union is currently set to " + getFieldDesc(getSetField()).name);
- }
- }
-
- public void set_bolt(BoltStats value) {
- if (value == null) throw new NullPointerException();
- setField_ = _Fields.BOLT;
- value_ = value;
- }
-
- public SpoutStats get_spout() {
- if (getSetField() == _Fields.SPOUT) {
- return (SpoutStats)getFieldValue();
- } else {
- throw new RuntimeException("Cannot get field 'spout' because union is currently set to " + getFieldDesc(getSetField()).name);
- }
- }
-
- public void set_spout(SpoutStats value) {
- if (value == null) throw new NullPointerException();
- setField_ = _Fields.SPOUT;
- value_ = value;
- }
-
- public boolean is_set_bolt() {
- return setField_ == _Fields.BOLT;
- }
-
-
- public boolean is_set_spout() {
- return setField_ == _Fields.SPOUT;
- }
-
-
- public boolean equals(Object other) {
- if (other instanceof ExecutorSpecificStats) {
- return equals((ExecutorSpecificStats)other);
- } else {
- return false;
- }
- }
-
- public boolean equals(ExecutorSpecificStats other) {
- return other != null && getSetField() == other.getSetField() && getFieldValue().equals(other.getFieldValue());
- }
-
- @Override
- public int compareTo(ExecutorSpecificStats other) {
- int lastComparison = org.apache.thrift.TBaseHelper.compareTo(getSetField(), other.getSetField());
- if (lastComparison == 0) {
- return org.apache.thrift.TBaseHelper.compareTo(getFieldValue(), other.getFieldValue());
- }
- return lastComparison;
- }
-
-
- @Override
- public int hashCode() {
- List<Object> list = new ArrayList<Object>();
- list.add(this.getClass().getName());
- org.apache.thrift.TFieldIdEnum setField = getSetField();
- if (setField != null) {
- list.add(setField.getThriftFieldId());
- Object value = getFieldValue();
- if (value instanceof org.apache.thrift.TEnum) {
- list.add(((org.apache.thrift.TEnum)getFieldValue()).getValue());
- } else {
- list.add(value);
- }
- }
- return list.hashCode();
- }
- 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) {
- throw new java.io.IOException(te);
- }
- }
-
-
- private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
- try {
- read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
- } catch (org.apache.thrift.TException te) {
- throw new java.io.IOException(te);
- }
- }
-
-
-}