http://git-wip-us.apache.org/repos/asf/storm/blob/a6171bd6/storm-core/src/jvm/backtype/storm/generated/StormTopology.java ---------------------------------------------------------------------- diff --git a/storm-core/src/jvm/backtype/storm/generated/StormTopology.java b/storm-core/src/jvm/backtype/storm/generated/StormTopology.java deleted file mode 100644 index caec6c6..0000000 --- a/storm-core/src/jvm/backtype/storm/generated/StormTopology.java +++ /dev/null @@ -1,1272 +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 StormTopology implements org.apache.thrift.TBase<StormTopology, StormTopology._Fields>, java.io.Serializable, Cloneable, Comparable<StormTopology> { - private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("StormTopology"); - - private static final org.apache.thrift.protocol.TField SPOUTS_FIELD_DESC = new org.apache.thrift.protocol.TField("spouts", org.apache.thrift.protocol.TType.MAP, (short)1); - private static final org.apache.thrift.protocol.TField BOLTS_FIELD_DESC = new org.apache.thrift.protocol.TField("bolts", org.apache.thrift.protocol.TType.MAP, (short)2); - private static final org.apache.thrift.protocol.TField STATE_SPOUTS_FIELD_DESC = new org.apache.thrift.protocol.TField("state_spouts", org.apache.thrift.protocol.TType.MAP, (short)3); - private static final org.apache.thrift.protocol.TField WORKER_HOOKS_FIELD_DESC = new org.apache.thrift.protocol.TField("worker_hooks", org.apache.thrift.protocol.TType.LIST, (short)4); - private static final org.apache.thrift.protocol.TField DEPENDENCY_JARS_FIELD_DESC = new org.apache.thrift.protocol.TField("dependency_jars", org.apache.thrift.protocol.TType.LIST, (short)5); - private static final org.apache.thrift.protocol.TField DEPENDENCY_ARTIFACTS_FIELD_DESC = new org.apache.thrift.protocol.TField("dependency_artifacts", org.apache.thrift.protocol.TType.LIST, (short)6); - - private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); - static { - schemes.put(StandardScheme.class, new StormTopologyStandardSchemeFactory()); - schemes.put(TupleScheme.class, new StormTopologyTupleSchemeFactory()); - } - - private Map<String,SpoutSpec> spouts; // required - private Map<String,Bolt> bolts; // required - private Map<String,StateSpoutSpec> state_spouts; // required - private List<ByteBuffer> worker_hooks; // optional - private List<String> dependency_jars; // optional - private List<String> dependency_artifacts; // 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 { - SPOUTS((short)1, "spouts"), - BOLTS((short)2, "bolts"), - STATE_SPOUTS((short)3, "state_spouts"), - WORKER_HOOKS((short)4, "worker_hooks"), - DEPENDENCY_JARS((short)5, "dependency_jars"), - DEPENDENCY_ARTIFACTS((short)6, "dependency_artifacts"); - - 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: // SPOUTS - return SPOUTS; - case 2: // BOLTS - return BOLTS; - case 3: // STATE_SPOUTS - return STATE_SPOUTS; - case 4: // WORKER_HOOKS - return WORKER_HOOKS; - case 5: // DEPENDENCY_JARS - return DEPENDENCY_JARS; - case 6: // DEPENDENCY_ARTIFACTS - return DEPENDENCY_ARTIFACTS; - 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.WORKER_HOOKS,_Fields.DEPENDENCY_JARS,_Fields.DEPENDENCY_ARTIFACTS}; - 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.SPOUTS, new org.apache.thrift.meta_data.FieldMetaData("spouts", org.apache.thrift.TFieldRequirementType.REQUIRED, - new org.apache.thrift.meta_data.MapMetaData(org.apache.thrift.protocol.TType.MAP, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING), - new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, SpoutSpec.class)))); - tmpMap.put(_Fields.BOLTS, new org.apache.thrift.meta_data.FieldMetaData("bolts", org.apache.thrift.TFieldRequirementType.REQUIRED, - new org.apache.thrift.meta_data.MapMetaData(org.apache.thrift.protocol.TType.MAP, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING), - new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, Bolt.class)))); - tmpMap.put(_Fields.STATE_SPOUTS, new org.apache.thrift.meta_data.FieldMetaData("state_spouts", org.apache.thrift.TFieldRequirementType.REQUIRED, - new org.apache.thrift.meta_data.MapMetaData(org.apache.thrift.protocol.TType.MAP, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING), - new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, StateSpoutSpec.class)))); - tmpMap.put(_Fields.WORKER_HOOKS, new org.apache.thrift.meta_data.FieldMetaData("worker_hooks", org.apache.thrift.TFieldRequirementType.OPTIONAL, - new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING , true)))); - tmpMap.put(_Fields.DEPENDENCY_JARS, new org.apache.thrift.meta_data.FieldMetaData("dependency_jars", org.apache.thrift.TFieldRequirementType.OPTIONAL, - new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)))); - tmpMap.put(_Fields.DEPENDENCY_ARTIFACTS, new org.apache.thrift.meta_data.FieldMetaData("dependency_artifacts", org.apache.thrift.TFieldRequirementType.OPTIONAL, - new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)))); - metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(StormTopology.class, metaDataMap); - } - - public StormTopology() { - } - - public StormTopology( - Map<String,SpoutSpec> spouts, - Map<String,Bolt> bolts, - Map<String,StateSpoutSpec> state_spouts) - { - this(); - this.spouts = spouts; - this.bolts = bolts; - this.state_spouts = state_spouts; - } - - /** - * Performs a deep copy on <i>other</i>. - */ - public StormTopology(StormTopology other) { - if (other.is_set_spouts()) { - Map<String,SpoutSpec> __this__spouts = new HashMap<String,SpoutSpec>(other.spouts.size()); - for (Map.Entry<String, SpoutSpec> other_element : other.spouts.entrySet()) { - - String other_element_key = other_element.getKey(); - SpoutSpec other_element_value = other_element.getValue(); - - String __this__spouts_copy_key = other_element_key; - - SpoutSpec __this__spouts_copy_value = new SpoutSpec(other_element_value); - - __this__spouts.put(__this__spouts_copy_key, __this__spouts_copy_value); - } - this.spouts = __this__spouts; - } - if (other.is_set_bolts()) { - Map<String,Bolt> __this__bolts = new HashMap<String,Bolt>(other.bolts.size()); - for (Map.Entry<String, Bolt> other_element : other.bolts.entrySet()) { - - String other_element_key = other_element.getKey(); - Bolt other_element_value = other_element.getValue(); - - String __this__bolts_copy_key = other_element_key; - - Bolt __this__bolts_copy_value = new Bolt(other_element_value); - - __this__bolts.put(__this__bolts_copy_key, __this__bolts_copy_value); - } - this.bolts = __this__bolts; - } - if (other.is_set_state_spouts()) { - Map<String,StateSpoutSpec> __this__state_spouts = new HashMap<String,StateSpoutSpec>(other.state_spouts.size()); - for (Map.Entry<String, StateSpoutSpec> other_element : other.state_spouts.entrySet()) { - - String other_element_key = other_element.getKey(); - StateSpoutSpec other_element_value = other_element.getValue(); - - String __this__state_spouts_copy_key = other_element_key; - - StateSpoutSpec __this__state_spouts_copy_value = new StateSpoutSpec(other_element_value); - - __this__state_spouts.put(__this__state_spouts_copy_key, __this__state_spouts_copy_value); - } - this.state_spouts = __this__state_spouts; - } - if (other.is_set_worker_hooks()) { - List<ByteBuffer> __this__worker_hooks = new ArrayList<ByteBuffer>(other.worker_hooks); - this.worker_hooks = __this__worker_hooks; - } - if (other.is_set_dependency_jars()) { - List<String> __this__dependency_jars = new ArrayList<String>(other.dependency_jars); - this.dependency_jars = __this__dependency_jars; - } - if (other.is_set_dependency_artifacts()) { - List<String> __this__dependency_artifacts = new ArrayList<String>(other.dependency_artifacts); - this.dependency_artifacts = __this__dependency_artifacts; - } - } - - public StormTopology deepCopy() { - return new StormTopology(this); - } - - @Override - public void clear() { - this.spouts = null; - this.bolts = null; - this.state_spouts = null; - this.worker_hooks = null; - this.dependency_jars = null; - this.dependency_artifacts = null; - } - - public int get_spouts_size() { - return (this.spouts == null) ? 0 : this.spouts.size(); - } - - public void put_to_spouts(String key, SpoutSpec val) { - if (this.spouts == null) { - this.spouts = new HashMap<String,SpoutSpec>(); - } - this.spouts.put(key, val); - } - - public Map<String,SpoutSpec> get_spouts() { - return this.spouts; - } - - public void set_spouts(Map<String,SpoutSpec> spouts) { - this.spouts = spouts; - } - - public void unset_spouts() { - this.spouts = null; - } - - /** Returns true if field spouts is set (has been assigned a value) and false otherwise */ - public boolean is_set_spouts() { - return this.spouts != null; - } - - public void set_spouts_isSet(boolean value) { - if (!value) { - this.spouts = null; - } - } - - public int get_bolts_size() { - return (this.bolts == null) ? 0 : this.bolts.size(); - } - - public void put_to_bolts(String key, Bolt val) { - if (this.bolts == null) { - this.bolts = new HashMap<String,Bolt>(); - } - this.bolts.put(key, val); - } - - public Map<String,Bolt> get_bolts() { - return this.bolts; - } - - public void set_bolts(Map<String,Bolt> bolts) { - this.bolts = bolts; - } - - public void unset_bolts() { - this.bolts = null; - } - - /** Returns true if field bolts is set (has been assigned a value) and false otherwise */ - public boolean is_set_bolts() { - return this.bolts != null; - } - - public void set_bolts_isSet(boolean value) { - if (!value) { - this.bolts = null; - } - } - - public int get_state_spouts_size() { - return (this.state_spouts == null) ? 0 : this.state_spouts.size(); - } - - public void put_to_state_spouts(String key, StateSpoutSpec val) { - if (this.state_spouts == null) { - this.state_spouts = new HashMap<String,StateSpoutSpec>(); - } - this.state_spouts.put(key, val); - } - - public Map<String,StateSpoutSpec> get_state_spouts() { - return this.state_spouts; - } - - public void set_state_spouts(Map<String,StateSpoutSpec> state_spouts) { - this.state_spouts = state_spouts; - } - - public void unset_state_spouts() { - this.state_spouts = null; - } - - /** Returns true if field state_spouts is set (has been assigned a value) and false otherwise */ - public boolean is_set_state_spouts() { - return this.state_spouts != null; - } - - public void set_state_spouts_isSet(boolean value) { - if (!value) { - this.state_spouts = null; - } - } - - public int get_worker_hooks_size() { - return (this.worker_hooks == null) ? 0 : this.worker_hooks.size(); - } - - public java.util.Iterator<ByteBuffer> get_worker_hooks_iterator() { - return (this.worker_hooks == null) ? null : this.worker_hooks.iterator(); - } - - public void add_to_worker_hooks(ByteBuffer elem) { - if (this.worker_hooks == null) { - this.worker_hooks = new ArrayList<ByteBuffer>(); - } - this.worker_hooks.add(elem); - } - - public List<ByteBuffer> get_worker_hooks() { - return this.worker_hooks; - } - - public void set_worker_hooks(List<ByteBuffer> worker_hooks) { - this.worker_hooks = worker_hooks; - } - - public void unset_worker_hooks() { - this.worker_hooks = null; - } - - /** Returns true if field worker_hooks is set (has been assigned a value) and false otherwise */ - public boolean is_set_worker_hooks() { - return this.worker_hooks != null; - } - - public void set_worker_hooks_isSet(boolean value) { - if (!value) { - this.worker_hooks = null; - } - } - - public int get_dependency_jars_size() { - return (this.dependency_jars == null) ? 0 : this.dependency_jars.size(); - } - - public java.util.Iterator<String> get_dependency_jars_iterator() { - return (this.dependency_jars == null) ? null : this.dependency_jars.iterator(); - } - - public void add_to_dependency_jars(String elem) { - if (this.dependency_jars == null) { - this.dependency_jars = new ArrayList<String>(); - } - this.dependency_jars.add(elem); - } - - public List<String> get_dependency_jars() { - return this.dependency_jars; - } - - public void set_dependency_jars(List<String> dependency_jars) { - this.dependency_jars = dependency_jars; - } - - public void unset_dependency_jars() { - this.dependency_jars = null; - } - - /** Returns true if field dependency_jars is set (has been assigned a value) and false otherwise */ - public boolean is_set_dependency_jars() { - return this.dependency_jars != null; - } - - public void set_dependency_jars_isSet(boolean value) { - if (!value) { - this.dependency_jars = null; - } - } - - public int get_dependency_artifacts_size() { - return (this.dependency_artifacts == null) ? 0 : this.dependency_artifacts.size(); - } - - public java.util.Iterator<String> get_dependency_artifacts_iterator() { - return (this.dependency_artifacts == null) ? null : this.dependency_artifacts.iterator(); - } - - public void add_to_dependency_artifacts(String elem) { - if (this.dependency_artifacts == null) { - this.dependency_artifacts = new ArrayList<String>(); - } - this.dependency_artifacts.add(elem); - } - - public List<String> get_dependency_artifacts() { - return this.dependency_artifacts; - } - - public void set_dependency_artifacts(List<String> dependency_artifacts) { - this.dependency_artifacts = dependency_artifacts; - } - - public void unset_dependency_artifacts() { - this.dependency_artifacts = null; - } - - /** Returns true if field dependency_artifacts is set (has been assigned a value) and false otherwise */ - public boolean is_set_dependency_artifacts() { - return this.dependency_artifacts != null; - } - - public void set_dependency_artifacts_isSet(boolean value) { - if (!value) { - this.dependency_artifacts = null; - } - } - - public void setFieldValue(_Fields field, Object value) { - switch (field) { - case SPOUTS: - if (value == null) { - unset_spouts(); - } else { - set_spouts((Map<String,SpoutSpec>)value); - } - break; - - case BOLTS: - if (value == null) { - unset_bolts(); - } else { - set_bolts((Map<String,Bolt>)value); - } - break; - - case STATE_SPOUTS: - if (value == null) { - unset_state_spouts(); - } else { - set_state_spouts((Map<String,StateSpoutSpec>)value); - } - break; - - case WORKER_HOOKS: - if (value == null) { - unset_worker_hooks(); - } else { - set_worker_hooks((List<ByteBuffer>)value); - } - break; - - case DEPENDENCY_JARS: - if (value == null) { - unset_dependency_jars(); - } else { - set_dependency_jars((List<String>)value); - } - break; - - case DEPENDENCY_ARTIFACTS: - if (value == null) { - unset_dependency_artifacts(); - } else { - set_dependency_artifacts((List<String>)value); - } - break; - - } - } - - public Object getFieldValue(_Fields field) { - switch (field) { - case SPOUTS: - return get_spouts(); - - case BOLTS: - return get_bolts(); - - case STATE_SPOUTS: - return get_state_spouts(); - - case WORKER_HOOKS: - return get_worker_hooks(); - - case DEPENDENCY_JARS: - return get_dependency_jars(); - - case DEPENDENCY_ARTIFACTS: - return get_dependency_artifacts(); - - } - 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 SPOUTS: - return is_set_spouts(); - case BOLTS: - return is_set_bolts(); - case STATE_SPOUTS: - return is_set_state_spouts(); - case WORKER_HOOKS: - return is_set_worker_hooks(); - case DEPENDENCY_JARS: - return is_set_dependency_jars(); - case DEPENDENCY_ARTIFACTS: - return is_set_dependency_artifacts(); - } - throw new IllegalStateException(); - } - - @Override - public boolean equals(Object that) { - if (that == null) - return false; - if (that instanceof StormTopology) - return this.equals((StormTopology)that); - return false; - } - - public boolean equals(StormTopology that) { - if (that == null) - return false; - - boolean this_present_spouts = true && this.is_set_spouts(); - boolean that_present_spouts = true && that.is_set_spouts(); - if (this_present_spouts || that_present_spouts) { - if (!(this_present_spouts && that_present_spouts)) - return false; - if (!this.spouts.equals(that.spouts)) - return false; - } - - boolean this_present_bolts = true && this.is_set_bolts(); - boolean that_present_bolts = true && that.is_set_bolts(); - if (this_present_bolts || that_present_bolts) { - if (!(this_present_bolts && that_present_bolts)) - return false; - if (!this.bolts.equals(that.bolts)) - return false; - } - - boolean this_present_state_spouts = true && this.is_set_state_spouts(); - boolean that_present_state_spouts = true && that.is_set_state_spouts(); - if (this_present_state_spouts || that_present_state_spouts) { - if (!(this_present_state_spouts && that_present_state_spouts)) - return false; - if (!this.state_spouts.equals(that.state_spouts)) - return false; - } - - boolean this_present_worker_hooks = true && this.is_set_worker_hooks(); - boolean that_present_worker_hooks = true && that.is_set_worker_hooks(); - if (this_present_worker_hooks || that_present_worker_hooks) { - if (!(this_present_worker_hooks && that_present_worker_hooks)) - return false; - if (!this.worker_hooks.equals(that.worker_hooks)) - return false; - } - - boolean this_present_dependency_jars = true && this.is_set_dependency_jars(); - boolean that_present_dependency_jars = true && that.is_set_dependency_jars(); - if (this_present_dependency_jars || that_present_dependency_jars) { - if (!(this_present_dependency_jars && that_present_dependency_jars)) - return false; - if (!this.dependency_jars.equals(that.dependency_jars)) - return false; - } - - boolean this_present_dependency_artifacts = true && this.is_set_dependency_artifacts(); - boolean that_present_dependency_artifacts = true && that.is_set_dependency_artifacts(); - if (this_present_dependency_artifacts || that_present_dependency_artifacts) { - if (!(this_present_dependency_artifacts && that_present_dependency_artifacts)) - return false; - if (!this.dependency_artifacts.equals(that.dependency_artifacts)) - return false; - } - - return true; - } - - @Override - public int hashCode() { - List<Object> list = new ArrayList<Object>(); - - boolean present_spouts = true && (is_set_spouts()); - list.add(present_spouts); - if (present_spouts) - list.add(spouts); - - boolean present_bolts = true && (is_set_bolts()); - list.add(present_bolts); - if (present_bolts) - list.add(bolts); - - boolean present_state_spouts = true && (is_set_state_spouts()); - list.add(present_state_spouts); - if (present_state_spouts) - list.add(state_spouts); - - boolean present_worker_hooks = true && (is_set_worker_hooks()); - list.add(present_worker_hooks); - if (present_worker_hooks) - list.add(worker_hooks); - - boolean present_dependency_jars = true && (is_set_dependency_jars()); - list.add(present_dependency_jars); - if (present_dependency_jars) - list.add(dependency_jars); - - boolean present_dependency_artifacts = true && (is_set_dependency_artifacts()); - list.add(present_dependency_artifacts); - if (present_dependency_artifacts) - list.add(dependency_artifacts); - - return list.hashCode(); - } - - @Override - public int compareTo(StormTopology other) { - if (!getClass().equals(other.getClass())) { - return getClass().getName().compareTo(other.getClass().getName()); - } - - int lastComparison = 0; - - lastComparison = Boolean.valueOf(is_set_spouts()).compareTo(other.is_set_spouts()); - if (lastComparison != 0) { - return lastComparison; - } - if (is_set_spouts()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.spouts, other.spouts); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(is_set_bolts()).compareTo(other.is_set_bolts()); - if (lastComparison != 0) { - return lastComparison; - } - if (is_set_bolts()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.bolts, other.bolts); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(is_set_state_spouts()).compareTo(other.is_set_state_spouts()); - if (lastComparison != 0) { - return lastComparison; - } - if (is_set_state_spouts()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.state_spouts, other.state_spouts); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(is_set_worker_hooks()).compareTo(other.is_set_worker_hooks()); - if (lastComparison != 0) { - return lastComparison; - } - if (is_set_worker_hooks()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.worker_hooks, other.worker_hooks); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(is_set_dependency_jars()).compareTo(other.is_set_dependency_jars()); - if (lastComparison != 0) { - return lastComparison; - } - if (is_set_dependency_jars()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.dependency_jars, other.dependency_jars); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(is_set_dependency_artifacts()).compareTo(other.is_set_dependency_artifacts()); - if (lastComparison != 0) { - return lastComparison; - } - if (is_set_dependency_artifacts()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.dependency_artifacts, other.dependency_artifacts); - 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("StormTopology("); - boolean first = true; - - sb.append("spouts:"); - if (this.spouts == null) { - sb.append("null"); - } else { - sb.append(this.spouts); - } - first = false; - if (!first) sb.append(", "); - sb.append("bolts:"); - if (this.bolts == null) { - sb.append("null"); - } else { - sb.append(this.bolts); - } - first = false; - if (!first) sb.append(", "); - sb.append("state_spouts:"); - if (this.state_spouts == null) { - sb.append("null"); - } else { - sb.append(this.state_spouts); - } - first = false; - if (is_set_worker_hooks()) { - if (!first) sb.append(", "); - sb.append("worker_hooks:"); - if (this.worker_hooks == null) { - sb.append("null"); - } else { - org.apache.thrift.TBaseHelper.toString(this.worker_hooks, sb); - } - first = false; - } - if (is_set_dependency_jars()) { - if (!first) sb.append(", "); - sb.append("dependency_jars:"); - if (this.dependency_jars == null) { - sb.append("null"); - } else { - sb.append(this.dependency_jars); - } - first = false; - } - if (is_set_dependency_artifacts()) { - if (!first) sb.append(", "); - sb.append("dependency_artifacts:"); - if (this.dependency_artifacts == null) { - sb.append("null"); - } else { - sb.append(this.dependency_artifacts); - } - first = false; - } - sb.append(")"); - return sb.toString(); - } - - public void validate() throws org.apache.thrift.TException { - // check for required fields - if (!is_set_spouts()) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'spouts' is unset! Struct:" + toString()); - } - - if (!is_set_bolts()) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'bolts' is unset! Struct:" + toString()); - } - - if (!is_set_state_spouts()) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'state_spouts' 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 { - 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 StormTopologyStandardSchemeFactory implements SchemeFactory { - public StormTopologyStandardScheme getScheme() { - return new StormTopologyStandardScheme(); - } - } - - private static class StormTopologyStandardScheme extends StandardScheme<StormTopology> { - - public void read(org.apache.thrift.protocol.TProtocol iprot, StormTopology 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: // SPOUTS - if (schemeField.type == org.apache.thrift.protocol.TType.MAP) { - { - org.apache.thrift.protocol.TMap _map44 = iprot.readMapBegin(); - struct.spouts = new HashMap<String,SpoutSpec>(2*_map44.size); - String _key45; - SpoutSpec _val46; - for (int _i47 = 0; _i47 < _map44.size; ++_i47) - { - _key45 = iprot.readString(); - _val46 = new SpoutSpec(); - _val46.read(iprot); - struct.spouts.put(_key45, _val46); - } - iprot.readMapEnd(); - } - struct.set_spouts_isSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 2: // BOLTS - if (schemeField.type == org.apache.thrift.protocol.TType.MAP) { - { - org.apache.thrift.protocol.TMap _map48 = iprot.readMapBegin(); - struct.bolts = new HashMap<String,Bolt>(2*_map48.size); - String _key49; - Bolt _val50; - for (int _i51 = 0; _i51 < _map48.size; ++_i51) - { - _key49 = iprot.readString(); - _val50 = new Bolt(); - _val50.read(iprot); - struct.bolts.put(_key49, _val50); - } - iprot.readMapEnd(); - } - struct.set_bolts_isSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 3: // STATE_SPOUTS - if (schemeField.type == org.apache.thrift.protocol.TType.MAP) { - { - org.apache.thrift.protocol.TMap _map52 = iprot.readMapBegin(); - struct.state_spouts = new HashMap<String,StateSpoutSpec>(2*_map52.size); - String _key53; - StateSpoutSpec _val54; - for (int _i55 = 0; _i55 < _map52.size; ++_i55) - { - _key53 = iprot.readString(); - _val54 = new StateSpoutSpec(); - _val54.read(iprot); - struct.state_spouts.put(_key53, _val54); - } - iprot.readMapEnd(); - } - struct.set_state_spouts_isSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 4: // WORKER_HOOKS - if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { - { - org.apache.thrift.protocol.TList _list56 = iprot.readListBegin(); - struct.worker_hooks = new ArrayList<ByteBuffer>(_list56.size); - ByteBuffer _elem57; - for (int _i58 = 0; _i58 < _list56.size; ++_i58) - { - _elem57 = iprot.readBinary(); - struct.worker_hooks.add(_elem57); - } - iprot.readListEnd(); - } - struct.set_worker_hooks_isSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 5: // DEPENDENCY_JARS - if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { - { - org.apache.thrift.protocol.TList _list59 = iprot.readListBegin(); - struct.dependency_jars = new ArrayList<String>(_list59.size); - String _elem60; - for (int _i61 = 0; _i61 < _list59.size; ++_i61) - { - _elem60 = iprot.readString(); - struct.dependency_jars.add(_elem60); - } - iprot.readListEnd(); - } - struct.set_dependency_jars_isSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 6: // DEPENDENCY_ARTIFACTS - if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { - { - org.apache.thrift.protocol.TList _list62 = iprot.readListBegin(); - struct.dependency_artifacts = new ArrayList<String>(_list62.size); - String _elem63; - for (int _i64 = 0; _i64 < _list62.size; ++_i64) - { - _elem63 = iprot.readString(); - struct.dependency_artifacts.add(_elem63); - } - iprot.readListEnd(); - } - struct.set_dependency_artifacts_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, StormTopology struct) throws org.apache.thrift.TException { - struct.validate(); - - oprot.writeStructBegin(STRUCT_DESC); - if (struct.spouts != null) { - oprot.writeFieldBegin(SPOUTS_FIELD_DESC); - { - oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, struct.spouts.size())); - for (Map.Entry<String, SpoutSpec> _iter65 : struct.spouts.entrySet()) - { - oprot.writeString(_iter65.getKey()); - _iter65.getValue().write(oprot); - } - oprot.writeMapEnd(); - } - oprot.writeFieldEnd(); - } - if (struct.bolts != null) { - oprot.writeFieldBegin(BOLTS_FIELD_DESC); - { - oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, struct.bolts.size())); - for (Map.Entry<String, Bolt> _iter66 : struct.bolts.entrySet()) - { - oprot.writeString(_iter66.getKey()); - _iter66.getValue().write(oprot); - } - oprot.writeMapEnd(); - } - oprot.writeFieldEnd(); - } - if (struct.state_spouts != null) { - oprot.writeFieldBegin(STATE_SPOUTS_FIELD_DESC); - { - oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, struct.state_spouts.size())); - for (Map.Entry<String, StateSpoutSpec> _iter67 : struct.state_spouts.entrySet()) - { - oprot.writeString(_iter67.getKey()); - _iter67.getValue().write(oprot); - } - oprot.writeMapEnd(); - } - oprot.writeFieldEnd(); - } - if (struct.worker_hooks != null) { - if (struct.is_set_worker_hooks()) { - oprot.writeFieldBegin(WORKER_HOOKS_FIELD_DESC); - { - oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.worker_hooks.size())); - for (ByteBuffer _iter68 : struct.worker_hooks) - { - oprot.writeBinary(_iter68); - } - oprot.writeListEnd(); - } - oprot.writeFieldEnd(); - } - } - if (struct.dependency_jars != null) { - if (struct.is_set_dependency_jars()) { - oprot.writeFieldBegin(DEPENDENCY_JARS_FIELD_DESC); - { - oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.dependency_jars.size())); - for (String _iter69 : struct.dependency_jars) - { - oprot.writeString(_iter69); - } - oprot.writeListEnd(); - } - oprot.writeFieldEnd(); - } - } - if (struct.dependency_artifacts != null) { - if (struct.is_set_dependency_artifacts()) { - oprot.writeFieldBegin(DEPENDENCY_ARTIFACTS_FIELD_DESC); - { - oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.dependency_artifacts.size())); - for (String _iter70 : struct.dependency_artifacts) - { - oprot.writeString(_iter70); - } - oprot.writeListEnd(); - } - oprot.writeFieldEnd(); - } - } - oprot.writeFieldStop(); - oprot.writeStructEnd(); - } - - } - - private static class StormTopologyTupleSchemeFactory implements SchemeFactory { - public StormTopologyTupleScheme getScheme() { - return new StormTopologyTupleScheme(); - } - } - - private static class StormTopologyTupleScheme extends TupleScheme<StormTopology> { - - @Override - public void write(org.apache.thrift.protocol.TProtocol prot, StormTopology struct) throws org.apache.thrift.TException { - TTupleProtocol oprot = (TTupleProtocol) prot; - { - oprot.writeI32(struct.spouts.size()); - for (Map.Entry<String, SpoutSpec> _iter71 : struct.spouts.entrySet()) - { - oprot.writeString(_iter71.getKey()); - _iter71.getValue().write(oprot); - } - } - { - oprot.writeI32(struct.bolts.size()); - for (Map.Entry<String, Bolt> _iter72 : struct.bolts.entrySet()) - { - oprot.writeString(_iter72.getKey()); - _iter72.getValue().write(oprot); - } - } - { - oprot.writeI32(struct.state_spouts.size()); - for (Map.Entry<String, StateSpoutSpec> _iter73 : struct.state_spouts.entrySet()) - { - oprot.writeString(_iter73.getKey()); - _iter73.getValue().write(oprot); - } - } - BitSet optionals = new BitSet(); - if (struct.is_set_worker_hooks()) { - optionals.set(0); - } - if (struct.is_set_dependency_jars()) { - optionals.set(1); - } - if (struct.is_set_dependency_artifacts()) { - optionals.set(2); - } - oprot.writeBitSet(optionals, 3); - if (struct.is_set_worker_hooks()) { - { - oprot.writeI32(struct.worker_hooks.size()); - for (ByteBuffer _iter74 : struct.worker_hooks) - { - oprot.writeBinary(_iter74); - } - } - } - if (struct.is_set_dependency_jars()) { - { - oprot.writeI32(struct.dependency_jars.size()); - for (String _iter75 : struct.dependency_jars) - { - oprot.writeString(_iter75); - } - } - } - if (struct.is_set_dependency_artifacts()) { - { - oprot.writeI32(struct.dependency_artifacts.size()); - for (String _iter76 : struct.dependency_artifacts) - { - oprot.writeString(_iter76); - } - } - } - } - - @Override - public void read(org.apache.thrift.protocol.TProtocol prot, StormTopology struct) throws org.apache.thrift.TException { - TTupleProtocol iprot = (TTupleProtocol) prot; - { - org.apache.thrift.protocol.TMap _map77 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.spouts = new HashMap<String,SpoutSpec>(2*_map77.size); - String _key78; - SpoutSpec _val79; - for (int _i80 = 0; _i80 < _map77.size; ++_i80) - { - _key78 = iprot.readString(); - _val79 = new SpoutSpec(); - _val79.read(iprot); - struct.spouts.put(_key78, _val79); - } - } - struct.set_spouts_isSet(true); - { - org.apache.thrift.protocol.TMap _map81 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.bolts = new HashMap<String,Bolt>(2*_map81.size); - String _key82; - Bolt _val83; - for (int _i84 = 0; _i84 < _map81.size; ++_i84) - { - _key82 = iprot.readString(); - _val83 = new Bolt(); - _val83.read(iprot); - struct.bolts.put(_key82, _val83); - } - } - struct.set_bolts_isSet(true); - { - org.apache.thrift.protocol.TMap _map85 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.state_spouts = new HashMap<String,StateSpoutSpec>(2*_map85.size); - String _key86; - StateSpoutSpec _val87; - for (int _i88 = 0; _i88 < _map85.size; ++_i88) - { - _key86 = iprot.readString(); - _val87 = new StateSpoutSpec(); - _val87.read(iprot); - struct.state_spouts.put(_key86, _val87); - } - } - struct.set_state_spouts_isSet(true); - BitSet incoming = iprot.readBitSet(3); - if (incoming.get(0)) { - { - org.apache.thrift.protocol.TList _list89 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); - struct.worker_hooks = new ArrayList<ByteBuffer>(_list89.size); - ByteBuffer _elem90; - for (int _i91 = 0; _i91 < _list89.size; ++_i91) - { - _elem90 = iprot.readBinary(); - struct.worker_hooks.add(_elem90); - } - } - struct.set_worker_hooks_isSet(true); - } - if (incoming.get(1)) { - { - org.apache.thrift.protocol.TList _list92 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); - struct.dependency_jars = new ArrayList<String>(_list92.size); - String _elem93; - for (int _i94 = 0; _i94 < _list92.size; ++_i94) - { - _elem93 = iprot.readString(); - struct.dependency_jars.add(_elem93); - } - } - struct.set_dependency_jars_isSet(true); - } - if (incoming.get(2)) { - { - org.apache.thrift.protocol.TList _list95 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); - struct.dependency_artifacts = new ArrayList<String>(_list95.size); - String _elem96; - for (int _i97 = 0; _i97 < _list95.size; ++_i97) - { - _elem96 = iprot.readString(); - struct.dependency_artifacts.add(_elem96); - } - } - struct.set_dependency_artifacts_isSet(true); - } - } - } - -} -
http://git-wip-us.apache.org/repos/asf/storm/blob/a6171bd6/storm-core/src/jvm/backtype/storm/generated/StreamInfo.java ---------------------------------------------------------------------- diff --git a/storm-core/src/jvm/backtype/storm/generated/StreamInfo.java b/storm-core/src/jvm/backtype/storm/generated/StreamInfo.java deleted file mode 100644 index bb78631..0000000 --- a/storm-core/src/jvm/backtype/storm/generated/StreamInfo.java +++ /dev/null @@ -1,554 +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 StreamInfo implements org.apache.thrift.TBase<StreamInfo, StreamInfo._Fields>, java.io.Serializable, Cloneable, Comparable<StreamInfo> { - private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("StreamInfo"); - - private static final org.apache.thrift.protocol.TField OUTPUT_FIELDS_FIELD_DESC = new org.apache.thrift.protocol.TField("output_fields", org.apache.thrift.protocol.TType.LIST, (short)1); - private static final org.apache.thrift.protocol.TField DIRECT_FIELD_DESC = new org.apache.thrift.protocol.TField("direct", org.apache.thrift.protocol.TType.BOOL, (short)2); - - private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); - static { - schemes.put(StandardScheme.class, new StreamInfoStandardSchemeFactory()); - schemes.put(TupleScheme.class, new StreamInfoTupleSchemeFactory()); - } - - private List<String> output_fields; // required - private boolean direct; // 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 { - OUTPUT_FIELDS((short)1, "output_fields"), - DIRECT((short)2, "direct"); - - 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: // OUTPUT_FIELDS - return OUTPUT_FIELDS; - case 2: // DIRECT - return DIRECT; - 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 __DIRECT_ISSET_ID = 0; - 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.OUTPUT_FIELDS, new org.apache.thrift.meta_data.FieldMetaData("output_fields", org.apache.thrift.TFieldRequirementType.REQUIRED, - new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)))); - tmpMap.put(_Fields.DIRECT, new org.apache.thrift.meta_data.FieldMetaData("direct", org.apache.thrift.TFieldRequirementType.REQUIRED, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.BOOL))); - metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(StreamInfo.class, metaDataMap); - } - - public StreamInfo() { - } - - public StreamInfo( - List<String> output_fields, - boolean direct) - { - this(); - this.output_fields = output_fields; - this.direct = direct; - set_direct_isSet(true); - } - - /** - * Performs a deep copy on <i>other</i>. - */ - public StreamInfo(StreamInfo other) { - __isset_bitfield = other.__isset_bitfield; - if (other.is_set_output_fields()) { - List<String> __this__output_fields = new ArrayList<String>(other.output_fields); - this.output_fields = __this__output_fields; - } - this.direct = other.direct; - } - - public StreamInfo deepCopy() { - return new StreamInfo(this); - } - - @Override - public void clear() { - this.output_fields = null; - set_direct_isSet(false); - this.direct = false; - } - - public int get_output_fields_size() { - return (this.output_fields == null) ? 0 : this.output_fields.size(); - } - - public java.util.Iterator<String> get_output_fields_iterator() { - return (this.output_fields == null) ? null : this.output_fields.iterator(); - } - - public void add_to_output_fields(String elem) { - if (this.output_fields == null) { - this.output_fields = new ArrayList<String>(); - } - this.output_fields.add(elem); - } - - public List<String> get_output_fields() { - return this.output_fields; - } - - public void set_output_fields(List<String> output_fields) { - this.output_fields = output_fields; - } - - public void unset_output_fields() { - this.output_fields = null; - } - - /** Returns true if field output_fields is set (has been assigned a value) and false otherwise */ - public boolean is_set_output_fields() { - return this.output_fields != null; - } - - public void set_output_fields_isSet(boolean value) { - if (!value) { - this.output_fields = null; - } - } - - public boolean is_direct() { - return this.direct; - } - - public void set_direct(boolean direct) { - this.direct = direct; - set_direct_isSet(true); - } - - public void unset_direct() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __DIRECT_ISSET_ID); - } - - /** Returns true if field direct is set (has been assigned a value) and false otherwise */ - public boolean is_set_direct() { - return EncodingUtils.testBit(__isset_bitfield, __DIRECT_ISSET_ID); - } - - public void set_direct_isSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __DIRECT_ISSET_ID, value); - } - - public void setFieldValue(_Fields field, Object value) { - switch (field) { - case OUTPUT_FIELDS: - if (value == null) { - unset_output_fields(); - } else { - set_output_fields((List<String>)value); - } - break; - - case DIRECT: - if (value == null) { - unset_direct(); - } else { - set_direct((Boolean)value); - } - break; - - } - } - - public Object getFieldValue(_Fields field) { - switch (field) { - case OUTPUT_FIELDS: - return get_output_fields(); - - case DIRECT: - return is_direct(); - - } - 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 OUTPUT_FIELDS: - return is_set_output_fields(); - case DIRECT: - return is_set_direct(); - } - throw new IllegalStateException(); - } - - @Override - public boolean equals(Object that) { - if (that == null) - return false; - if (that instanceof StreamInfo) - return this.equals((StreamInfo)that); - return false; - } - - public boolean equals(StreamInfo that) { - if (that == null) - return false; - - boolean this_present_output_fields = true && this.is_set_output_fields(); - boolean that_present_output_fields = true && that.is_set_output_fields(); - if (this_present_output_fields || that_present_output_fields) { - if (!(this_present_output_fields && that_present_output_fields)) - return false; - if (!this.output_fields.equals(that.output_fields)) - return false; - } - - boolean this_present_direct = true; - boolean that_present_direct = true; - if (this_present_direct || that_present_direct) { - if (!(this_present_direct && that_present_direct)) - return false; - if (this.direct != that.direct) - return false; - } - - return true; - } - - @Override - public int hashCode() { - List<Object> list = new ArrayList<Object>(); - - boolean present_output_fields = true && (is_set_output_fields()); - list.add(present_output_fields); - if (present_output_fields) - list.add(output_fields); - - boolean present_direct = true; - list.add(present_direct); - if (present_direct) - list.add(direct); - - return list.hashCode(); - } - - @Override - public int compareTo(StreamInfo other) { - if (!getClass().equals(other.getClass())) { - return getClass().getName().compareTo(other.getClass().getName()); - } - - int lastComparison = 0; - - lastComparison = Boolean.valueOf(is_set_output_fields()).compareTo(other.is_set_output_fields()); - if (lastComparison != 0) { - return lastComparison; - } - if (is_set_output_fields()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.output_fields, other.output_fields); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(is_set_direct()).compareTo(other.is_set_direct()); - if (lastComparison != 0) { - return lastComparison; - } - if (is_set_direct()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.direct, other.direct); - 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("StreamInfo("); - boolean first = true; - - sb.append("output_fields:"); - if (this.output_fields == null) { - sb.append("null"); - } else { - sb.append(this.output_fields); - } - first = false; - if (!first) sb.append(", "); - sb.append("direct:"); - sb.append(this.direct); - first = false; - sb.append(")"); - return sb.toString(); - } - - public void validate() throws org.apache.thrift.TException { - // check for required fields - if (!is_set_output_fields()) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'output_fields' is unset! Struct:" + toString()); - } - - if (!is_set_direct()) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'direct' 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 StreamInfoStandardSchemeFactory implements SchemeFactory { - public StreamInfoStandardScheme getScheme() { - return new StreamInfoStandardScheme(); - } - } - - private static class StreamInfoStandardScheme extends StandardScheme<StreamInfo> { - - public void read(org.apache.thrift.protocol.TProtocol iprot, StreamInfo 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: // OUTPUT_FIELDS - if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { - { - org.apache.thrift.protocol.TList _list16 = iprot.readListBegin(); - struct.output_fields = new ArrayList<String>(_list16.size); - String _elem17; - for (int _i18 = 0; _i18 < _list16.size; ++_i18) - { - _elem17 = iprot.readString(); - struct.output_fields.add(_elem17); - } - iprot.readListEnd(); - } - struct.set_output_fields_isSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 2: // DIRECT - if (schemeField.type == org.apache.thrift.protocol.TType.BOOL) { - struct.direct = iprot.readBool(); - struct.set_direct_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, StreamInfo struct) throws org.apache.thrift.TException { - struct.validate(); - - oprot.writeStructBegin(STRUCT_DESC); - if (struct.output_fields != null) { - oprot.writeFieldBegin(OUTPUT_FIELDS_FIELD_DESC); - { - oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.output_fields.size())); - for (String _iter19 : struct.output_fields) - { - oprot.writeString(_iter19); - } - oprot.writeListEnd(); - } - oprot.writeFieldEnd(); - } - oprot.writeFieldBegin(DIRECT_FIELD_DESC); - oprot.writeBool(struct.direct); - oprot.writeFieldEnd(); - oprot.writeFieldStop(); - oprot.writeStructEnd(); - } - - } - - private static class StreamInfoTupleSchemeFactory implements SchemeFactory { - public StreamInfoTupleScheme getScheme() { - return new StreamInfoTupleScheme(); - } - } - - private static class StreamInfoTupleScheme extends TupleScheme<StreamInfo> { - - @Override - public void write(org.apache.thrift.protocol.TProtocol prot, StreamInfo struct) throws org.apache.thrift.TException { - TTupleProtocol oprot = (TTupleProtocol) prot; - { - oprot.writeI32(struct.output_fields.size()); - for (String _iter20 : struct.output_fields) - { - oprot.writeString(_iter20); - } - } - oprot.writeBool(struct.direct); - } - - @Override - public void read(org.apache.thrift.protocol.TProtocol prot, StreamInfo struct) throws org.apache.thrift.TException { - TTupleProtocol iprot = (TTupleProtocol) prot; - { - org.apache.thrift.protocol.TList _list21 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); - struct.output_fields = new ArrayList<String>(_list21.size); - String _elem22; - for (int _i23 = 0; _i23 < _list21.size; ++_i23) - { - _elem22 = iprot.readString(); - struct.output_fields.add(_elem22); - } - } - struct.set_output_fields_isSet(true); - struct.direct = iprot.readBool(); - struct.set_direct_isSet(true); - } - } - -} - http://git-wip-us.apache.org/repos/asf/storm/blob/a6171bd6/storm-core/src/jvm/backtype/storm/generated/SubmitOptions.java ---------------------------------------------------------------------- diff --git a/storm-core/src/jvm/backtype/storm/generated/SubmitOptions.java b/storm-core/src/jvm/backtype/storm/generated/SubmitOptions.java deleted file mode 100644 index 2287244..0000000 --- a/storm-core/src/jvm/backtype/storm/generated/SubmitOptions.java +++ /dev/null @@ -1,533 +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 SubmitOptions implements org.apache.thrift.TBase<SubmitOptions, SubmitOptions._Fields>, java.io.Serializable, Cloneable, Comparable<SubmitOptions> { - private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("SubmitOptions"); - - private static final org.apache.thrift.protocol.TField INITIAL_STATUS_FIELD_DESC = new org.apache.thrift.protocol.TField("initial_status", org.apache.thrift.protocol.TType.I32, (short)1); - private static final org.apache.thrift.protocol.TField CREDS_FIELD_DESC = new org.apache.thrift.protocol.TField("creds", 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 SubmitOptionsStandardSchemeFactory()); - schemes.put(TupleScheme.class, new SubmitOptionsTupleSchemeFactory()); - } - - private TopologyInitialStatus initial_status; // required - private Credentials creds; // 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 { - /** - * - * @see TopologyInitialStatus - */ - INITIAL_STATUS((short)1, "initial_status"), - CREDS((short)2, "creds"); - - 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: // INITIAL_STATUS - return INITIAL_STATUS; - case 2: // CREDS - return CREDS; - 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.CREDS}; - 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.INITIAL_STATUS, new org.apache.thrift.meta_data.FieldMetaData("initial_status", org.apache.thrift.TFieldRequirementType.REQUIRED, - new org.apache.thrift.meta_data.EnumMetaData(org.apache.thrift.protocol.TType.ENUM, TopologyInitialStatus.class))); - tmpMap.put(_Fields.CREDS, new org.apache.thrift.meta_data.FieldMetaData("creds", org.apache.thrift.TFieldRequirementType.OPTIONAL, - new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, Credentials.class))); - metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(SubmitOptions.class, metaDataMap); - } - - public SubmitOptions() { - } - - public SubmitOptions( - TopologyInitialStatus initial_status) - { - this(); - this.initial_status = initial_status; - } - - /** - * Performs a deep copy on <i>other</i>. - */ - public SubmitOptions(SubmitOptions other) { - if (other.is_set_initial_status()) { - this.initial_status = other.initial_status; - } - if (other.is_set_creds()) { - this.creds = new Credentials(other.creds); - } - } - - public SubmitOptions deepCopy() { - return new SubmitOptions(this); - } - - @Override - public void clear() { - this.initial_status = null; - this.creds = null; - } - - /** - * - * @see TopologyInitialStatus - */ - public TopologyInitialStatus get_initial_status() { - return this.initial_status; - } - - /** - * - * @see TopologyInitialStatus - */ - public void set_initial_status(TopologyInitialStatus initial_status) { - this.initial_status = initial_status; - } - - public void unset_initial_status() { - this.initial_status = null; - } - - /** Returns true if field initial_status is set (has been assigned a value) and false otherwise */ - public boolean is_set_initial_status() { - return this.initial_status != null; - } - - public void set_initial_status_isSet(boolean value) { - if (!value) { - this.initial_status = null; - } - } - - public Credentials get_creds() { - return this.creds; - } - - public void set_creds(Credentials creds) { - this.creds = creds; - } - - public void unset_creds() { - this.creds = null; - } - - /** Returns true if field creds is set (has been assigned a value) and false otherwise */ - public boolean is_set_creds() { - return this.creds != null; - } - - public void set_creds_isSet(boolean value) { - if (!value) { - this.creds = null; - } - } - - public void setFieldValue(_Fields field, Object value) { - switch (field) { - case INITIAL_STATUS: - if (value == null) { - unset_initial_status(); - } else { - set_initial_status((TopologyInitialStatus)value); - } - break; - - case CREDS: - if (value == null) { - unset_creds(); - } else { - set_creds((Credentials)value); - } - break; - - } - } - - public Object getFieldValue(_Fields field) { - switch (field) { - case INITIAL_STATUS: - return get_initial_status(); - - case CREDS: - return get_creds(); - - } - 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 INITIAL_STATUS: - return is_set_initial_status(); - case CREDS: - return is_set_creds(); - } - throw new IllegalStateException(); - } - - @Override - public boolean equals(Object that) { - if (that == null) - return false; - if (that instanceof SubmitOptions) - return this.equals((SubmitOptions)that); - return false; - } - - public boolean equals(SubmitOptions that) { - if (that == null) - return false; - - boolean this_present_initial_status = true && this.is_set_initial_status(); - boolean that_present_initial_status = true && that.is_set_initial_status(); - if (this_present_initial_status || that_present_initial_status) { - if (!(this_present_initial_status && that_present_initial_status)) - return false; - if (!this.initial_status.equals(that.initial_status)) - return false; - } - - boolean this_present_creds = true && this.is_set_creds(); - boolean that_present_creds = true && that.is_set_creds(); - if (this_present_creds || that_present_creds) { - if (!(this_present_creds && that_present_creds)) - return false; - if (!this.creds.equals(that.creds)) - return false; - } - - return true; - } - - @Override - public int hashCode() { - List<Object> list = new ArrayList<Object>(); - - boolean present_initial_status = true && (is_set_initial_status()); - list.add(present_initial_status); - if (present_initial_status) - list.add(initial_status.getValue()); - - boolean present_creds = true && (is_set_creds()); - list.add(present_creds); - if (present_creds) - list.add(creds); - - return list.hashCode(); - } - - @Override - public int compareTo(SubmitOptions other) { - if (!getClass().equals(other.getClass())) { - return getClass().getName().compareTo(other.getClass().getName()); - } - - int lastComparison = 0; - - lastComparison = Boolean.valueOf(is_set_initial_status()).compareTo(other.is_set_initial_status()); - if (lastComparison != 0) { - return lastComparison; - } - if (is_set_initial_status()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.initial_status, other.initial_status); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(is_set_creds()).compareTo(other.is_set_creds()); - if (lastComparison != 0) { - return lastComparison; - } - if (is_set_creds()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.creds, other.creds); - 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("SubmitOptions("); - boolean first = true; - - sb.append("initial_status:"); - if (this.initial_status == null) { - sb.append("null"); - } else { - sb.append(this.initial_status); - } - first = false; - if (is_set_creds()) { - if (!first) sb.append(", "); - sb.append("creds:"); - if (this.creds == null) { - sb.append("null"); - } else { - sb.append(this.creds); - } - first = false; - } - sb.append(")"); - return sb.toString(); - } - - public void validate() throws org.apache.thrift.TException { - // check for required fields - if (!is_set_initial_status()) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'initial_status' is unset! Struct:" + toString()); - } - - // check for sub-struct validity - if (creds != null) { - creds.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 SubmitOptionsStandardSchemeFactory implements SchemeFactory { - public SubmitOptionsStandardScheme getScheme() { - return new SubmitOptionsStandardScheme(); - } - } - - private static class SubmitOptionsStandardScheme extends StandardScheme<SubmitOptions> { - - public void read(org.apache.thrift.protocol.TProtocol iprot, SubmitOptions 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: // INITIAL_STATUS - if (schemeField.type == org.apache.thrift.protocol.TType.I32) { - struct.initial_status = org.apache.storm.generated.TopologyInitialStatus.findByValue(iprot.readI32()); - struct.set_initial_status_isSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 2: // CREDS - if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) { - struct.creds = new Credentials(); - struct.creds.read(iprot); - struct.set_creds_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, SubmitOptions struct) throws org.apache.thrift.TException { - struct.validate(); - - oprot.writeStructBegin(STRUCT_DESC); - if (struct.initial_status != null) { - oprot.writeFieldBegin(INITIAL_STATUS_FIELD_DESC); - oprot.writeI32(struct.initial_status.getValue()); - oprot.writeFieldEnd(); - } - if (struct.creds != null) { - if (struct.is_set_creds()) { - oprot.writeFieldBegin(CREDS_FIELD_DESC); - struct.creds.write(oprot); - oprot.writeFieldEnd(); - } - } - oprot.writeFieldStop(); - oprot.writeStructEnd(); - } - - } - - private static class SubmitOptionsTupleSchemeFactory implements SchemeFactory { - public SubmitOptionsTupleScheme getScheme() { - return new SubmitOptionsTupleScheme(); - } - } - - private static class SubmitOptionsTupleScheme extends TupleScheme<SubmitOptions> { - - @Override - public void write(org.apache.thrift.protocol.TProtocol prot, SubmitOptions struct) throws org.apache.thrift.TException { - TTupleProtocol oprot = (TTupleProtocol) prot; - oprot.writeI32(struct.initial_status.getValue()); - BitSet optionals = new BitSet(); - if (struct.is_set_creds()) { - optionals.set(0); - } - oprot.writeBitSet(optionals, 1); - if (struct.is_set_creds()) { - struct.creds.write(oprot); - } - } - - @Override - public void read(org.apache.thrift.protocol.TProtocol prot, SubmitOptions struct) throws org.apache.thrift.TException { - TTupleProtocol iprot = (TTupleProtocol) prot; - struct.initial_status = org.apache.storm.generated.TopologyInitialStatus.findByValue(iprot.readI32()); - struct.set_initial_status_isSet(true); - BitSet incoming = iprot.readBitSet(1); - if (incoming.get(0)) { - struct.creds = new Credentials(); - struct.creds.read(iprot); - struct.set_creds_isSet(true); - } - } - } - -} -
