You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by bo...@apache.org on 2018/05/23 20:03:47 UTC
[17/43] storm git commit: STORM-3061: thrift 0.11
http://git-wip-us.apache.org/repos/asf/storm/blob/1fd1e17f/storm-client/src/jvm/org/apache/storm/generated/StormTopology.java
----------------------------------------------------------------------
diff --git a/storm-client/src/jvm/org/apache/storm/generated/StormTopology.java b/storm-client/src/jvm/org/apache/storm/generated/StormTopology.java
index 7594220..8a7a931 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/StormTopology.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/StormTopology.java
@@ -16,42 +16,15 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.3)
+ * Autogenerated by Thrift Compiler (0.11.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
*/
package org.apache.storm.generated;
-import org.apache.thrift.scheme.IScheme;
-import org.apache.thrift.scheme.SchemeFactory;
-import org.apache.thrift.scheme.StandardScheme;
-
-import org.apache.thrift.scheme.TupleScheme;
-import org.apache.thrift.protocol.TTupleProtocol;
-import org.apache.thrift.protocol.TProtocolException;
-import org.apache.thrift.EncodingUtils;
-import org.apache.thrift.TException;
-import org.apache.thrift.async.AsyncMethodCallback;
-import org.apache.thrift.server.AbstractNonblockingServer.*;
-import java.util.List;
-import java.util.ArrayList;
-import java.util.Map;
-import java.util.HashMap;
-import java.util.EnumMap;
-import java.util.Set;
-import java.util.HashSet;
-import java.util.EnumSet;
-import java.util.Collections;
-import java.util.BitSet;
-import java.nio.ByteBuffer;
-import java.util.Arrays;
-import javax.annotation.Generated;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
+@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
+@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.11.0)")
public class 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");
@@ -66,22 +39,19 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
private static final org.apache.thrift.protocol.TField COMPONENT_TO_SHARED_MEMORY_FIELD_DESC = new org.apache.thrift.protocol.TField("component_to_shared_memory", org.apache.thrift.protocol.TType.MAP, (short)9);
private static final org.apache.thrift.protocol.TField SHARED_MEMORY_FIELD_DESC = new org.apache.thrift.protocol.TField("shared_memory", org.apache.thrift.protocol.TType.MAP, (short)10);
- 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 static final org.apache.thrift.scheme.SchemeFactory STANDARD_SCHEME_FACTORY = new StormTopologyStandardSchemeFactory();
+ private static final org.apache.thrift.scheme.SchemeFactory TUPLE_SCHEME_FACTORY = 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
- private String storm_version; // optional
- private String jdk_version; // optional
- private Map<String,Set<String>> component_to_shared_memory; // optional
- private Map<String,SharedMemory> shared_memory; // optional
+ private java.util.Map<java.lang.String,SpoutSpec> spouts; // required
+ private java.util.Map<java.lang.String,Bolt> bolts; // required
+ private java.util.Map<java.lang.String,StateSpoutSpec> state_spouts; // required
+ private java.util.List<java.nio.ByteBuffer> worker_hooks; // optional
+ private java.util.List<java.lang.String> dependency_jars; // optional
+ private java.util.List<java.lang.String> dependency_artifacts; // optional
+ private java.lang.String storm_version; // optional
+ private java.lang.String jdk_version; // optional
+ private java.util.Map<java.lang.String,java.util.Set<java.lang.String>> component_to_shared_memory; // optional
+ private java.util.Map<java.lang.String,SharedMemory> shared_memory; // 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 {
@@ -96,10 +66,10 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
COMPONENT_TO_SHARED_MEMORY((short)9, "component_to_shared_memory"),
SHARED_MEMORY((short)10, "shared_memory");
- private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
+ private static final java.util.Map<java.lang.String, _Fields> byName = new java.util.HashMap<java.lang.String, _Fields>();
static {
- for (_Fields field : EnumSet.allOf(_Fields.class)) {
+ for (_Fields field : java.util.EnumSet.allOf(_Fields.class)) {
byName.put(field.getFieldName(), field);
}
}
@@ -140,21 +110,21 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
*/
public static _Fields findByThriftIdOrThrow(int fieldId) {
_Fields fields = findByThriftId(fieldId);
- if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
+ if (fields == null) throw new java.lang.IllegalArgumentException("Field " + fieldId + " doesn't exist!");
return fields;
}
/**
* Find the _Fields constant that matches name, or null if its not found.
*/
- public static _Fields findByName(String name) {
+ public static _Fields findByName(java.lang.String name) {
return byName.get(name);
}
private final short _thriftId;
- private final String _fieldName;
+ private final java.lang.String _fieldName;
- _Fields(short thriftId, String fieldName) {
+ _Fields(short thriftId, java.lang.String fieldName) {
_thriftId = thriftId;
_fieldName = fieldName;
}
@@ -163,16 +133,16 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
return _thriftId;
}
- public String getFieldName() {
+ public java.lang.String getFieldName() {
return _fieldName;
}
}
// isset id assignments
private static final _Fields optionals[] = {_Fields.WORKER_HOOKS,_Fields.DEPENDENCY_JARS,_Fields.DEPENDENCY_ARTIFACTS,_Fields.STORM_VERSION,_Fields.JDK_VERSION,_Fields.COMPONENT_TO_SHARED_MEMORY,_Fields.SHARED_MEMORY};
- public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
+ public static final java.util.Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
static {
- Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
+ java.util.Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new java.util.EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
tmpMap.put(_Fields.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),
@@ -207,7 +177,7 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
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, SharedMemory.class))));
- metaDataMap = Collections.unmodifiableMap(tmpMap);
+ metaDataMap = java.util.Collections.unmodifiableMap(tmpMap);
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(StormTopology.class, metaDataMap);
}
@@ -215,9 +185,9 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
}
public StormTopology(
- Map<String,SpoutSpec> spouts,
- Map<String,Bolt> bolts,
- Map<String,StateSpoutSpec> state_spouts)
+ java.util.Map<java.lang.String,SpoutSpec> spouts,
+ java.util.Map<java.lang.String,Bolt> bolts,
+ java.util.Map<java.lang.String,StateSpoutSpec> state_spouts)
{
this();
this.spouts = spouts;
@@ -230,13 +200,13 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
*/
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()) {
+ java.util.Map<java.lang.String,SpoutSpec> __this__spouts = new java.util.HashMap<java.lang.String,SpoutSpec>(other.spouts.size());
+ for (java.util.Map.Entry<java.lang.String, SpoutSpec> other_element : other.spouts.entrySet()) {
- String other_element_key = other_element.getKey();
+ java.lang.String other_element_key = other_element.getKey();
SpoutSpec other_element_value = other_element.getValue();
- String __this__spouts_copy_key = other_element_key;
+ java.lang.String __this__spouts_copy_key = other_element_key;
SpoutSpec __this__spouts_copy_value = new SpoutSpec(other_element_value);
@@ -245,13 +215,13 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
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()) {
+ java.util.Map<java.lang.String,Bolt> __this__bolts = new java.util.HashMap<java.lang.String,Bolt>(other.bolts.size());
+ for (java.util.Map.Entry<java.lang.String, Bolt> other_element : other.bolts.entrySet()) {
- String other_element_key = other_element.getKey();
+ java.lang.String other_element_key = other_element.getKey();
Bolt other_element_value = other_element.getValue();
- String __this__bolts_copy_key = other_element_key;
+ java.lang.String __this__bolts_copy_key = other_element_key;
Bolt __this__bolts_copy_value = new Bolt(other_element_value);
@@ -260,13 +230,13 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
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()) {
+ java.util.Map<java.lang.String,StateSpoutSpec> __this__state_spouts = new java.util.HashMap<java.lang.String,StateSpoutSpec>(other.state_spouts.size());
+ for (java.util.Map.Entry<java.lang.String, StateSpoutSpec> other_element : other.state_spouts.entrySet()) {
- String other_element_key = other_element.getKey();
+ java.lang.String other_element_key = other_element.getKey();
StateSpoutSpec other_element_value = other_element.getValue();
- String __this__state_spouts_copy_key = other_element_key;
+ java.lang.String __this__state_spouts_copy_key = other_element_key;
StateSpoutSpec __this__state_spouts_copy_value = new StateSpoutSpec(other_element_value);
@@ -275,15 +245,15 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
this.state_spouts = __this__state_spouts;
}
if (other.is_set_worker_hooks()) {
- List<ByteBuffer> __this__worker_hooks = new ArrayList<ByteBuffer>(other.worker_hooks);
+ java.util.List<java.nio.ByteBuffer> __this__worker_hooks = new java.util.ArrayList<java.nio.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);
+ java.util.List<java.lang.String> __this__dependency_jars = new java.util.ArrayList<java.lang.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);
+ java.util.List<java.lang.String> __this__dependency_artifacts = new java.util.ArrayList<java.lang.String>(other.dependency_artifacts);
this.dependency_artifacts = __this__dependency_artifacts;
}
if (other.is_set_storm_version()) {
@@ -293,28 +263,28 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
this.jdk_version = other.jdk_version;
}
if (other.is_set_component_to_shared_memory()) {
- Map<String,Set<String>> __this__component_to_shared_memory = new HashMap<String,Set<String>>(other.component_to_shared_memory.size());
- for (Map.Entry<String, Set<String>> other_element : other.component_to_shared_memory.entrySet()) {
+ java.util.Map<java.lang.String,java.util.Set<java.lang.String>> __this__component_to_shared_memory = new java.util.HashMap<java.lang.String,java.util.Set<java.lang.String>>(other.component_to_shared_memory.size());
+ for (java.util.Map.Entry<java.lang.String, java.util.Set<java.lang.String>> other_element : other.component_to_shared_memory.entrySet()) {
- String other_element_key = other_element.getKey();
- Set<String> other_element_value = other_element.getValue();
+ java.lang.String other_element_key = other_element.getKey();
+ java.util.Set<java.lang.String> other_element_value = other_element.getValue();
- String __this__component_to_shared_memory_copy_key = other_element_key;
+ java.lang.String __this__component_to_shared_memory_copy_key = other_element_key;
- Set<String> __this__component_to_shared_memory_copy_value = new HashSet<String>(other_element_value);
+ java.util.Set<java.lang.String> __this__component_to_shared_memory_copy_value = new java.util.HashSet<java.lang.String>(other_element_value);
__this__component_to_shared_memory.put(__this__component_to_shared_memory_copy_key, __this__component_to_shared_memory_copy_value);
}
this.component_to_shared_memory = __this__component_to_shared_memory;
}
if (other.is_set_shared_memory()) {
- Map<String,SharedMemory> __this__shared_memory = new HashMap<String,SharedMemory>(other.shared_memory.size());
- for (Map.Entry<String, SharedMemory> other_element : other.shared_memory.entrySet()) {
+ java.util.Map<java.lang.String,SharedMemory> __this__shared_memory = new java.util.HashMap<java.lang.String,SharedMemory>(other.shared_memory.size());
+ for (java.util.Map.Entry<java.lang.String, SharedMemory> other_element : other.shared_memory.entrySet()) {
- String other_element_key = other_element.getKey();
+ java.lang.String other_element_key = other_element.getKey();
SharedMemory other_element_value = other_element.getValue();
- String __this__shared_memory_copy_key = other_element_key;
+ java.lang.String __this__shared_memory_copy_key = other_element_key;
SharedMemory __this__shared_memory_copy_value = new SharedMemory(other_element_value);
@@ -346,18 +316,18 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
return (this.spouts == null) ? 0 : this.spouts.size();
}
- public void put_to_spouts(String key, SpoutSpec val) {
+ public void put_to_spouts(java.lang.String key, SpoutSpec val) {
if (this.spouts == null) {
- this.spouts = new HashMap<String,SpoutSpec>();
+ this.spouts = new java.util.HashMap<java.lang.String,SpoutSpec>();
}
this.spouts.put(key, val);
}
- public Map<String,SpoutSpec> get_spouts() {
+ public java.util.Map<java.lang.String,SpoutSpec> get_spouts() {
return this.spouts;
}
- public void set_spouts(Map<String,SpoutSpec> spouts) {
+ public void set_spouts(java.util.Map<java.lang.String,SpoutSpec> spouts) {
this.spouts = spouts;
}
@@ -380,18 +350,18 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
return (this.bolts == null) ? 0 : this.bolts.size();
}
- public void put_to_bolts(String key, Bolt val) {
+ public void put_to_bolts(java.lang.String key, Bolt val) {
if (this.bolts == null) {
- this.bolts = new HashMap<String,Bolt>();
+ this.bolts = new java.util.HashMap<java.lang.String,Bolt>();
}
this.bolts.put(key, val);
}
- public Map<String,Bolt> get_bolts() {
+ public java.util.Map<java.lang.String,Bolt> get_bolts() {
return this.bolts;
}
- public void set_bolts(Map<String,Bolt> bolts) {
+ public void set_bolts(java.util.Map<java.lang.String,Bolt> bolts) {
this.bolts = bolts;
}
@@ -414,18 +384,18 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
return (this.state_spouts == null) ? 0 : this.state_spouts.size();
}
- public void put_to_state_spouts(String key, StateSpoutSpec val) {
+ public void put_to_state_spouts(java.lang.String key, StateSpoutSpec val) {
if (this.state_spouts == null) {
- this.state_spouts = new HashMap<String,StateSpoutSpec>();
+ this.state_spouts = new java.util.HashMap<java.lang.String,StateSpoutSpec>();
}
this.state_spouts.put(key, val);
}
- public Map<String,StateSpoutSpec> get_state_spouts() {
+ public java.util.Map<java.lang.String,StateSpoutSpec> get_state_spouts() {
return this.state_spouts;
}
- public void set_state_spouts(Map<String,StateSpoutSpec> state_spouts) {
+ public void set_state_spouts(java.util.Map<java.lang.String,StateSpoutSpec> state_spouts) {
this.state_spouts = state_spouts;
}
@@ -448,22 +418,22 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
return (this.worker_hooks == null) ? 0 : this.worker_hooks.size();
}
- public java.util.Iterator<ByteBuffer> get_worker_hooks_iterator() {
+ public java.util.Iterator<java.nio.ByteBuffer> get_worker_hooks_iterator() {
return (this.worker_hooks == null) ? null : this.worker_hooks.iterator();
}
- public void add_to_worker_hooks(ByteBuffer elem) {
+ public void add_to_worker_hooks(java.nio.ByteBuffer elem) {
if (this.worker_hooks == null) {
- this.worker_hooks = new ArrayList<ByteBuffer>();
+ this.worker_hooks = new java.util.ArrayList<java.nio.ByteBuffer>();
}
this.worker_hooks.add(elem);
}
- public List<ByteBuffer> get_worker_hooks() {
+ public java.util.List<java.nio.ByteBuffer> get_worker_hooks() {
return this.worker_hooks;
}
- public void set_worker_hooks(List<ByteBuffer> worker_hooks) {
+ public void set_worker_hooks(java.util.List<java.nio.ByteBuffer> worker_hooks) {
this.worker_hooks = worker_hooks;
}
@@ -486,22 +456,22 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
return (this.dependency_jars == null) ? 0 : this.dependency_jars.size();
}
- public java.util.Iterator<String> get_dependency_jars_iterator() {
+ public java.util.Iterator<java.lang.String> get_dependency_jars_iterator() {
return (this.dependency_jars == null) ? null : this.dependency_jars.iterator();
}
- public void add_to_dependency_jars(String elem) {
+ public void add_to_dependency_jars(java.lang.String elem) {
if (this.dependency_jars == null) {
- this.dependency_jars = new ArrayList<String>();
+ this.dependency_jars = new java.util.ArrayList<java.lang.String>();
}
this.dependency_jars.add(elem);
}
- public List<String> get_dependency_jars() {
+ public java.util.List<java.lang.String> get_dependency_jars() {
return this.dependency_jars;
}
- public void set_dependency_jars(List<String> dependency_jars) {
+ public void set_dependency_jars(java.util.List<java.lang.String> dependency_jars) {
this.dependency_jars = dependency_jars;
}
@@ -524,22 +494,22 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
return (this.dependency_artifacts == null) ? 0 : this.dependency_artifacts.size();
}
- public java.util.Iterator<String> get_dependency_artifacts_iterator() {
+ public java.util.Iterator<java.lang.String> get_dependency_artifacts_iterator() {
return (this.dependency_artifacts == null) ? null : this.dependency_artifacts.iterator();
}
- public void add_to_dependency_artifacts(String elem) {
+ public void add_to_dependency_artifacts(java.lang.String elem) {
if (this.dependency_artifacts == null) {
- this.dependency_artifacts = new ArrayList<String>();
+ this.dependency_artifacts = new java.util.ArrayList<java.lang.String>();
}
this.dependency_artifacts.add(elem);
}
- public List<String> get_dependency_artifacts() {
+ public java.util.List<java.lang.String> get_dependency_artifacts() {
return this.dependency_artifacts;
}
- public void set_dependency_artifacts(List<String> dependency_artifacts) {
+ public void set_dependency_artifacts(java.util.List<java.lang.String> dependency_artifacts) {
this.dependency_artifacts = dependency_artifacts;
}
@@ -558,11 +528,11 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
}
}
- public String get_storm_version() {
+ public java.lang.String get_storm_version() {
return this.storm_version;
}
- public void set_storm_version(String storm_version) {
+ public void set_storm_version(java.lang.String storm_version) {
this.storm_version = storm_version;
}
@@ -581,11 +551,11 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
}
}
- public String get_jdk_version() {
+ public java.lang.String get_jdk_version() {
return this.jdk_version;
}
- public void set_jdk_version(String jdk_version) {
+ public void set_jdk_version(java.lang.String jdk_version) {
this.jdk_version = jdk_version;
}
@@ -608,18 +578,18 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
return (this.component_to_shared_memory == null) ? 0 : this.component_to_shared_memory.size();
}
- public void put_to_component_to_shared_memory(String key, Set<String> val) {
+ public void put_to_component_to_shared_memory(java.lang.String key, java.util.Set<java.lang.String> val) {
if (this.component_to_shared_memory == null) {
- this.component_to_shared_memory = new HashMap<String,Set<String>>();
+ this.component_to_shared_memory = new java.util.HashMap<java.lang.String,java.util.Set<java.lang.String>>();
}
this.component_to_shared_memory.put(key, val);
}
- public Map<String,Set<String>> get_component_to_shared_memory() {
+ public java.util.Map<java.lang.String,java.util.Set<java.lang.String>> get_component_to_shared_memory() {
return this.component_to_shared_memory;
}
- public void set_component_to_shared_memory(Map<String,Set<String>> component_to_shared_memory) {
+ public void set_component_to_shared_memory(java.util.Map<java.lang.String,java.util.Set<java.lang.String>> component_to_shared_memory) {
this.component_to_shared_memory = component_to_shared_memory;
}
@@ -642,18 +612,18 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
return (this.shared_memory == null) ? 0 : this.shared_memory.size();
}
- public void put_to_shared_memory(String key, SharedMemory val) {
+ public void put_to_shared_memory(java.lang.String key, SharedMemory val) {
if (this.shared_memory == null) {
- this.shared_memory = new HashMap<String,SharedMemory>();
+ this.shared_memory = new java.util.HashMap<java.lang.String,SharedMemory>();
}
this.shared_memory.put(key, val);
}
- public Map<String,SharedMemory> get_shared_memory() {
+ public java.util.Map<java.lang.String,SharedMemory> get_shared_memory() {
return this.shared_memory;
}
- public void set_shared_memory(Map<String,SharedMemory> shared_memory) {
+ public void set_shared_memory(java.util.Map<java.lang.String,SharedMemory> shared_memory) {
this.shared_memory = shared_memory;
}
@@ -672,13 +642,13 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
}
}
- public void setFieldValue(_Fields field, Object value) {
+ public void setFieldValue(_Fields field, java.lang.Object value) {
switch (field) {
case SPOUTS:
if (value == null) {
unset_spouts();
} else {
- set_spouts((Map<String,SpoutSpec>)value);
+ set_spouts((java.util.Map<java.lang.String,SpoutSpec>)value);
}
break;
@@ -686,7 +656,7 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
if (value == null) {
unset_bolts();
} else {
- set_bolts((Map<String,Bolt>)value);
+ set_bolts((java.util.Map<java.lang.String,Bolt>)value);
}
break;
@@ -694,7 +664,7 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
if (value == null) {
unset_state_spouts();
} else {
- set_state_spouts((Map<String,StateSpoutSpec>)value);
+ set_state_spouts((java.util.Map<java.lang.String,StateSpoutSpec>)value);
}
break;
@@ -702,7 +672,7 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
if (value == null) {
unset_worker_hooks();
} else {
- set_worker_hooks((List<ByteBuffer>)value);
+ set_worker_hooks((java.util.List<java.nio.ByteBuffer>)value);
}
break;
@@ -710,7 +680,7 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
if (value == null) {
unset_dependency_jars();
} else {
- set_dependency_jars((List<String>)value);
+ set_dependency_jars((java.util.List<java.lang.String>)value);
}
break;
@@ -718,7 +688,7 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
if (value == null) {
unset_dependency_artifacts();
} else {
- set_dependency_artifacts((List<String>)value);
+ set_dependency_artifacts((java.util.List<java.lang.String>)value);
}
break;
@@ -726,7 +696,7 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
if (value == null) {
unset_storm_version();
} else {
- set_storm_version((String)value);
+ set_storm_version((java.lang.String)value);
}
break;
@@ -734,7 +704,7 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
if (value == null) {
unset_jdk_version();
} else {
- set_jdk_version((String)value);
+ set_jdk_version((java.lang.String)value);
}
break;
@@ -742,7 +712,7 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
if (value == null) {
unset_component_to_shared_memory();
} else {
- set_component_to_shared_memory((Map<String,Set<String>>)value);
+ set_component_to_shared_memory((java.util.Map<java.lang.String,java.util.Set<java.lang.String>>)value);
}
break;
@@ -750,14 +720,14 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
if (value == null) {
unset_shared_memory();
} else {
- set_shared_memory((Map<String,SharedMemory>)value);
+ set_shared_memory((java.util.Map<java.lang.String,SharedMemory>)value);
}
break;
}
}
- public Object getFieldValue(_Fields field) {
+ public java.lang.Object getFieldValue(_Fields field) {
switch (field) {
case SPOUTS:
return get_spouts();
@@ -790,13 +760,13 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
return get_shared_memory();
}
- throw new IllegalStateException();
+ throw new java.lang.IllegalStateException();
}
/** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */
public boolean isSet(_Fields field) {
if (field == null) {
- throw new IllegalArgumentException();
+ throw new java.lang.IllegalArgumentException();
}
switch (field) {
@@ -821,11 +791,11 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
case SHARED_MEMORY:
return is_set_shared_memory();
}
- throw new IllegalStateException();
+ throw new java.lang.IllegalStateException();
}
@Override
- public boolean equals(Object that) {
+ public boolean equals(java.lang.Object that) {
if (that == null)
return false;
if (that instanceof StormTopology)
@@ -836,6 +806,8 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
public boolean equals(StormTopology that) {
if (that == null)
return false;
+ if (this == that)
+ return true;
boolean this_present_spouts = true && this.is_set_spouts();
boolean that_present_spouts = true && that.is_set_spouts();
@@ -932,59 +904,49 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
@Override
public int hashCode() {
- List<Object> list = new ArrayList<Object>();
+ int hashCode = 1;
- boolean present_spouts = true && (is_set_spouts());
- list.add(present_spouts);
- if (present_spouts)
- list.add(spouts);
+ hashCode = hashCode * 8191 + ((is_set_spouts()) ? 131071 : 524287);
+ if (is_set_spouts())
+ hashCode = hashCode * 8191 + spouts.hashCode();
- boolean present_bolts = true && (is_set_bolts());
- list.add(present_bolts);
- if (present_bolts)
- list.add(bolts);
+ hashCode = hashCode * 8191 + ((is_set_bolts()) ? 131071 : 524287);
+ if (is_set_bolts())
+ hashCode = hashCode * 8191 + bolts.hashCode();
- boolean present_state_spouts = true && (is_set_state_spouts());
- list.add(present_state_spouts);
- if (present_state_spouts)
- list.add(state_spouts);
+ hashCode = hashCode * 8191 + ((is_set_state_spouts()) ? 131071 : 524287);
+ if (is_set_state_spouts())
+ hashCode = hashCode * 8191 + state_spouts.hashCode();
- boolean present_worker_hooks = true && (is_set_worker_hooks());
- list.add(present_worker_hooks);
- if (present_worker_hooks)
- list.add(worker_hooks);
+ hashCode = hashCode * 8191 + ((is_set_worker_hooks()) ? 131071 : 524287);
+ if (is_set_worker_hooks())
+ hashCode = hashCode * 8191 + worker_hooks.hashCode();
- boolean present_dependency_jars = true && (is_set_dependency_jars());
- list.add(present_dependency_jars);
- if (present_dependency_jars)
- list.add(dependency_jars);
+ hashCode = hashCode * 8191 + ((is_set_dependency_jars()) ? 131071 : 524287);
+ if (is_set_dependency_jars())
+ hashCode = hashCode * 8191 + dependency_jars.hashCode();
- boolean present_dependency_artifacts = true && (is_set_dependency_artifacts());
- list.add(present_dependency_artifacts);
- if (present_dependency_artifacts)
- list.add(dependency_artifacts);
+ hashCode = hashCode * 8191 + ((is_set_dependency_artifacts()) ? 131071 : 524287);
+ if (is_set_dependency_artifacts())
+ hashCode = hashCode * 8191 + dependency_artifacts.hashCode();
- boolean present_storm_version = true && (is_set_storm_version());
- list.add(present_storm_version);
- if (present_storm_version)
- list.add(storm_version);
+ hashCode = hashCode * 8191 + ((is_set_storm_version()) ? 131071 : 524287);
+ if (is_set_storm_version())
+ hashCode = hashCode * 8191 + storm_version.hashCode();
- boolean present_jdk_version = true && (is_set_jdk_version());
- list.add(present_jdk_version);
- if (present_jdk_version)
- list.add(jdk_version);
+ hashCode = hashCode * 8191 + ((is_set_jdk_version()) ? 131071 : 524287);
+ if (is_set_jdk_version())
+ hashCode = hashCode * 8191 + jdk_version.hashCode();
- boolean present_component_to_shared_memory = true && (is_set_component_to_shared_memory());
- list.add(present_component_to_shared_memory);
- if (present_component_to_shared_memory)
- list.add(component_to_shared_memory);
+ hashCode = hashCode * 8191 + ((is_set_component_to_shared_memory()) ? 131071 : 524287);
+ if (is_set_component_to_shared_memory())
+ hashCode = hashCode * 8191 + component_to_shared_memory.hashCode();
- boolean present_shared_memory = true && (is_set_shared_memory());
- list.add(present_shared_memory);
- if (present_shared_memory)
- list.add(shared_memory);
+ hashCode = hashCode * 8191 + ((is_set_shared_memory()) ? 131071 : 524287);
+ if (is_set_shared_memory())
+ hashCode = hashCode * 8191 + shared_memory.hashCode();
- return list.hashCode();
+ return hashCode;
}
@Override
@@ -995,7 +957,7 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
int lastComparison = 0;
- lastComparison = Boolean.valueOf(is_set_spouts()).compareTo(other.is_set_spouts());
+ lastComparison = java.lang.Boolean.valueOf(is_set_spouts()).compareTo(other.is_set_spouts());
if (lastComparison != 0) {
return lastComparison;
}
@@ -1005,7 +967,7 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
return lastComparison;
}
}
- lastComparison = Boolean.valueOf(is_set_bolts()).compareTo(other.is_set_bolts());
+ lastComparison = java.lang.Boolean.valueOf(is_set_bolts()).compareTo(other.is_set_bolts());
if (lastComparison != 0) {
return lastComparison;
}
@@ -1015,7 +977,7 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
return lastComparison;
}
}
- lastComparison = Boolean.valueOf(is_set_state_spouts()).compareTo(other.is_set_state_spouts());
+ lastComparison = java.lang.Boolean.valueOf(is_set_state_spouts()).compareTo(other.is_set_state_spouts());
if (lastComparison != 0) {
return lastComparison;
}
@@ -1025,7 +987,7 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
return lastComparison;
}
}
- lastComparison = Boolean.valueOf(is_set_worker_hooks()).compareTo(other.is_set_worker_hooks());
+ lastComparison = java.lang.Boolean.valueOf(is_set_worker_hooks()).compareTo(other.is_set_worker_hooks());
if (lastComparison != 0) {
return lastComparison;
}
@@ -1035,7 +997,7 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
return lastComparison;
}
}
- lastComparison = Boolean.valueOf(is_set_dependency_jars()).compareTo(other.is_set_dependency_jars());
+ lastComparison = java.lang.Boolean.valueOf(is_set_dependency_jars()).compareTo(other.is_set_dependency_jars());
if (lastComparison != 0) {
return lastComparison;
}
@@ -1045,7 +1007,7 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
return lastComparison;
}
}
- lastComparison = Boolean.valueOf(is_set_dependency_artifacts()).compareTo(other.is_set_dependency_artifacts());
+ lastComparison = java.lang.Boolean.valueOf(is_set_dependency_artifacts()).compareTo(other.is_set_dependency_artifacts());
if (lastComparison != 0) {
return lastComparison;
}
@@ -1055,7 +1017,7 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
return lastComparison;
}
}
- lastComparison = Boolean.valueOf(is_set_storm_version()).compareTo(other.is_set_storm_version());
+ lastComparison = java.lang.Boolean.valueOf(is_set_storm_version()).compareTo(other.is_set_storm_version());
if (lastComparison != 0) {
return lastComparison;
}
@@ -1065,7 +1027,7 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
return lastComparison;
}
}
- lastComparison = Boolean.valueOf(is_set_jdk_version()).compareTo(other.is_set_jdk_version());
+ lastComparison = java.lang.Boolean.valueOf(is_set_jdk_version()).compareTo(other.is_set_jdk_version());
if (lastComparison != 0) {
return lastComparison;
}
@@ -1075,7 +1037,7 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
return lastComparison;
}
}
- lastComparison = Boolean.valueOf(is_set_component_to_shared_memory()).compareTo(other.is_set_component_to_shared_memory());
+ lastComparison = java.lang.Boolean.valueOf(is_set_component_to_shared_memory()).compareTo(other.is_set_component_to_shared_memory());
if (lastComparison != 0) {
return lastComparison;
}
@@ -1085,7 +1047,7 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
return lastComparison;
}
}
- lastComparison = Boolean.valueOf(is_set_shared_memory()).compareTo(other.is_set_shared_memory());
+ lastComparison = java.lang.Boolean.valueOf(is_set_shared_memory()).compareTo(other.is_set_shared_memory());
if (lastComparison != 0) {
return lastComparison;
}
@@ -1103,16 +1065,16 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
}
public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException {
- schemes.get(iprot.getScheme()).getScheme().read(iprot, this);
+ scheme(iprot).read(iprot, this);
}
public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
- schemes.get(oprot.getScheme()).getScheme().write(oprot, this);
+ scheme(oprot).write(oprot, this);
}
@Override
- public String toString() {
- StringBuilder sb = new StringBuilder("StormTopology(");
+ public java.lang.String toString() {
+ java.lang.StringBuilder sb = new java.lang.StringBuilder("StormTopology(");
boolean first = true;
sb.append("spouts:");
@@ -1237,7 +1199,7 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
}
}
- private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
+ private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, java.lang.ClassNotFoundException {
try {
read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
} catch (org.apache.thrift.TException te) {
@@ -1245,13 +1207,13 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
}
}
- private static class StormTopologyStandardSchemeFactory implements SchemeFactory {
+ private static class StormTopologyStandardSchemeFactory implements org.apache.thrift.scheme.SchemeFactory {
public StormTopologyStandardScheme getScheme() {
return new StormTopologyStandardScheme();
}
}
- private static class StormTopologyStandardScheme extends StandardScheme<StormTopology> {
+ private static class StormTopologyStandardScheme extends org.apache.thrift.scheme.StandardScheme<StormTopology> {
public void read(org.apache.thrift.protocol.TProtocol iprot, StormTopology struct) throws org.apache.thrift.TException {
org.apache.thrift.protocol.TField schemeField;
@@ -1267,8 +1229,8 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
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;
+ struct.spouts = new java.util.HashMap<java.lang.String,SpoutSpec>(2*_map44.size);
+ java.lang.String _key45;
SpoutSpec _val46;
for (int _i47 = 0; _i47 < _map44.size; ++_i47)
{
@@ -1288,8 +1250,8 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
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;
+ struct.bolts = new java.util.HashMap<java.lang.String,Bolt>(2*_map48.size);
+ java.lang.String _key49;
Bolt _val50;
for (int _i51 = 0; _i51 < _map48.size; ++_i51)
{
@@ -1309,8 +1271,8 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
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;
+ struct.state_spouts = new java.util.HashMap<java.lang.String,StateSpoutSpec>(2*_map52.size);
+ java.lang.String _key53;
StateSpoutSpec _val54;
for (int _i55 = 0; _i55 < _map52.size; ++_i55)
{
@@ -1330,8 +1292,8 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
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;
+ struct.worker_hooks = new java.util.ArrayList<java.nio.ByteBuffer>(_list56.size);
+ java.nio.ByteBuffer _elem57;
for (int _i58 = 0; _i58 < _list56.size; ++_i58)
{
_elem57 = iprot.readBinary();
@@ -1348,8 +1310,8 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
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;
+ struct.dependency_jars = new java.util.ArrayList<java.lang.String>(_list59.size);
+ java.lang.String _elem60;
for (int _i61 = 0; _i61 < _list59.size; ++_i61)
{
_elem60 = iprot.readString();
@@ -1366,8 +1328,8 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
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;
+ struct.dependency_artifacts = new java.util.ArrayList<java.lang.String>(_list62.size);
+ java.lang.String _elem63;
for (int _i64 = 0; _i64 < _list62.size; ++_i64)
{
_elem63 = iprot.readString();
@@ -1400,16 +1362,16 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
org.apache.thrift.protocol.TMap _map65 = iprot.readMapBegin();
- struct.component_to_shared_memory = new HashMap<String,Set<String>>(2*_map65.size);
- String _key66;
- Set<String> _val67;
+ struct.component_to_shared_memory = new java.util.HashMap<java.lang.String,java.util.Set<java.lang.String>>(2*_map65.size);
+ java.lang.String _key66;
+ java.util.Set<java.lang.String> _val67;
for (int _i68 = 0; _i68 < _map65.size; ++_i68)
{
_key66 = iprot.readString();
{
org.apache.thrift.protocol.TSet _set69 = iprot.readSetBegin();
- _val67 = new HashSet<String>(2*_set69.size);
- String _elem70;
+ _val67 = new java.util.HashSet<java.lang.String>(2*_set69.size);
+ java.lang.String _elem70;
for (int _i71 = 0; _i71 < _set69.size; ++_i71)
{
_elem70 = iprot.readString();
@@ -1430,8 +1392,8 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
org.apache.thrift.protocol.TMap _map72 = iprot.readMapBegin();
- struct.shared_memory = new HashMap<String,SharedMemory>(2*_map72.size);
- String _key73;
+ struct.shared_memory = new java.util.HashMap<java.lang.String,SharedMemory>(2*_map72.size);
+ java.lang.String _key73;
SharedMemory _val74;
for (int _i75 = 0; _i75 < _map72.size; ++_i75)
{
@@ -1464,7 +1426,7 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
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> _iter76 : struct.spouts.entrySet())
+ for (java.util.Map.Entry<java.lang.String, SpoutSpec> _iter76 : struct.spouts.entrySet())
{
oprot.writeString(_iter76.getKey());
_iter76.getValue().write(oprot);
@@ -1477,7 +1439,7 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
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> _iter77 : struct.bolts.entrySet())
+ for (java.util.Map.Entry<java.lang.String, Bolt> _iter77 : struct.bolts.entrySet())
{
oprot.writeString(_iter77.getKey());
_iter77.getValue().write(oprot);
@@ -1490,7 +1452,7 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
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> _iter78 : struct.state_spouts.entrySet())
+ for (java.util.Map.Entry<java.lang.String, StateSpoutSpec> _iter78 : struct.state_spouts.entrySet())
{
oprot.writeString(_iter78.getKey());
_iter78.getValue().write(oprot);
@@ -1504,7 +1466,7 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
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 _iter79 : struct.worker_hooks)
+ for (java.nio.ByteBuffer _iter79 : struct.worker_hooks)
{
oprot.writeBinary(_iter79);
}
@@ -1518,7 +1480,7 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
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 _iter80 : struct.dependency_jars)
+ for (java.lang.String _iter80 : struct.dependency_jars)
{
oprot.writeString(_iter80);
}
@@ -1532,7 +1494,7 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
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 _iter81 : struct.dependency_artifacts)
+ for (java.lang.String _iter81 : struct.dependency_artifacts)
{
oprot.writeString(_iter81);
}
@@ -1560,12 +1522,12 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
oprot.writeFieldBegin(COMPONENT_TO_SHARED_MEMORY_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.SET, struct.component_to_shared_memory.size()));
- for (Map.Entry<String, Set<String>> _iter82 : struct.component_to_shared_memory.entrySet())
+ for (java.util.Map.Entry<java.lang.String, java.util.Set<java.lang.String>> _iter82 : struct.component_to_shared_memory.entrySet())
{
oprot.writeString(_iter82.getKey());
{
oprot.writeSetBegin(new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRING, _iter82.getValue().size()));
- for (String _iter83 : _iter82.getValue())
+ for (java.lang.String _iter83 : _iter82.getValue())
{
oprot.writeString(_iter83);
}
@@ -1582,7 +1544,7 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
oprot.writeFieldBegin(SHARED_MEMORY_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, struct.shared_memory.size()));
- for (Map.Entry<String, SharedMemory> _iter84 : struct.shared_memory.entrySet())
+ for (java.util.Map.Entry<java.lang.String, SharedMemory> _iter84 : struct.shared_memory.entrySet())
{
oprot.writeString(_iter84.getKey());
_iter84.getValue().write(oprot);
@@ -1598,20 +1560,20 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
}
- private static class StormTopologyTupleSchemeFactory implements SchemeFactory {
+ private static class StormTopologyTupleSchemeFactory implements org.apache.thrift.scheme.SchemeFactory {
public StormTopologyTupleScheme getScheme() {
return new StormTopologyTupleScheme();
}
}
- private static class StormTopologyTupleScheme extends TupleScheme<StormTopology> {
+ private static class StormTopologyTupleScheme extends org.apache.thrift.scheme.TupleScheme<StormTopology> {
@Override
public void write(org.apache.thrift.protocol.TProtocol prot, StormTopology struct) throws org.apache.thrift.TException {
- TTupleProtocol oprot = (TTupleProtocol) prot;
+ org.apache.thrift.protocol.TTupleProtocol oprot = (org.apache.thrift.protocol.TTupleProtocol) prot;
{
oprot.writeI32(struct.spouts.size());
- for (Map.Entry<String, SpoutSpec> _iter85 : struct.spouts.entrySet())
+ for (java.util.Map.Entry<java.lang.String, SpoutSpec> _iter85 : struct.spouts.entrySet())
{
oprot.writeString(_iter85.getKey());
_iter85.getValue().write(oprot);
@@ -1619,7 +1581,7 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
}
{
oprot.writeI32(struct.bolts.size());
- for (Map.Entry<String, Bolt> _iter86 : struct.bolts.entrySet())
+ for (java.util.Map.Entry<java.lang.String, Bolt> _iter86 : struct.bolts.entrySet())
{
oprot.writeString(_iter86.getKey());
_iter86.getValue().write(oprot);
@@ -1627,13 +1589,13 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
}
{
oprot.writeI32(struct.state_spouts.size());
- for (Map.Entry<String, StateSpoutSpec> _iter87 : struct.state_spouts.entrySet())
+ for (java.util.Map.Entry<java.lang.String, StateSpoutSpec> _iter87 : struct.state_spouts.entrySet())
{
oprot.writeString(_iter87.getKey());
_iter87.getValue().write(oprot);
}
}
- BitSet optionals = new BitSet();
+ java.util.BitSet optionals = new java.util.BitSet();
if (struct.is_set_worker_hooks()) {
optionals.set(0);
}
@@ -1659,7 +1621,7 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
if (struct.is_set_worker_hooks()) {
{
oprot.writeI32(struct.worker_hooks.size());
- for (ByteBuffer _iter88 : struct.worker_hooks)
+ for (java.nio.ByteBuffer _iter88 : struct.worker_hooks)
{
oprot.writeBinary(_iter88);
}
@@ -1668,7 +1630,7 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
if (struct.is_set_dependency_jars()) {
{
oprot.writeI32(struct.dependency_jars.size());
- for (String _iter89 : struct.dependency_jars)
+ for (java.lang.String _iter89 : struct.dependency_jars)
{
oprot.writeString(_iter89);
}
@@ -1677,7 +1639,7 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
if (struct.is_set_dependency_artifacts()) {
{
oprot.writeI32(struct.dependency_artifacts.size());
- for (String _iter90 : struct.dependency_artifacts)
+ for (java.lang.String _iter90 : struct.dependency_artifacts)
{
oprot.writeString(_iter90);
}
@@ -1692,12 +1654,12 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
if (struct.is_set_component_to_shared_memory()) {
{
oprot.writeI32(struct.component_to_shared_memory.size());
- for (Map.Entry<String, Set<String>> _iter91 : struct.component_to_shared_memory.entrySet())
+ for (java.util.Map.Entry<java.lang.String, java.util.Set<java.lang.String>> _iter91 : struct.component_to_shared_memory.entrySet())
{
oprot.writeString(_iter91.getKey());
{
oprot.writeI32(_iter91.getValue().size());
- for (String _iter92 : _iter91.getValue())
+ for (java.lang.String _iter92 : _iter91.getValue())
{
oprot.writeString(_iter92);
}
@@ -1708,7 +1670,7 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
if (struct.is_set_shared_memory()) {
{
oprot.writeI32(struct.shared_memory.size());
- for (Map.Entry<String, SharedMemory> _iter93 : struct.shared_memory.entrySet())
+ for (java.util.Map.Entry<java.lang.String, SharedMemory> _iter93 : struct.shared_memory.entrySet())
{
oprot.writeString(_iter93.getKey());
_iter93.getValue().write(oprot);
@@ -1719,11 +1681,11 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
@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.TTupleProtocol iprot = (org.apache.thrift.protocol.TTupleProtocol) prot;
{
org.apache.thrift.protocol.TMap _map94 = 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*_map94.size);
- String _key95;
+ struct.spouts = new java.util.HashMap<java.lang.String,SpoutSpec>(2*_map94.size);
+ java.lang.String _key95;
SpoutSpec _val96;
for (int _i97 = 0; _i97 < _map94.size; ++_i97)
{
@@ -1736,8 +1698,8 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
struct.set_spouts_isSet(true);
{
org.apache.thrift.protocol.TMap _map98 = 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*_map98.size);
- String _key99;
+ struct.bolts = new java.util.HashMap<java.lang.String,Bolt>(2*_map98.size);
+ java.lang.String _key99;
Bolt _val100;
for (int _i101 = 0; _i101 < _map98.size; ++_i101)
{
@@ -1750,8 +1712,8 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
struct.set_bolts_isSet(true);
{
org.apache.thrift.protocol.TMap _map102 = 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*_map102.size);
- String _key103;
+ struct.state_spouts = new java.util.HashMap<java.lang.String,StateSpoutSpec>(2*_map102.size);
+ java.lang.String _key103;
StateSpoutSpec _val104;
for (int _i105 = 0; _i105 < _map102.size; ++_i105)
{
@@ -1762,12 +1724,12 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
}
}
struct.set_state_spouts_isSet(true);
- BitSet incoming = iprot.readBitSet(7);
+ java.util.BitSet incoming = iprot.readBitSet(7);
if (incoming.get(0)) {
{
org.apache.thrift.protocol.TList _list106 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.worker_hooks = new ArrayList<ByteBuffer>(_list106.size);
- ByteBuffer _elem107;
+ struct.worker_hooks = new java.util.ArrayList<java.nio.ByteBuffer>(_list106.size);
+ java.nio.ByteBuffer _elem107;
for (int _i108 = 0; _i108 < _list106.size; ++_i108)
{
_elem107 = iprot.readBinary();
@@ -1779,8 +1741,8 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
if (incoming.get(1)) {
{
org.apache.thrift.protocol.TList _list109 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.dependency_jars = new ArrayList<String>(_list109.size);
- String _elem110;
+ struct.dependency_jars = new java.util.ArrayList<java.lang.String>(_list109.size);
+ java.lang.String _elem110;
for (int _i111 = 0; _i111 < _list109.size; ++_i111)
{
_elem110 = iprot.readString();
@@ -1792,8 +1754,8 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
if (incoming.get(2)) {
{
org.apache.thrift.protocol.TList _list112 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.dependency_artifacts = new ArrayList<String>(_list112.size);
- String _elem113;
+ struct.dependency_artifacts = new java.util.ArrayList<java.lang.String>(_list112.size);
+ java.lang.String _elem113;
for (int _i114 = 0; _i114 < _list112.size; ++_i114)
{
_elem113 = iprot.readString();
@@ -1813,16 +1775,16 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
if (incoming.get(5)) {
{
org.apache.thrift.protocol.TMap _map115 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.SET, iprot.readI32());
- struct.component_to_shared_memory = new HashMap<String,Set<String>>(2*_map115.size);
- String _key116;
- Set<String> _val117;
+ struct.component_to_shared_memory = new java.util.HashMap<java.lang.String,java.util.Set<java.lang.String>>(2*_map115.size);
+ java.lang.String _key116;
+ java.util.Set<java.lang.String> _val117;
for (int _i118 = 0; _i118 < _map115.size; ++_i118)
{
_key116 = iprot.readString();
{
org.apache.thrift.protocol.TSet _set119 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- _val117 = new HashSet<String>(2*_set119.size);
- String _elem120;
+ _val117 = new java.util.HashSet<java.lang.String>(2*_set119.size);
+ java.lang.String _elem120;
for (int _i121 = 0; _i121 < _set119.size; ++_i121)
{
_elem120 = iprot.readString();
@@ -1837,8 +1799,8 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
if (incoming.get(6)) {
{
org.apache.thrift.protocol.TMap _map122 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.shared_memory = new HashMap<String,SharedMemory>(2*_map122.size);
- String _key123;
+ struct.shared_memory = new java.util.HashMap<java.lang.String,SharedMemory>(2*_map122.size);
+ java.lang.String _key123;
SharedMemory _val124;
for (int _i125 = 0; _i125 < _map122.size; ++_i125)
{
@@ -1853,5 +1815,8 @@ public class StormTopology implements org.apache.thrift.TBase<StormTopology, Sto
}
}
+ private static <S extends org.apache.thrift.scheme.IScheme> S scheme(org.apache.thrift.protocol.TProtocol proto) {
+ return (org.apache.thrift.scheme.StandardScheme.class.equals(proto.getScheme()) ? STANDARD_SCHEME_FACTORY : TUPLE_SCHEME_FACTORY).getScheme();
+ }
}
http://git-wip-us.apache.org/repos/asf/storm/blob/1fd1e17f/storm-client/src/jvm/org/apache/storm/generated/StreamInfo.java
----------------------------------------------------------------------
diff --git a/storm-client/src/jvm/org/apache/storm/generated/StreamInfo.java b/storm-client/src/jvm/org/apache/storm/generated/StreamInfo.java
index bb78631..2f29b7c 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/StreamInfo.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/StreamInfo.java
@@ -16,55 +16,25 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.3)
+ * Autogenerated by Thrift Compiler (0.11.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
*/
package org.apache.storm.generated;
-import org.apache.thrift.scheme.IScheme;
-import org.apache.thrift.scheme.SchemeFactory;
-import org.apache.thrift.scheme.StandardScheme;
-
-import org.apache.thrift.scheme.TupleScheme;
-import org.apache.thrift.protocol.TTupleProtocol;
-import org.apache.thrift.protocol.TProtocolException;
-import org.apache.thrift.EncodingUtils;
-import org.apache.thrift.TException;
-import org.apache.thrift.async.AsyncMethodCallback;
-import org.apache.thrift.server.AbstractNonblockingServer.*;
-import java.util.List;
-import java.util.ArrayList;
-import java.util.Map;
-import java.util.HashMap;
-import java.util.EnumMap;
-import java.util.Set;
-import java.util.HashSet;
-import java.util.EnumSet;
-import java.util.Collections;
-import java.util.BitSet;
-import java.nio.ByteBuffer;
-import java.util.Arrays;
-import javax.annotation.Generated;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
+@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
+@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.11.0)")
public class 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 static final org.apache.thrift.scheme.SchemeFactory STANDARD_SCHEME_FACTORY = new StreamInfoStandardSchemeFactory();
+ private static final org.apache.thrift.scheme.SchemeFactory TUPLE_SCHEME_FACTORY = new StreamInfoTupleSchemeFactory();
- private List<String> output_fields; // required
+ private java.util.List<java.lang.String> output_fields; // required
private boolean direct; // required
/** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
@@ -72,10 +42,10 @@ public class StreamInfo implements org.apache.thrift.TBase<StreamInfo, StreamInf
OUTPUT_FIELDS((short)1, "output_fields"),
DIRECT((short)2, "direct");
- private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
+ private static final java.util.Map<java.lang.String, _Fields> byName = new java.util.HashMap<java.lang.String, _Fields>();
static {
- for (_Fields field : EnumSet.allOf(_Fields.class)) {
+ for (_Fields field : java.util.EnumSet.allOf(_Fields.class)) {
byName.put(field.getFieldName(), field);
}
}
@@ -100,21 +70,21 @@ public class StreamInfo implements org.apache.thrift.TBase<StreamInfo, StreamInf
*/
public static _Fields findByThriftIdOrThrow(int fieldId) {
_Fields fields = findByThriftId(fieldId);
- if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
+ if (fields == null) throw new java.lang.IllegalArgumentException("Field " + fieldId + " doesn't exist!");
return fields;
}
/**
* Find the _Fields constant that matches name, or null if its not found.
*/
- public static _Fields findByName(String name) {
+ public static _Fields findByName(java.lang.String name) {
return byName.get(name);
}
private final short _thriftId;
- private final String _fieldName;
+ private final java.lang.String _fieldName;
- _Fields(short thriftId, String fieldName) {
+ _Fields(short thriftId, java.lang.String fieldName) {
_thriftId = thriftId;
_fieldName = fieldName;
}
@@ -123,7 +93,7 @@ public class StreamInfo implements org.apache.thrift.TBase<StreamInfo, StreamInf
return _thriftId;
}
- public String getFieldName() {
+ public java.lang.String getFieldName() {
return _fieldName;
}
}
@@ -131,15 +101,15 @@ public class StreamInfo implements org.apache.thrift.TBase<StreamInfo, StreamInf
// 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;
+ public static final java.util.Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
static {
- Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
+ java.util.Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new java.util.EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
tmpMap.put(_Fields.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);
+ metaDataMap = java.util.Collections.unmodifiableMap(tmpMap);
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(StreamInfo.class, metaDataMap);
}
@@ -147,7 +117,7 @@ public class StreamInfo implements org.apache.thrift.TBase<StreamInfo, StreamInf
}
public StreamInfo(
- List<String> output_fields,
+ java.util.List<java.lang.String> output_fields,
boolean direct)
{
this();
@@ -162,7 +132,7 @@ public class StreamInfo implements org.apache.thrift.TBase<StreamInfo, StreamInf
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);
+ java.util.List<java.lang.String> __this__output_fields = new java.util.ArrayList<java.lang.String>(other.output_fields);
this.output_fields = __this__output_fields;
}
this.direct = other.direct;
@@ -183,22 +153,22 @@ public class StreamInfo implements org.apache.thrift.TBase<StreamInfo, StreamInf
return (this.output_fields == null) ? 0 : this.output_fields.size();
}
- public java.util.Iterator<String> get_output_fields_iterator() {
+ public java.util.Iterator<java.lang.String> get_output_fields_iterator() {
return (this.output_fields == null) ? null : this.output_fields.iterator();
}
- public void add_to_output_fields(String elem) {
+ public void add_to_output_fields(java.lang.String elem) {
if (this.output_fields == null) {
- this.output_fields = new ArrayList<String>();
+ this.output_fields = new java.util.ArrayList<java.lang.String>();
}
this.output_fields.add(elem);
}
- public List<String> get_output_fields() {
+ public java.util.List<java.lang.String> get_output_fields() {
return this.output_fields;
}
- public void set_output_fields(List<String> output_fields) {
+ public void set_output_fields(java.util.List<java.lang.String> output_fields) {
this.output_fields = output_fields;
}
@@ -227,25 +197,25 @@ public class StreamInfo implements org.apache.thrift.TBase<StreamInfo, StreamInf
}
public void unset_direct() {
- __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __DIRECT_ISSET_ID);
+ __isset_bitfield = org.apache.thrift.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);
+ return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __DIRECT_ISSET_ID);
}
public void set_direct_isSet(boolean value) {
- __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __DIRECT_ISSET_ID, value);
+ __isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __DIRECT_ISSET_ID, value);
}
- public void setFieldValue(_Fields field, Object value) {
+ public void setFieldValue(_Fields field, java.lang.Object value) {
switch (field) {
case OUTPUT_FIELDS:
if (value == null) {
unset_output_fields();
} else {
- set_output_fields((List<String>)value);
+ set_output_fields((java.util.List<java.lang.String>)value);
}
break;
@@ -253,14 +223,14 @@ public class StreamInfo implements org.apache.thrift.TBase<StreamInfo, StreamInf
if (value == null) {
unset_direct();
} else {
- set_direct((Boolean)value);
+ set_direct((java.lang.Boolean)value);
}
break;
}
}
- public Object getFieldValue(_Fields field) {
+ public java.lang.Object getFieldValue(_Fields field) {
switch (field) {
case OUTPUT_FIELDS:
return get_output_fields();
@@ -269,13 +239,13 @@ public class StreamInfo implements org.apache.thrift.TBase<StreamInfo, StreamInf
return is_direct();
}
- throw new IllegalStateException();
+ throw new java.lang.IllegalStateException();
}
/** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */
public boolean isSet(_Fields field) {
if (field == null) {
- throw new IllegalArgumentException();
+ throw new java.lang.IllegalArgumentException();
}
switch (field) {
@@ -284,11 +254,11 @@ public class StreamInfo implements org.apache.thrift.TBase<StreamInfo, StreamInf
case DIRECT:
return is_set_direct();
}
- throw new IllegalStateException();
+ throw new java.lang.IllegalStateException();
}
@Override
- public boolean equals(Object that) {
+ public boolean equals(java.lang.Object that) {
if (that == null)
return false;
if (that instanceof StreamInfo)
@@ -299,6 +269,8 @@ public class StreamInfo implements org.apache.thrift.TBase<StreamInfo, StreamInf
public boolean equals(StreamInfo that) {
if (that == null)
return false;
+ if (this == that)
+ return true;
boolean this_present_output_fields = true && this.is_set_output_fields();
boolean that_present_output_fields = true && that.is_set_output_fields();
@@ -323,19 +295,15 @@ public class StreamInfo implements org.apache.thrift.TBase<StreamInfo, StreamInf
@Override
public int hashCode() {
- List<Object> list = new ArrayList<Object>();
+ int hashCode = 1;
- boolean present_output_fields = true && (is_set_output_fields());
- list.add(present_output_fields);
- if (present_output_fields)
- list.add(output_fields);
+ hashCode = hashCode * 8191 + ((is_set_output_fields()) ? 131071 : 524287);
+ if (is_set_output_fields())
+ hashCode = hashCode * 8191 + output_fields.hashCode();
- boolean present_direct = true;
- list.add(present_direct);
- if (present_direct)
- list.add(direct);
+ hashCode = hashCode * 8191 + ((direct) ? 131071 : 524287);
- return list.hashCode();
+ return hashCode;
}
@Override
@@ -346,7 +314,7 @@ public class StreamInfo implements org.apache.thrift.TBase<StreamInfo, StreamInf
int lastComparison = 0;
- lastComparison = Boolean.valueOf(is_set_output_fields()).compareTo(other.is_set_output_fields());
+ lastComparison = java.lang.Boolean.valueOf(is_set_output_fields()).compareTo(other.is_set_output_fields());
if (lastComparison != 0) {
return lastComparison;
}
@@ -356,7 +324,7 @@ public class StreamInfo implements org.apache.thrift.TBase<StreamInfo, StreamInf
return lastComparison;
}
}
- lastComparison = Boolean.valueOf(is_set_direct()).compareTo(other.is_set_direct());
+ lastComparison = java.lang.Boolean.valueOf(is_set_direct()).compareTo(other.is_set_direct());
if (lastComparison != 0) {
return lastComparison;
}
@@ -374,16 +342,16 @@ public class StreamInfo implements org.apache.thrift.TBase<StreamInfo, StreamInf
}
public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException {
- schemes.get(iprot.getScheme()).getScheme().read(iprot, this);
+ scheme(iprot).read(iprot, this);
}
public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
- schemes.get(oprot.getScheme()).getScheme().write(oprot, this);
+ scheme(oprot).write(oprot, this);
}
@Override
- public String toString() {
- StringBuilder sb = new StringBuilder("StreamInfo(");
+ public java.lang.String toString() {
+ java.lang.StringBuilder sb = new java.lang.StringBuilder("StreamInfo(");
boolean first = true;
sb.append("output_fields:");
@@ -422,7 +390,7 @@ public class StreamInfo implements org.apache.thrift.TBase<StreamInfo, StreamInf
}
}
- private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
+ private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, java.lang.ClassNotFoundException {
try {
// it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor.
__isset_bitfield = 0;
@@ -432,13 +400,13 @@ public class StreamInfo implements org.apache.thrift.TBase<StreamInfo, StreamInf
}
}
- private static class StreamInfoStandardSchemeFactory implements SchemeFactory {
+ private static class StreamInfoStandardSchemeFactory implements org.apache.thrift.scheme.SchemeFactory {
public StreamInfoStandardScheme getScheme() {
return new StreamInfoStandardScheme();
}
}
- private static class StreamInfoStandardScheme extends StandardScheme<StreamInfo> {
+ private static class StreamInfoStandardScheme extends org.apache.thrift.scheme.StandardScheme<StreamInfo> {
public void read(org.apache.thrift.protocol.TProtocol iprot, StreamInfo struct) throws org.apache.thrift.TException {
org.apache.thrift.protocol.TField schemeField;
@@ -454,8 +422,8 @@ public class StreamInfo implements org.apache.thrift.TBase<StreamInfo, StreamInf
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;
+ struct.output_fields = new java.util.ArrayList<java.lang.String>(_list16.size);
+ java.lang.String _elem17;
for (int _i18 = 0; _i18 < _list16.size; ++_i18)
{
_elem17 = iprot.readString();
@@ -493,7 +461,7 @@ public class StreamInfo implements org.apache.thrift.TBase<StreamInfo, StreamInf
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)
+ for (java.lang.String _iter19 : struct.output_fields)
{
oprot.writeString(_iter19);
}
@@ -510,20 +478,20 @@ public class StreamInfo implements org.apache.thrift.TBase<StreamInfo, StreamInf
}
- private static class StreamInfoTupleSchemeFactory implements SchemeFactory {
+ private static class StreamInfoTupleSchemeFactory implements org.apache.thrift.scheme.SchemeFactory {
public StreamInfoTupleScheme getScheme() {
return new StreamInfoTupleScheme();
}
}
- private static class StreamInfoTupleScheme extends TupleScheme<StreamInfo> {
+ private static class StreamInfoTupleScheme extends org.apache.thrift.scheme.TupleScheme<StreamInfo> {
@Override
public void write(org.apache.thrift.protocol.TProtocol prot, StreamInfo struct) throws org.apache.thrift.TException {
- TTupleProtocol oprot = (TTupleProtocol) prot;
+ org.apache.thrift.protocol.TTupleProtocol oprot = (org.apache.thrift.protocol.TTupleProtocol) prot;
{
oprot.writeI32(struct.output_fields.size());
- for (String _iter20 : struct.output_fields)
+ for (java.lang.String _iter20 : struct.output_fields)
{
oprot.writeString(_iter20);
}
@@ -533,11 +501,11 @@ public class StreamInfo implements org.apache.thrift.TBase<StreamInfo, StreamInf
@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.TTupleProtocol iprot = (org.apache.thrift.protocol.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;
+ struct.output_fields = new java.util.ArrayList<java.lang.String>(_list21.size);
+ java.lang.String _elem22;
for (int _i23 = 0; _i23 < _list21.size; ++_i23)
{
_elem22 = iprot.readString();
@@ -550,5 +518,8 @@ public class StreamInfo implements org.apache.thrift.TBase<StreamInfo, StreamInf
}
}
+ private static <S extends org.apache.thrift.scheme.IScheme> S scheme(org.apache.thrift.protocol.TProtocol proto) {
+ return (org.apache.thrift.scheme.StandardScheme.class.equals(proto.getScheme()) ? STANDARD_SCHEME_FACTORY : TUPLE_SCHEME_FACTORY).getScheme();
+ }
}