You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by ka...@apache.org on 2016/10/11 23:51:12 UTC
[34/59] [abbrv] [partial] storm git commit: Ported successfully.
http://git-wip-us.apache.org/repos/asf/storm/blob/a6171bd6/storm-core/src/jvm/backtype/storm/generated/AccessControl.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/AccessControl.java b/storm-core/src/jvm/backtype/storm/generated/AccessControl.java
deleted file mode 100644
index c1c072a..0000000
--- a/storm-core/src/jvm/backtype/storm/generated/AccessControl.java
+++ /dev/null
@@ -1,627 +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 AccessControl implements org.apache.thrift.TBase<AccessControl, AccessControl._Fields>, java.io.Serializable, Cloneable, Comparable<AccessControl> {
- private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("AccessControl");
-
- private static final org.apache.thrift.protocol.TField TYPE_FIELD_DESC = new org.apache.thrift.protocol.TField("type", org.apache.thrift.protocol.TType.I32, (short)1);
- private static final org.apache.thrift.protocol.TField NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("name", org.apache.thrift.protocol.TType.STRING, (short)2);
- private static final org.apache.thrift.protocol.TField ACCESS_FIELD_DESC = new org.apache.thrift.protocol.TField("access", org.apache.thrift.protocol.TType.I32, (short)3);
-
- private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
- static {
- schemes.put(StandardScheme.class, new AccessControlStandardSchemeFactory());
- schemes.put(TupleScheme.class, new AccessControlTupleSchemeFactory());
- }
-
- private AccessControlType type; // required
- private String name; // optional
- private int access; // 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 {
- /**
- *
- * @see AccessControlType
- */
- TYPE((short)1, "type"),
- NAME((short)2, "name"),
- ACCESS((short)3, "access");
-
- 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: // TYPE
- return TYPE;
- case 2: // NAME
- return NAME;
- case 3: // ACCESS
- return ACCESS;
- 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 __ACCESS_ISSET_ID = 0;
- private byte __isset_bitfield = 0;
- private static final _Fields optionals[] = {_Fields.NAME};
- 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.TYPE, new org.apache.thrift.meta_data.FieldMetaData("type", org.apache.thrift.TFieldRequirementType.REQUIRED,
- new org.apache.thrift.meta_data.EnumMetaData(org.apache.thrift.protocol.TType.ENUM, AccessControlType.class)));
- tmpMap.put(_Fields.NAME, new org.apache.thrift.meta_data.FieldMetaData("name", org.apache.thrift.TFieldRequirementType.OPTIONAL,
- new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
- tmpMap.put(_Fields.ACCESS, new org.apache.thrift.meta_data.FieldMetaData("access", org.apache.thrift.TFieldRequirementType.REQUIRED,
- new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32)));
- metaDataMap = Collections.unmodifiableMap(tmpMap);
- org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(AccessControl.class, metaDataMap);
- }
-
- public AccessControl() {
- }
-
- public AccessControl(
- AccessControlType type,
- int access)
- {
- this();
- this.type = type;
- this.access = access;
- set_access_isSet(true);
- }
-
- /**
- * Performs a deep copy on <i>other</i>.
- */
- public AccessControl(AccessControl other) {
- __isset_bitfield = other.__isset_bitfield;
- if (other.is_set_type()) {
- this.type = other.type;
- }
- if (other.is_set_name()) {
- this.name = other.name;
- }
- this.access = other.access;
- }
-
- public AccessControl deepCopy() {
- return new AccessControl(this);
- }
-
- @Override
- public void clear() {
- this.type = null;
- this.name = null;
- set_access_isSet(false);
- this.access = 0;
- }
-
- /**
- *
- * @see AccessControlType
- */
- public AccessControlType get_type() {
- return this.type;
- }
-
- /**
- *
- * @see AccessControlType
- */
- public void set_type(AccessControlType type) {
- this.type = type;
- }
-
- public void unset_type() {
- this.type = null;
- }
-
- /** Returns true if field type is set (has been assigned a value) and false otherwise */
- public boolean is_set_type() {
- return this.type != null;
- }
-
- public void set_type_isSet(boolean value) {
- if (!value) {
- this.type = null;
- }
- }
-
- public String get_name() {
- return this.name;
- }
-
- public void set_name(String name) {
- this.name = name;
- }
-
- public void unset_name() {
- this.name = null;
- }
-
- /** Returns true if field name is set (has been assigned a value) and false otherwise */
- public boolean is_set_name() {
- return this.name != null;
- }
-
- public void set_name_isSet(boolean value) {
- if (!value) {
- this.name = null;
- }
- }
-
- public int get_access() {
- return this.access;
- }
-
- public void set_access(int access) {
- this.access = access;
- set_access_isSet(true);
- }
-
- public void unset_access() {
- __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __ACCESS_ISSET_ID);
- }
-
- /** Returns true if field access is set (has been assigned a value) and false otherwise */
- public boolean is_set_access() {
- return EncodingUtils.testBit(__isset_bitfield, __ACCESS_ISSET_ID);
- }
-
- public void set_access_isSet(boolean value) {
- __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __ACCESS_ISSET_ID, value);
- }
-
- public void setFieldValue(_Fields field, Object value) {
- switch (field) {
- case TYPE:
- if (value == null) {
- unset_type();
- } else {
- set_type((AccessControlType)value);
- }
- break;
-
- case NAME:
- if (value == null) {
- unset_name();
- } else {
- set_name((String)value);
- }
- break;
-
- case ACCESS:
- if (value == null) {
- unset_access();
- } else {
- set_access((Integer)value);
- }
- break;
-
- }
- }
-
- public Object getFieldValue(_Fields field) {
- switch (field) {
- case TYPE:
- return get_type();
-
- case NAME:
- return get_name();
-
- case ACCESS:
- return get_access();
-
- }
- 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 TYPE:
- return is_set_type();
- case NAME:
- return is_set_name();
- case ACCESS:
- return is_set_access();
- }
- throw new IllegalStateException();
- }
-
- @Override
- public boolean equals(Object that) {
- if (that == null)
- return false;
- if (that instanceof AccessControl)
- return this.equals((AccessControl)that);
- return false;
- }
-
- public boolean equals(AccessControl that) {
- if (that == null)
- return false;
-
- boolean this_present_type = true && this.is_set_type();
- boolean that_present_type = true && that.is_set_type();
- if (this_present_type || that_present_type) {
- if (!(this_present_type && that_present_type))
- return false;
- if (!this.type.equals(that.type))
- return false;
- }
-
- boolean this_present_name = true && this.is_set_name();
- boolean that_present_name = true && that.is_set_name();
- if (this_present_name || that_present_name) {
- if (!(this_present_name && that_present_name))
- return false;
- if (!this.name.equals(that.name))
- return false;
- }
-
- boolean this_present_access = true;
- boolean that_present_access = true;
- if (this_present_access || that_present_access) {
- if (!(this_present_access && that_present_access))
- return false;
- if (this.access != that.access)
- return false;
- }
-
- return true;
- }
-
- @Override
- public int hashCode() {
- List<Object> list = new ArrayList<Object>();
-
- boolean present_type = true && (is_set_type());
- list.add(present_type);
- if (present_type)
- list.add(type.getValue());
-
- boolean present_name = true && (is_set_name());
- list.add(present_name);
- if (present_name)
- list.add(name);
-
- boolean present_access = true;
- list.add(present_access);
- if (present_access)
- list.add(access);
-
- return list.hashCode();
- }
-
- @Override
- public int compareTo(AccessControl other) {
- if (!getClass().equals(other.getClass())) {
- return getClass().getName().compareTo(other.getClass().getName());
- }
-
- int lastComparison = 0;
-
- lastComparison = Boolean.valueOf(is_set_type()).compareTo(other.is_set_type());
- if (lastComparison != 0) {
- return lastComparison;
- }
- if (is_set_type()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.type, other.type);
- if (lastComparison != 0) {
- return lastComparison;
- }
- }
- lastComparison = Boolean.valueOf(is_set_name()).compareTo(other.is_set_name());
- if (lastComparison != 0) {
- return lastComparison;
- }
- if (is_set_name()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.name, other.name);
- if (lastComparison != 0) {
- return lastComparison;
- }
- }
- lastComparison = Boolean.valueOf(is_set_access()).compareTo(other.is_set_access());
- if (lastComparison != 0) {
- return lastComparison;
- }
- if (is_set_access()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.access, other.access);
- 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("AccessControl(");
- boolean first = true;
-
- sb.append("type:");
- if (this.type == null) {
- sb.append("null");
- } else {
- sb.append(this.type);
- }
- first = false;
- if (is_set_name()) {
- if (!first) sb.append(", ");
- sb.append("name:");
- if (this.name == null) {
- sb.append("null");
- } else {
- sb.append(this.name);
- }
- first = false;
- }
- if (!first) sb.append(", ");
- sb.append("access:");
- sb.append(this.access);
- first = false;
- sb.append(")");
- return sb.toString();
- }
-
- public void validate() throws org.apache.thrift.TException {
- // check for required fields
- if (!is_set_type()) {
- throw new org.apache.thrift.protocol.TProtocolException("Required field 'type' is unset! Struct:" + toString());
- }
-
- if (!is_set_access()) {
- throw new org.apache.thrift.protocol.TProtocolException("Required field 'access' 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 AccessControlStandardSchemeFactory implements SchemeFactory {
- public AccessControlStandardScheme getScheme() {
- return new AccessControlStandardScheme();
- }
- }
-
- private static class AccessControlStandardScheme extends StandardScheme<AccessControl> {
-
- public void read(org.apache.thrift.protocol.TProtocol iprot, AccessControl 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: // TYPE
- if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
- struct.type = org.apache.storm.generated.AccessControlType.findByValue(iprot.readI32());
- struct.set_type_isSet(true);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
- }
- break;
- case 2: // NAME
- if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
- struct.name = iprot.readString();
- struct.set_name_isSet(true);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
- }
- break;
- case 3: // ACCESS
- if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
- struct.access = iprot.readI32();
- struct.set_access_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, AccessControl struct) throws org.apache.thrift.TException {
- struct.validate();
-
- oprot.writeStructBegin(STRUCT_DESC);
- if (struct.type != null) {
- oprot.writeFieldBegin(TYPE_FIELD_DESC);
- oprot.writeI32(struct.type.getValue());
- oprot.writeFieldEnd();
- }
- if (struct.name != null) {
- if (struct.is_set_name()) {
- oprot.writeFieldBegin(NAME_FIELD_DESC);
- oprot.writeString(struct.name);
- oprot.writeFieldEnd();
- }
- }
- oprot.writeFieldBegin(ACCESS_FIELD_DESC);
- oprot.writeI32(struct.access);
- oprot.writeFieldEnd();
- oprot.writeFieldStop();
- oprot.writeStructEnd();
- }
-
- }
-
- private static class AccessControlTupleSchemeFactory implements SchemeFactory {
- public AccessControlTupleScheme getScheme() {
- return new AccessControlTupleScheme();
- }
- }
-
- private static class AccessControlTupleScheme extends TupleScheme<AccessControl> {
-
- @Override
- public void write(org.apache.thrift.protocol.TProtocol prot, AccessControl struct) throws org.apache.thrift.TException {
- TTupleProtocol oprot = (TTupleProtocol) prot;
- oprot.writeI32(struct.type.getValue());
- oprot.writeI32(struct.access);
- BitSet optionals = new BitSet();
- if (struct.is_set_name()) {
- optionals.set(0);
- }
- oprot.writeBitSet(optionals, 1);
- if (struct.is_set_name()) {
- oprot.writeString(struct.name);
- }
- }
-
- @Override
- public void read(org.apache.thrift.protocol.TProtocol prot, AccessControl struct) throws org.apache.thrift.TException {
- TTupleProtocol iprot = (TTupleProtocol) prot;
- struct.type = org.apache.storm.generated.AccessControlType.findByValue(iprot.readI32());
- struct.set_type_isSet(true);
- struct.access = iprot.readI32();
- struct.set_access_isSet(true);
- BitSet incoming = iprot.readBitSet(1);
- if (incoming.get(0)) {
- struct.name = iprot.readString();
- struct.set_name_isSet(true);
- }
- }
- }
-
-}
-
http://git-wip-us.apache.org/repos/asf/storm/blob/a6171bd6/storm-core/src/jvm/backtype/storm/generated/AccessControlType.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/AccessControlType.java b/storm-core/src/jvm/backtype/storm/generated/AccessControlType.java
deleted file mode 100644
index cb75b9b..0000000
--- a/storm-core/src/jvm/backtype/storm/generated/AccessControlType.java
+++ /dev/null
@@ -1,62 +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 java.util.Map;
-import java.util.HashMap;
-import org.apache.thrift.TEnum;
-
-public enum AccessControlType implements org.apache.thrift.TEnum {
- OTHER(1),
- USER(2);
-
- private final int value;
-
- private AccessControlType(int value) {
- this.value = value;
- }
-
- /**
- * Get the integer value of this enum value, as defined in the Thrift IDL.
- */
- public int getValue() {
- return value;
- }
-
- /**
- * Find a the enum type by its integer value, as defined in the Thrift IDL.
- * @return null if the value is not found.
- */
- public static AccessControlType findByValue(int value) {
- switch (value) {
- case 1:
- return OTHER;
- case 2:
- return USER;
- default:
- return null;
- }
- }
-}
http://git-wip-us.apache.org/repos/asf/storm/blob/a6171bd6/storm-core/src/jvm/backtype/storm/generated/AlreadyAliveException.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/AlreadyAliveException.java b/storm-core/src/jvm/backtype/storm/generated/AlreadyAliveException.java
deleted file mode 100644
index 4e635fb..0000000
--- a/storm-core/src/jvm/backtype/storm/generated/AlreadyAliveException.java
+++ /dev/null
@@ -1,406 +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 AlreadyAliveException extends TException implements org.apache.thrift.TBase<AlreadyAliveException, AlreadyAliveException._Fields>, java.io.Serializable, Cloneable, Comparable<AlreadyAliveException> {
- private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("AlreadyAliveException");
-
- private static final org.apache.thrift.protocol.TField MSG_FIELD_DESC = new org.apache.thrift.protocol.TField("msg", org.apache.thrift.protocol.TType.STRING, (short)1);
-
- private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
- static {
- schemes.put(StandardScheme.class, new AlreadyAliveExceptionStandardSchemeFactory());
- schemes.put(TupleScheme.class, new AlreadyAliveExceptionTupleSchemeFactory());
- }
-
- private String msg; // 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 {
- MSG((short)1, "msg");
-
- 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: // MSG
- return MSG;
- 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
- 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.MSG, new org.apache.thrift.meta_data.FieldMetaData("msg", org.apache.thrift.TFieldRequirementType.REQUIRED,
- new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
- metaDataMap = Collections.unmodifiableMap(tmpMap);
- org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(AlreadyAliveException.class, metaDataMap);
- }
-
- public AlreadyAliveException() {
- }
-
- public AlreadyAliveException(
- String msg)
- {
- this();
- this.msg = msg;
- }
-
- /**
- * Performs a deep copy on <i>other</i>.
- */
- public AlreadyAliveException(AlreadyAliveException other) {
- if (other.is_set_msg()) {
- this.msg = other.msg;
- }
- }
-
- public AlreadyAliveException deepCopy() {
- return new AlreadyAliveException(this);
- }
-
- @Override
- public void clear() {
- this.msg = null;
- }
-
- public String get_msg() {
- return this.msg;
- }
-
- public void set_msg(String msg) {
- this.msg = msg;
- }
-
- public void unset_msg() {
- this.msg = null;
- }
-
- /** Returns true if field msg is set (has been assigned a value) and false otherwise */
- public boolean is_set_msg() {
- return this.msg != null;
- }
-
- public void set_msg_isSet(boolean value) {
- if (!value) {
- this.msg = null;
- }
- }
-
- public void setFieldValue(_Fields field, Object value) {
- switch (field) {
- case MSG:
- if (value == null) {
- unset_msg();
- } else {
- set_msg((String)value);
- }
- break;
-
- }
- }
-
- public Object getFieldValue(_Fields field) {
- switch (field) {
- case MSG:
- return get_msg();
-
- }
- 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 MSG:
- return is_set_msg();
- }
- throw new IllegalStateException();
- }
-
- @Override
- public boolean equals(Object that) {
- if (that == null)
- return false;
- if (that instanceof AlreadyAliveException)
- return this.equals((AlreadyAliveException)that);
- return false;
- }
-
- public boolean equals(AlreadyAliveException that) {
- if (that == null)
- return false;
-
- boolean this_present_msg = true && this.is_set_msg();
- boolean that_present_msg = true && that.is_set_msg();
- if (this_present_msg || that_present_msg) {
- if (!(this_present_msg && that_present_msg))
- return false;
- if (!this.msg.equals(that.msg))
- return false;
- }
-
- return true;
- }
-
- @Override
- public int hashCode() {
- List<Object> list = new ArrayList<Object>();
-
- boolean present_msg = true && (is_set_msg());
- list.add(present_msg);
- if (present_msg)
- list.add(msg);
-
- return list.hashCode();
- }
-
- @Override
- public int compareTo(AlreadyAliveException other) {
- if (!getClass().equals(other.getClass())) {
- return getClass().getName().compareTo(other.getClass().getName());
- }
-
- int lastComparison = 0;
-
- lastComparison = Boolean.valueOf(is_set_msg()).compareTo(other.is_set_msg());
- if (lastComparison != 0) {
- return lastComparison;
- }
- if (is_set_msg()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.msg, other.msg);
- 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("AlreadyAliveException(");
- boolean first = true;
-
- sb.append("msg:");
- if (this.msg == null) {
- sb.append("null");
- } else {
- sb.append(this.msg);
- }
- first = false;
- sb.append(")");
- return sb.toString();
- }
-
- public void validate() throws org.apache.thrift.TException {
- // check for required fields
- if (!is_set_msg()) {
- throw new org.apache.thrift.protocol.TProtocolException("Required field 'msg' 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 AlreadyAliveExceptionStandardSchemeFactory implements SchemeFactory {
- public AlreadyAliveExceptionStandardScheme getScheme() {
- return new AlreadyAliveExceptionStandardScheme();
- }
- }
-
- private static class AlreadyAliveExceptionStandardScheme extends StandardScheme<AlreadyAliveException> {
-
- public void read(org.apache.thrift.protocol.TProtocol iprot, AlreadyAliveException 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: // MSG
- if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
- struct.msg = iprot.readString();
- struct.set_msg_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, AlreadyAliveException struct) throws org.apache.thrift.TException {
- struct.validate();
-
- oprot.writeStructBegin(STRUCT_DESC);
- if (struct.msg != null) {
- oprot.writeFieldBegin(MSG_FIELD_DESC);
- oprot.writeString(struct.msg);
- oprot.writeFieldEnd();
- }
- oprot.writeFieldStop();
- oprot.writeStructEnd();
- }
-
- }
-
- private static class AlreadyAliveExceptionTupleSchemeFactory implements SchemeFactory {
- public AlreadyAliveExceptionTupleScheme getScheme() {
- return new AlreadyAliveExceptionTupleScheme();
- }
- }
-
- private static class AlreadyAliveExceptionTupleScheme extends TupleScheme<AlreadyAliveException> {
-
- @Override
- public void write(org.apache.thrift.protocol.TProtocol prot, AlreadyAliveException struct) throws org.apache.thrift.TException {
- TTupleProtocol oprot = (TTupleProtocol) prot;
- oprot.writeString(struct.msg);
- }
-
- @Override
- public void read(org.apache.thrift.protocol.TProtocol prot, AlreadyAliveException struct) throws org.apache.thrift.TException {
- TTupleProtocol iprot = (TTupleProtocol) prot;
- struct.msg = iprot.readString();
- struct.set_msg_isSet(true);
- }
- }
-
-}
-
http://git-wip-us.apache.org/repos/asf/storm/blob/a6171bd6/storm-core/src/jvm/backtype/storm/generated/Assignment.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/Assignment.java b/storm-core/src/jvm/backtype/storm/generated/Assignment.java
deleted file mode 100644
index 4c973d5..0000000
--- a/storm-core/src/jvm/backtype/storm/generated/Assignment.java
+++ /dev/null
@@ -1,1159 +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 Assignment implements org.apache.thrift.TBase<Assignment, Assignment._Fields>, java.io.Serializable, Cloneable, Comparable<Assignment> {
- private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("Assignment");
-
- private static final org.apache.thrift.protocol.TField MASTER_CODE_DIR_FIELD_DESC = new org.apache.thrift.protocol.TField("master_code_dir", org.apache.thrift.protocol.TType.STRING, (short)1);
- private static final org.apache.thrift.protocol.TField NODE_HOST_FIELD_DESC = new org.apache.thrift.protocol.TField("node_host", org.apache.thrift.protocol.TType.MAP, (short)2);
- private static final org.apache.thrift.protocol.TField EXECUTOR_NODE_PORT_FIELD_DESC = new org.apache.thrift.protocol.TField("executor_node_port", org.apache.thrift.protocol.TType.MAP, (short)3);
- private static final org.apache.thrift.protocol.TField EXECUTOR_START_TIME_SECS_FIELD_DESC = new org.apache.thrift.protocol.TField("executor_start_time_secs", org.apache.thrift.protocol.TType.MAP, (short)4);
- private static final org.apache.thrift.protocol.TField WORKER_RESOURCES_FIELD_DESC = new org.apache.thrift.protocol.TField("worker_resources", org.apache.thrift.protocol.TType.MAP, (short)5);
-
- private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
- static {
- schemes.put(StandardScheme.class, new AssignmentStandardSchemeFactory());
- schemes.put(TupleScheme.class, new AssignmentTupleSchemeFactory());
- }
-
- private String master_code_dir; // required
- private Map<String,String> node_host; // optional
- private Map<List<Long>,NodeInfo> executor_node_port; // optional
- private Map<List<Long>,Long> executor_start_time_secs; // optional
- private Map<NodeInfo,WorkerResources> worker_resources; // 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 {
- MASTER_CODE_DIR((short)1, "master_code_dir"),
- NODE_HOST((short)2, "node_host"),
- EXECUTOR_NODE_PORT((short)3, "executor_node_port"),
- EXECUTOR_START_TIME_SECS((short)4, "executor_start_time_secs"),
- WORKER_RESOURCES((short)5, "worker_resources");
-
- 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: // MASTER_CODE_DIR
- return MASTER_CODE_DIR;
- case 2: // NODE_HOST
- return NODE_HOST;
- case 3: // EXECUTOR_NODE_PORT
- return EXECUTOR_NODE_PORT;
- case 4: // EXECUTOR_START_TIME_SECS
- return EXECUTOR_START_TIME_SECS;
- case 5: // WORKER_RESOURCES
- return WORKER_RESOURCES;
- 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.NODE_HOST,_Fields.EXECUTOR_NODE_PORT,_Fields.EXECUTOR_START_TIME_SECS,_Fields.WORKER_RESOURCES};
- 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.MASTER_CODE_DIR, new org.apache.thrift.meta_data.FieldMetaData("master_code_dir", org.apache.thrift.TFieldRequirementType.REQUIRED,
- new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
- tmpMap.put(_Fields.NODE_HOST, new org.apache.thrift.meta_data.FieldMetaData("node_host", org.apache.thrift.TFieldRequirementType.OPTIONAL,
- 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.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))));
- tmpMap.put(_Fields.EXECUTOR_NODE_PORT, new org.apache.thrift.meta_data.FieldMetaData("executor_node_port", org.apache.thrift.TFieldRequirementType.OPTIONAL,
- new org.apache.thrift.meta_data.MapMetaData(org.apache.thrift.protocol.TType.MAP,
- 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.I64)),
- new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, NodeInfo.class))));
- tmpMap.put(_Fields.EXECUTOR_START_TIME_SECS, new org.apache.thrift.meta_data.FieldMetaData("executor_start_time_secs", org.apache.thrift.TFieldRequirementType.OPTIONAL,
- new org.apache.thrift.meta_data.MapMetaData(org.apache.thrift.protocol.TType.MAP,
- 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.I64)),
- new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64))));
- tmpMap.put(_Fields.WORKER_RESOURCES, new org.apache.thrift.meta_data.FieldMetaData("worker_resources", org.apache.thrift.TFieldRequirementType.OPTIONAL,
- new org.apache.thrift.meta_data.MapMetaData(org.apache.thrift.protocol.TType.MAP,
- new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, NodeInfo.class),
- new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, WorkerResources.class))));
- metaDataMap = Collections.unmodifiableMap(tmpMap);
- org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(Assignment.class, metaDataMap);
- }
-
- public Assignment() {
- this.node_host = new HashMap<String,String>();
-
- this.executor_node_port = new HashMap<List<Long>,NodeInfo>();
-
- this.executor_start_time_secs = new HashMap<List<Long>,Long>();
-
- this.worker_resources = new HashMap<NodeInfo,WorkerResources>();
-
- }
-
- public Assignment(
- String master_code_dir)
- {
- this();
- this.master_code_dir = master_code_dir;
- }
-
- /**
- * Performs a deep copy on <i>other</i>.
- */
- public Assignment(Assignment other) {
- if (other.is_set_master_code_dir()) {
- this.master_code_dir = other.master_code_dir;
- }
- if (other.is_set_node_host()) {
- Map<String,String> __this__node_host = new HashMap<String,String>(other.node_host);
- this.node_host = __this__node_host;
- }
- if (other.is_set_executor_node_port()) {
- Map<List<Long>,NodeInfo> __this__executor_node_port = new HashMap<List<Long>,NodeInfo>(other.executor_node_port.size());
- for (Map.Entry<List<Long>, NodeInfo> other_element : other.executor_node_port.entrySet()) {
-
- List<Long> other_element_key = other_element.getKey();
- NodeInfo other_element_value = other_element.getValue();
-
- List<Long> __this__executor_node_port_copy_key = new ArrayList<Long>(other_element_key);
-
- NodeInfo __this__executor_node_port_copy_value = new NodeInfo(other_element_value);
-
- __this__executor_node_port.put(__this__executor_node_port_copy_key, __this__executor_node_port_copy_value);
- }
- this.executor_node_port = __this__executor_node_port;
- }
- if (other.is_set_executor_start_time_secs()) {
- Map<List<Long>,Long> __this__executor_start_time_secs = new HashMap<List<Long>,Long>(other.executor_start_time_secs.size());
- for (Map.Entry<List<Long>, Long> other_element : other.executor_start_time_secs.entrySet()) {
-
- List<Long> other_element_key = other_element.getKey();
- Long other_element_value = other_element.getValue();
-
- List<Long> __this__executor_start_time_secs_copy_key = new ArrayList<Long>(other_element_key);
-
- Long __this__executor_start_time_secs_copy_value = other_element_value;
-
- __this__executor_start_time_secs.put(__this__executor_start_time_secs_copy_key, __this__executor_start_time_secs_copy_value);
- }
- this.executor_start_time_secs = __this__executor_start_time_secs;
- }
- if (other.is_set_worker_resources()) {
- Map<NodeInfo,WorkerResources> __this__worker_resources = new HashMap<NodeInfo,WorkerResources>(other.worker_resources.size());
- for (Map.Entry<NodeInfo, WorkerResources> other_element : other.worker_resources.entrySet()) {
-
- NodeInfo other_element_key = other_element.getKey();
- WorkerResources other_element_value = other_element.getValue();
-
- NodeInfo __this__worker_resources_copy_key = new NodeInfo(other_element_key);
-
- WorkerResources __this__worker_resources_copy_value = new WorkerResources(other_element_value);
-
- __this__worker_resources.put(__this__worker_resources_copy_key, __this__worker_resources_copy_value);
- }
- this.worker_resources = __this__worker_resources;
- }
- }
-
- public Assignment deepCopy() {
- return new Assignment(this);
- }
-
- @Override
- public void clear() {
- this.master_code_dir = null;
- this.node_host = new HashMap<String,String>();
-
- this.executor_node_port = new HashMap<List<Long>,NodeInfo>();
-
- this.executor_start_time_secs = new HashMap<List<Long>,Long>();
-
- this.worker_resources = new HashMap<NodeInfo,WorkerResources>();
-
- }
-
- public String get_master_code_dir() {
- return this.master_code_dir;
- }
-
- public void set_master_code_dir(String master_code_dir) {
- this.master_code_dir = master_code_dir;
- }
-
- public void unset_master_code_dir() {
- this.master_code_dir = null;
- }
-
- /** Returns true if field master_code_dir is set (has been assigned a value) and false otherwise */
- public boolean is_set_master_code_dir() {
- return this.master_code_dir != null;
- }
-
- public void set_master_code_dir_isSet(boolean value) {
- if (!value) {
- this.master_code_dir = null;
- }
- }
-
- public int get_node_host_size() {
- return (this.node_host == null) ? 0 : this.node_host.size();
- }
-
- public void put_to_node_host(String key, String val) {
- if (this.node_host == null) {
- this.node_host = new HashMap<String,String>();
- }
- this.node_host.put(key, val);
- }
-
- public Map<String,String> get_node_host() {
- return this.node_host;
- }
-
- public void set_node_host(Map<String,String> node_host) {
- this.node_host = node_host;
- }
-
- public void unset_node_host() {
- this.node_host = null;
- }
-
- /** Returns true if field node_host is set (has been assigned a value) and false otherwise */
- public boolean is_set_node_host() {
- return this.node_host != null;
- }
-
- public void set_node_host_isSet(boolean value) {
- if (!value) {
- this.node_host = null;
- }
- }
-
- public int get_executor_node_port_size() {
- return (this.executor_node_port == null) ? 0 : this.executor_node_port.size();
- }
-
- public void put_to_executor_node_port(List<Long> key, NodeInfo val) {
- if (this.executor_node_port == null) {
- this.executor_node_port = new HashMap<List<Long>,NodeInfo>();
- }
- this.executor_node_port.put(key, val);
- }
-
- public Map<List<Long>,NodeInfo> get_executor_node_port() {
- return this.executor_node_port;
- }
-
- public void set_executor_node_port(Map<List<Long>,NodeInfo> executor_node_port) {
- this.executor_node_port = executor_node_port;
- }
-
- public void unset_executor_node_port() {
- this.executor_node_port = null;
- }
-
- /** Returns true if field executor_node_port is set (has been assigned a value) and false otherwise */
- public boolean is_set_executor_node_port() {
- return this.executor_node_port != null;
- }
-
- public void set_executor_node_port_isSet(boolean value) {
- if (!value) {
- this.executor_node_port = null;
- }
- }
-
- public int get_executor_start_time_secs_size() {
- return (this.executor_start_time_secs == null) ? 0 : this.executor_start_time_secs.size();
- }
-
- public void put_to_executor_start_time_secs(List<Long> key, long val) {
- if (this.executor_start_time_secs == null) {
- this.executor_start_time_secs = new HashMap<List<Long>,Long>();
- }
- this.executor_start_time_secs.put(key, val);
- }
-
- public Map<List<Long>,Long> get_executor_start_time_secs() {
- return this.executor_start_time_secs;
- }
-
- public void set_executor_start_time_secs(Map<List<Long>,Long> executor_start_time_secs) {
- this.executor_start_time_secs = executor_start_time_secs;
- }
-
- public void unset_executor_start_time_secs() {
- this.executor_start_time_secs = null;
- }
-
- /** Returns true if field executor_start_time_secs is set (has been assigned a value) and false otherwise */
- public boolean is_set_executor_start_time_secs() {
- return this.executor_start_time_secs != null;
- }
-
- public void set_executor_start_time_secs_isSet(boolean value) {
- if (!value) {
- this.executor_start_time_secs = null;
- }
- }
-
- public int get_worker_resources_size() {
- return (this.worker_resources == null) ? 0 : this.worker_resources.size();
- }
-
- public void put_to_worker_resources(NodeInfo key, WorkerResources val) {
- if (this.worker_resources == null) {
- this.worker_resources = new HashMap<NodeInfo,WorkerResources>();
- }
- this.worker_resources.put(key, val);
- }
-
- public Map<NodeInfo,WorkerResources> get_worker_resources() {
- return this.worker_resources;
- }
-
- public void set_worker_resources(Map<NodeInfo,WorkerResources> worker_resources) {
- this.worker_resources = worker_resources;
- }
-
- public void unset_worker_resources() {
- this.worker_resources = null;
- }
-
- /** Returns true if field worker_resources is set (has been assigned a value) and false otherwise */
- public boolean is_set_worker_resources() {
- return this.worker_resources != null;
- }
-
- public void set_worker_resources_isSet(boolean value) {
- if (!value) {
- this.worker_resources = null;
- }
- }
-
- public void setFieldValue(_Fields field, Object value) {
- switch (field) {
- case MASTER_CODE_DIR:
- if (value == null) {
- unset_master_code_dir();
- } else {
- set_master_code_dir((String)value);
- }
- break;
-
- case NODE_HOST:
- if (value == null) {
- unset_node_host();
- } else {
- set_node_host((Map<String,String>)value);
- }
- break;
-
- case EXECUTOR_NODE_PORT:
- if (value == null) {
- unset_executor_node_port();
- } else {
- set_executor_node_port((Map<List<Long>,NodeInfo>)value);
- }
- break;
-
- case EXECUTOR_START_TIME_SECS:
- if (value == null) {
- unset_executor_start_time_secs();
- } else {
- set_executor_start_time_secs((Map<List<Long>,Long>)value);
- }
- break;
-
- case WORKER_RESOURCES:
- if (value == null) {
- unset_worker_resources();
- } else {
- set_worker_resources((Map<NodeInfo,WorkerResources>)value);
- }
- break;
-
- }
- }
-
- public Object getFieldValue(_Fields field) {
- switch (field) {
- case MASTER_CODE_DIR:
- return get_master_code_dir();
-
- case NODE_HOST:
- return get_node_host();
-
- case EXECUTOR_NODE_PORT:
- return get_executor_node_port();
-
- case EXECUTOR_START_TIME_SECS:
- return get_executor_start_time_secs();
-
- case WORKER_RESOURCES:
- return get_worker_resources();
-
- }
- 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 MASTER_CODE_DIR:
- return is_set_master_code_dir();
- case NODE_HOST:
- return is_set_node_host();
- case EXECUTOR_NODE_PORT:
- return is_set_executor_node_port();
- case EXECUTOR_START_TIME_SECS:
- return is_set_executor_start_time_secs();
- case WORKER_RESOURCES:
- return is_set_worker_resources();
- }
- throw new IllegalStateException();
- }
-
- @Override
- public boolean equals(Object that) {
- if (that == null)
- return false;
- if (that instanceof Assignment)
- return this.equals((Assignment)that);
- return false;
- }
-
- public boolean equals(Assignment that) {
- if (that == null)
- return false;
-
- boolean this_present_master_code_dir = true && this.is_set_master_code_dir();
- boolean that_present_master_code_dir = true && that.is_set_master_code_dir();
- if (this_present_master_code_dir || that_present_master_code_dir) {
- if (!(this_present_master_code_dir && that_present_master_code_dir))
- return false;
- if (!this.master_code_dir.equals(that.master_code_dir))
- return false;
- }
-
- boolean this_present_node_host = true && this.is_set_node_host();
- boolean that_present_node_host = true && that.is_set_node_host();
- if (this_present_node_host || that_present_node_host) {
- if (!(this_present_node_host && that_present_node_host))
- return false;
- if (!this.node_host.equals(that.node_host))
- return false;
- }
-
- boolean this_present_executor_node_port = true && this.is_set_executor_node_port();
- boolean that_present_executor_node_port = true && that.is_set_executor_node_port();
- if (this_present_executor_node_port || that_present_executor_node_port) {
- if (!(this_present_executor_node_port && that_present_executor_node_port))
- return false;
- if (!this.executor_node_port.equals(that.executor_node_port))
- return false;
- }
-
- boolean this_present_executor_start_time_secs = true && this.is_set_executor_start_time_secs();
- boolean that_present_executor_start_time_secs = true && that.is_set_executor_start_time_secs();
- if (this_present_executor_start_time_secs || that_present_executor_start_time_secs) {
- if (!(this_present_executor_start_time_secs && that_present_executor_start_time_secs))
- return false;
- if (!this.executor_start_time_secs.equals(that.executor_start_time_secs))
- return false;
- }
-
- boolean this_present_worker_resources = true && this.is_set_worker_resources();
- boolean that_present_worker_resources = true && that.is_set_worker_resources();
- if (this_present_worker_resources || that_present_worker_resources) {
- if (!(this_present_worker_resources && that_present_worker_resources))
- return false;
- if (!this.worker_resources.equals(that.worker_resources))
- return false;
- }
-
- return true;
- }
-
- @Override
- public int hashCode() {
- List<Object> list = new ArrayList<Object>();
-
- boolean present_master_code_dir = true && (is_set_master_code_dir());
- list.add(present_master_code_dir);
- if (present_master_code_dir)
- list.add(master_code_dir);
-
- boolean present_node_host = true && (is_set_node_host());
- list.add(present_node_host);
- if (present_node_host)
- list.add(node_host);
-
- boolean present_executor_node_port = true && (is_set_executor_node_port());
- list.add(present_executor_node_port);
- if (present_executor_node_port)
- list.add(executor_node_port);
-
- boolean present_executor_start_time_secs = true && (is_set_executor_start_time_secs());
- list.add(present_executor_start_time_secs);
- if (present_executor_start_time_secs)
- list.add(executor_start_time_secs);
-
- boolean present_worker_resources = true && (is_set_worker_resources());
- list.add(present_worker_resources);
- if (present_worker_resources)
- list.add(worker_resources);
-
- return list.hashCode();
- }
-
- @Override
- public int compareTo(Assignment other) {
- if (!getClass().equals(other.getClass())) {
- return getClass().getName().compareTo(other.getClass().getName());
- }
-
- int lastComparison = 0;
-
- lastComparison = Boolean.valueOf(is_set_master_code_dir()).compareTo(other.is_set_master_code_dir());
- if (lastComparison != 0) {
- return lastComparison;
- }
- if (is_set_master_code_dir()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.master_code_dir, other.master_code_dir);
- if (lastComparison != 0) {
- return lastComparison;
- }
- }
- lastComparison = Boolean.valueOf(is_set_node_host()).compareTo(other.is_set_node_host());
- if (lastComparison != 0) {
- return lastComparison;
- }
- if (is_set_node_host()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.node_host, other.node_host);
- if (lastComparison != 0) {
- return lastComparison;
- }
- }
- lastComparison = Boolean.valueOf(is_set_executor_node_port()).compareTo(other.is_set_executor_node_port());
- if (lastComparison != 0) {
- return lastComparison;
- }
- if (is_set_executor_node_port()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.executor_node_port, other.executor_node_port);
- if (lastComparison != 0) {
- return lastComparison;
- }
- }
- lastComparison = Boolean.valueOf(is_set_executor_start_time_secs()).compareTo(other.is_set_executor_start_time_secs());
- if (lastComparison != 0) {
- return lastComparison;
- }
- if (is_set_executor_start_time_secs()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.executor_start_time_secs, other.executor_start_time_secs);
- if (lastComparison != 0) {
- return lastComparison;
- }
- }
- lastComparison = Boolean.valueOf(is_set_worker_resources()).compareTo(other.is_set_worker_resources());
- if (lastComparison != 0) {
- return lastComparison;
- }
- if (is_set_worker_resources()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.worker_resources, other.worker_resources);
- 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("Assignment(");
- boolean first = true;
-
- sb.append("master_code_dir:");
- if (this.master_code_dir == null) {
- sb.append("null");
- } else {
- sb.append(this.master_code_dir);
- }
- first = false;
- if (is_set_node_host()) {
- if (!first) sb.append(", ");
- sb.append("node_host:");
- if (this.node_host == null) {
- sb.append("null");
- } else {
- sb.append(this.node_host);
- }
- first = false;
- }
- if (is_set_executor_node_port()) {
- if (!first) sb.append(", ");
- sb.append("executor_node_port:");
- if (this.executor_node_port == null) {
- sb.append("null");
- } else {
- sb.append(this.executor_node_port);
- }
- first = false;
- }
- if (is_set_executor_start_time_secs()) {
- if (!first) sb.append(", ");
- sb.append("executor_start_time_secs:");
- if (this.executor_start_time_secs == null) {
- sb.append("null");
- } else {
- sb.append(this.executor_start_time_secs);
- }
- first = false;
- }
- if (is_set_worker_resources()) {
- if (!first) sb.append(", ");
- sb.append("worker_resources:");
- if (this.worker_resources == null) {
- sb.append("null");
- } else {
- sb.append(this.worker_resources);
- }
- first = false;
- }
- sb.append(")");
- return sb.toString();
- }
-
- public void validate() throws org.apache.thrift.TException {
- // check for required fields
- if (!is_set_master_code_dir()) {
- throw new org.apache.thrift.protocol.TProtocolException("Required field 'master_code_dir' 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 AssignmentStandardSchemeFactory implements SchemeFactory {
- public AssignmentStandardScheme getScheme() {
- return new AssignmentStandardScheme();
- }
- }
-
- private static class AssignmentStandardScheme extends StandardScheme<Assignment> {
-
- public void read(org.apache.thrift.protocol.TProtocol iprot, Assignment 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: // MASTER_CODE_DIR
- if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
- struct.master_code_dir = iprot.readString();
- struct.set_master_code_dir_isSet(true);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
- }
- break;
- case 2: // NODE_HOST
- if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
- {
- org.apache.thrift.protocol.TMap _map618 = iprot.readMapBegin();
- struct.node_host = new HashMap<String,String>(2*_map618.size);
- String _key619;
- String _val620;
- for (int _i621 = 0; _i621 < _map618.size; ++_i621)
- {
- _key619 = iprot.readString();
- _val620 = iprot.readString();
- struct.node_host.put(_key619, _val620);
- }
- iprot.readMapEnd();
- }
- struct.set_node_host_isSet(true);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
- }
- break;
- case 3: // EXECUTOR_NODE_PORT
- if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
- {
- org.apache.thrift.protocol.TMap _map622 = iprot.readMapBegin();
- struct.executor_node_port = new HashMap<List<Long>,NodeInfo>(2*_map622.size);
- List<Long> _key623;
- NodeInfo _val624;
- for (int _i625 = 0; _i625 < _map622.size; ++_i625)
- {
- {
- org.apache.thrift.protocol.TList _list626 = iprot.readListBegin();
- _key623 = new ArrayList<Long>(_list626.size);
- long _elem627;
- for (int _i628 = 0; _i628 < _list626.size; ++_i628)
- {
- _elem627 = iprot.readI64();
- _key623.add(_elem627);
- }
- iprot.readListEnd();
- }
- _val624 = new NodeInfo();
- _val624.read(iprot);
- struct.executor_node_port.put(_key623, _val624);
- }
- iprot.readMapEnd();
- }
- struct.set_executor_node_port_isSet(true);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
- }
- break;
- case 4: // EXECUTOR_START_TIME_SECS
- if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
- {
- org.apache.thrift.protocol.TMap _map629 = iprot.readMapBegin();
- struct.executor_start_time_secs = new HashMap<List<Long>,Long>(2*_map629.size);
- List<Long> _key630;
- long _val631;
- for (int _i632 = 0; _i632 < _map629.size; ++_i632)
- {
- {
- org.apache.thrift.protocol.TList _list633 = iprot.readListBegin();
- _key630 = new ArrayList<Long>(_list633.size);
- long _elem634;
- for (int _i635 = 0; _i635 < _list633.size; ++_i635)
- {
- _elem634 = iprot.readI64();
- _key630.add(_elem634);
- }
- iprot.readListEnd();
- }
- _val631 = iprot.readI64();
- struct.executor_start_time_secs.put(_key630, _val631);
- }
- iprot.readMapEnd();
- }
- struct.set_executor_start_time_secs_isSet(true);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
- }
- break;
- case 5: // WORKER_RESOURCES
- if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
- {
- org.apache.thrift.protocol.TMap _map636 = iprot.readMapBegin();
- struct.worker_resources = new HashMap<NodeInfo,WorkerResources>(2*_map636.size);
- NodeInfo _key637;
- WorkerResources _val638;
- for (int _i639 = 0; _i639 < _map636.size; ++_i639)
- {
- _key637 = new NodeInfo();
- _key637.read(iprot);
- _val638 = new WorkerResources();
- _val638.read(iprot);
- struct.worker_resources.put(_key637, _val638);
- }
- iprot.readMapEnd();
- }
- struct.set_worker_resources_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, Assignment struct) throws org.apache.thrift.TException {
- struct.validate();
-
- oprot.writeStructBegin(STRUCT_DESC);
- if (struct.master_code_dir != null) {
- oprot.writeFieldBegin(MASTER_CODE_DIR_FIELD_DESC);
- oprot.writeString(struct.master_code_dir);
- oprot.writeFieldEnd();
- }
- if (struct.node_host != null) {
- if (struct.is_set_node_host()) {
- oprot.writeFieldBegin(NODE_HOST_FIELD_DESC);
- {
- oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, struct.node_host.size()));
- for (Map.Entry<String, String> _iter640 : struct.node_host.entrySet())
- {
- oprot.writeString(_iter640.getKey());
- oprot.writeString(_iter640.getValue());
- }
- oprot.writeMapEnd();
- }
- oprot.writeFieldEnd();
- }
- }
- if (struct.executor_node_port != null) {
- if (struct.is_set_executor_node_port()) {
- oprot.writeFieldBegin(EXECUTOR_NODE_PORT_FIELD_DESC);
- {
- oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.LIST, org.apache.thrift.protocol.TType.STRUCT, struct.executor_node_port.size()));
- for (Map.Entry<List<Long>, NodeInfo> _iter641 : struct.executor_node_port.entrySet())
- {
- {
- oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, _iter641.getKey().size()));
- for (long _iter642 : _iter641.getKey())
- {
- oprot.writeI64(_iter642);
- }
- oprot.writeListEnd();
- }
- _iter641.getValue().write(oprot);
- }
- oprot.writeMapEnd();
- }
- oprot.writeFieldEnd();
- }
- }
- if (struct.executor_start_time_secs != null) {
- if (struct.is_set_executor_start_time_secs()) {
- oprot.writeFieldBegin(EXECUTOR_START_TIME_SECS_FIELD_DESC);
- {
- oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.LIST, org.apache.thrift.protocol.TType.I64, struct.executor_start_time_secs.size()));
- for (Map.Entry<List<Long>, Long> _iter643 : struct.executor_start_time_secs.entrySet())
- {
- {
- oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, _iter643.getKey().size()));
- for (long _iter644 : _iter643.getKey())
- {
- oprot.writeI64(_iter644);
- }
- oprot.writeListEnd();
- }
- oprot.writeI64(_iter643.getValue());
- }
- oprot.writeMapEnd();
- }
- oprot.writeFieldEnd();
- }
- }
- if (struct.worker_resources != null) {
- if (struct.is_set_worker_resources()) {
- oprot.writeFieldBegin(WORKER_RESOURCES_FIELD_DESC);
- {
- oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRUCT, org.apache.thrift.protocol.TType.STRUCT, struct.worker_resources.size()));
- for (Map.Entry<NodeInfo, WorkerResources> _iter645 : struct.worker_resources.entrySet())
- {
- _iter645.getKey().write(oprot);
- _iter645.getValue().write(oprot);
- }
- oprot.writeMapEnd();
- }
- oprot.writeFieldEnd();
- }
- }
- oprot.writeFieldStop();
- oprot.writeStructEnd();
- }
-
- }
-
- private static class AssignmentTupleSchemeFactory implements SchemeFactory {
- public AssignmentTupleScheme getScheme() {
- return new AssignmentTupleScheme();
- }
- }
-
- private static class AssignmentTupleScheme extends TupleScheme<Assignment> {
-
- @Override
- public void write(org.apache.thrift.protocol.TProtocol prot, Assignment struct) throws org.apache.thrift.TException {
- TTupleProtocol oprot = (TTupleProtocol) prot;
- oprot.writeString(struct.master_code_dir);
- BitSet optionals = new BitSet();
- if (struct.is_set_node_host()) {
- optionals.set(0);
- }
- if (struct.is_set_executor_node_port()) {
- optionals.set(1);
- }
- if (struct.is_set_executor_start_time_secs()) {
- optionals.set(2);
- }
- if (struct.is_set_worker_resources()) {
- optionals.set(3);
- }
- oprot.writeBitSet(optionals, 4);
- if (struct.is_set_node_host()) {
- {
- oprot.writeI32(struct.node_host.size());
- for (Map.Entry<String, String> _iter646 : struct.node_host.entrySet())
- {
- oprot.writeString(_iter646.getKey());
- oprot.writeString(_iter646.getValue());
- }
- }
- }
- if (struct.is_set_executor_node_port()) {
- {
- oprot.writeI32(struct.executor_node_port.size());
- for (Map.Entry<List<Long>, NodeInfo> _iter647 : struct.executor_node_port.entrySet())
- {
- {
- oprot.writeI32(_iter647.getKey().size());
- for (long _iter648 : _iter647.getKey())
- {
- oprot.writeI64(_iter648);
- }
- }
- _iter647.getValue().write(oprot);
- }
- }
- }
- if (struct.is_set_executor_start_time_secs()) {
- {
- oprot.writeI32(struct.executor_start_time_secs.size());
- for (Map.Entry<List<Long>, Long> _iter649 : struct.executor_start_time_secs.entrySet())
- {
- {
- oprot.writeI32(_iter649.getKey().size());
- for (long _iter650 : _iter649.getKey())
- {
- oprot.writeI64(_iter650);
- }
- }
- oprot.writeI64(_iter649.getValue());
- }
- }
- }
- if (struct.is_set_worker_resources()) {
- {
- oprot.writeI32(struct.worker_resources.size());
- for (Map.Entry<NodeInfo, WorkerResources> _iter651 : struct.worker_resources.entrySet())
- {
- _iter651.getKey().write(oprot);
- _iter651.getValue().write(oprot);
- }
- }
- }
- }
-
- @Override
- public void read(org.apache.thrift.protocol.TProtocol prot, Assignment struct) throws org.apache.thrift.TException {
- TTupleProtocol iprot = (TTupleProtocol) prot;
- struct.master_code_dir = iprot.readString();
- struct.set_master_code_dir_isSet(true);
- BitSet incoming = iprot.readBitSet(4);
- if (incoming.get(0)) {
- {
- org.apache.thrift.protocol.TMap _map652 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.node_host = new HashMap<String,String>(2*_map652.size);
- String _key653;
- String _val654;
- for (int _i655 = 0; _i655 < _map652.size; ++_i655)
- {
- _key653 = iprot.readString();
- _val654 = iprot.readString();
- struct.node_host.put(_key653, _val654);
- }
- }
- struct.set_node_host_isSet(true);
- }
- if (incoming.get(1)) {
- {
- org.apache.thrift.protocol.TMap _map656 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.LIST, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.executor_node_port = new HashMap<List<Long>,NodeInfo>(2*_map656.size);
- List<Long> _key657;
- NodeInfo _val658;
- for (int _i659 = 0; _i659 < _map656.size; ++_i659)
- {
- {
- org.apache.thrift.protocol.TList _list660 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
- _key657 = new ArrayList<Long>(_list660.size);
- long _elem661;
- for (int _i662 = 0; _i662 < _list660.size; ++_i662)
- {
- _elem661 = iprot.readI64();
- _key657.add(_elem661);
- }
- }
- _val658 = new NodeInfo();
- _val658.read(iprot);
- struct.executor_node_port.put(_key657, _val658);
- }
- }
- struct.set_executor_node_port_isSet(true);
- }
- if (incoming.get(2)) {
- {
- org.apache.thrift.protocol.TMap _map663 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.LIST, org.apache.thrift.protocol.TType.I64, iprot.readI32());
- struct.executor_start_time_secs = new HashMap<List<Long>,Long>(2*_map663.size);
- List<Long> _key664;
- long _val665;
- for (int _i666 = 0; _i666 < _map663.size; ++_i666)
- {
- {
- org.apache.thrift.protocol.TList _list667 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
- _key664 = new ArrayList<Long>(_list667.size);
- long _elem668;
- for (int _i669 = 0; _i669 < _list667.size; ++_i669)
- {
- _elem668 = iprot.readI64();
- _key664.add(_elem668);
- }
- }
- _val665 = iprot.readI64();
- struct.executor_start_time_secs.put(_key664, _val665);
- }
- }
- struct.set_executor_start_time_secs_isSet(true);
- }
- if (incoming.get(3)) {
- {
- org.apache.thrift.protocol.TMap _map670 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRUCT, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.worker_resources = new HashMap<NodeInfo,WorkerResources>(2*_map670.size);
- NodeInfo _key671;
- WorkerResources _val672;
- for (int _i673 = 0; _i673 < _map670.size; ++_i673)
- {
- _key671 = new NodeInfo();
- _key671.read(iprot);
- _val672 = new WorkerResources();
- _val672.read(iprot);
- struct.worker_resources.put(_key671, _val672);
- }
- }
- struct.set_worker_resources_isSet(true);
- }
- }
- }
-
-}
-