http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/c46eb880/blur-thrift/src/main/java/org/apache/blur/thrift/generated/Blur.java ---------------------------------------------------------------------- diff --git a/blur-thrift/src/main/java/org/apache/blur/thrift/generated/Blur.java b/blur-thrift/src/main/java/org/apache/blur/thrift/generated/Blur.java index 962129d..eef3142 100644 --- a/blur-thrift/src/main/java/org/apache/blur/thrift/generated/Blur.java +++ b/blur-thrift/src/main/java/org/apache/blur/thrift/generated/Blur.java @@ -469,6 +469,15 @@ public class Blur { public Map<String,String> configuration() throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException; /** + * Fetches the Blur configuration. + * @return Map of property name to value. + * + * @param thriftServerPlusPort + * @param configName + */ + public String configurationPerServer(String thriftServerPlusPort, String configName) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException; + + /** * Fetches the Blur metrics by name. If the metrics parameter is null all the Metrics are returned. * @return Map of metric name to Metric. * @@ -633,6 +642,8 @@ public class Blur { public void configuration(org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.configuration_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException; + public void configurationPerServer(String thriftServerPlusPort, String configName, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.configurationPerServer_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException; + public void metrics(Set<String> metrics, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.metrics_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException; public void startTrace(String traceId, String requestId, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.startTrace_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException; @@ -1839,6 +1850,33 @@ public class Blur { throw new org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException(org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException.MISSING_RESULT, "configuration failed: unknown result"); } + public String configurationPerServer(String thriftServerPlusPort, String configName) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + send_configurationPerServer(thriftServerPlusPort, configName); + return recv_configurationPerServer(); + } + + public void send_configurationPerServer(String thriftServerPlusPort, String configName) throws org.apache.blur.thirdparty.thrift_0_9_0.TException + { + configurationPerServer_args args = new configurationPerServer_args(); + args.setThriftServerPlusPort(thriftServerPlusPort); + args.setConfigName(configName); + sendBase("configurationPerServer", args); + } + + public String recv_configurationPerServer() throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + configurationPerServer_result result = new configurationPerServer_result(); + receiveBase(result, "configurationPerServer"); + if (result.isSetSuccess()) { + return result.success; + } + if (result.ex != null) { + throw result.ex; + } + throw new org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException(org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException.MISSING_RESULT, "configurationPerServer failed: unknown result"); + } + public Map<String,Metric> metrics(Set<String> metrics) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { send_metrics(metrics); @@ -3624,6 +3662,41 @@ public class Blur { } } + public void configurationPerServer(String thriftServerPlusPort, String configName, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<configurationPerServer_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + checkReady(); + configurationPerServer_call method_call = new configurationPerServer_call(thriftServerPlusPort, configName, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class configurationPerServer_call extends org.apache.blur.thirdparty.thrift_0_9_0.async.TAsyncMethodCall { + private String thriftServerPlusPort; + private String configName; + public configurationPerServer_call(String thriftServerPlusPort, String configName, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<configurationPerServer_call> resultHandler, org.apache.blur.thirdparty.thrift_0_9_0.async.TAsyncClient client, org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolFactory protocolFactory, org.apache.blur.thirdparty.thrift_0_9_0.transport.TNonblockingTransport transport) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + super(client, protocolFactory, transport, resultHandler, false); + this.thriftServerPlusPort = thriftServerPlusPort; + this.configName = configName; + } + + public void write_args(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + prot.writeMessageBegin(new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMessage("configurationPerServer", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMessageType.CALL, 0)); + configurationPerServer_args args = new configurationPerServer_args(); + args.setThriftServerPlusPort(thriftServerPlusPort); + args.setConfigName(configName); + args.write(prot); + prot.writeMessageEnd(); + } + + public String getResult() throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { + if (getState() != org.apache.blur.thirdparty.thrift_0_9_0.async.TAsyncMethodCall.State.RESPONSE_READ) { + throw new IllegalStateException("Method call not finished!"); + } + org.apache.blur.thirdparty.thrift_0_9_0.transport.TMemoryInputTransport memoryTransport = new org.apache.blur.thirdparty.thrift_0_9_0.transport.TMemoryInputTransport(getFrameBuffer().array()); + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport); + return (new Client(prot)).recv_configurationPerServer(); + } + } + public void metrics(Set<String> metrics, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<metrics_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { checkReady(); metrics_call method_call = new metrics_call(metrics, resultHandler, this, ___protocolFactory, ___transport); @@ -3971,6 +4044,7 @@ public class Blur { processMap.put("shardServerLayoutState", new shardServerLayoutState()); processMap.put("isInSafeMode", new isInSafeMode()); processMap.put("configuration", new configuration()); + processMap.put("configurationPerServer", new configurationPerServer()); processMap.put("metrics", new metrics()); processMap.put("startTrace", new startTrace()); processMap.put("traceList", new traceList()); @@ -5108,6 +5182,30 @@ public class Blur { } } + public static class configurationPerServer<I extends Iface> extends org.apache.blur.thirdparty.thrift_0_9_0.ProcessFunction<I, configurationPerServer_args> { + public configurationPerServer() { + super("configurationPerServer"); + } + + public configurationPerServer_args getEmptyArgsInstance() { + return new configurationPerServer_args(); + } + + protected boolean isOneway() { + return false; + } + + public configurationPerServer_result getResult(I iface, configurationPerServer_args args) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + configurationPerServer_result result = new configurationPerServer_result(); + try { + result.success = iface.configurationPerServer(args.thriftServerPlusPort, args.configName); + } catch (BlurException ex) { + result.ex = ex; + } + return result; + } + } + public static class metrics<I extends Iface> extends org.apache.blur.thirdparty.thrift_0_9_0.ProcessFunction<I, metrics_args> { public metrics() { super("metrics"); @@ -38470,82 +38568,802 @@ public class Blur { } // isset id assignments - private static final int __SUCCESS_ISSET_ID = 0; - private byte __isset_bitfield = 0; + private static final int __SUCCESS_ISSET_ID = 0; + private byte __isset_bitfield = 0; + public static final Map<_Fields, org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData> metaDataMap; + static { + Map<_Fields, org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData>(_Fields.class); + tmpMap.put(_Fields.SUCCESS, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("success", org.apache.blur.thirdparty.thrift_0_9_0.TFieldRequirementType.DEFAULT, + new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldValueMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I64))); + tmpMap.put(_Fields.EX, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("ex", org.apache.blur.thirdparty.thrift_0_9_0.TFieldRequirementType.DEFAULT, + new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldValueMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT))); + metaDataMap = Collections.unmodifiableMap(tmpMap); + org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData.addStructMetaDataMap(recordFrequency_result.class, metaDataMap); + } + + public recordFrequency_result() { + } + + public recordFrequency_result( + long success, + BlurException ex) + { + this(); + this.success = success; + setSuccessIsSet(true); + this.ex = ex; + } + + /** + * Performs a deep copy on <i>other</i>. + */ + public recordFrequency_result(recordFrequency_result other) { + __isset_bitfield = other.__isset_bitfield; + this.success = other.success; + if (other.isSetEx()) { + this.ex = new BlurException(other.ex); + } + } + + public recordFrequency_result deepCopy() { + return new recordFrequency_result(this); + } + + @Override + public void clear() { + setSuccessIsSet(false); + this.success = 0; + this.ex = null; + } + + public long getSuccess() { + return this.success; + } + + public recordFrequency_result setSuccess(long success) { + this.success = success; + setSuccessIsSet(true); + return this; + } + + public void unsetSuccess() { + __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __SUCCESS_ISSET_ID); + } + + /** Returns true if field success is set (has been assigned a value) and false otherwise */ + public boolean isSetSuccess() { + return EncodingUtils.testBit(__isset_bitfield, __SUCCESS_ISSET_ID); + } + + public void setSuccessIsSet(boolean value) { + __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __SUCCESS_ISSET_ID, value); + } + + public BlurException getEx() { + return this.ex; + } + + public recordFrequency_result setEx(BlurException ex) { + this.ex = ex; + return this; + } + + public void unsetEx() { + this.ex = null; + } + + /** Returns true if field ex is set (has been assigned a value) and false otherwise */ + public boolean isSetEx() { + return this.ex != null; + } + + public void setExIsSet(boolean value) { + if (!value) { + this.ex = null; + } + } + + public void setFieldValue(_Fields field, Object value) { + switch (field) { + case SUCCESS: + if (value == null) { + unsetSuccess(); + } else { + setSuccess((Long)value); + } + break; + + case EX: + if (value == null) { + unsetEx(); + } else { + setEx((BlurException)value); + } + break; + + } + } + + public Object getFieldValue(_Fields field) { + switch (field) { + case SUCCESS: + return Long.valueOf(getSuccess()); + + case EX: + return getEx(); + + } + 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 SUCCESS: + return isSetSuccess(); + case EX: + return isSetEx(); + } + throw new IllegalStateException(); + } + + @Override + public boolean equals(Object that) { + if (that == null) + return false; + if (that instanceof recordFrequency_result) + return this.equals((recordFrequency_result)that); + return false; + } + + public boolean equals(recordFrequency_result that) { + if (that == null) + return false; + + boolean this_present_success = true; + boolean that_present_success = true; + if (this_present_success || that_present_success) { + if (!(this_present_success && that_present_success)) + return false; + if (this.success != that.success) + return false; + } + + boolean this_present_ex = true && this.isSetEx(); + boolean that_present_ex = true && that.isSetEx(); + if (this_present_ex || that_present_ex) { + if (!(this_present_ex && that_present_ex)) + return false; + if (!this.ex.equals(that.ex)) + return false; + } + + return true; + } + + @Override + public int hashCode() { + return 0; + } + + public int compareTo(recordFrequency_result other) { + if (!getClass().equals(other.getClass())) { + return getClass().getName().compareTo(other.getClass().getName()); + } + + int lastComparison = 0; + recordFrequency_result typedOther = (recordFrequency_result)other; + + lastComparison = Boolean.valueOf(isSetSuccess()).compareTo(typedOther.isSetSuccess()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetSuccess()) { + lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.success, typedOther.success); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetEx()).compareTo(typedOther.isSetEx()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetEx()) { + lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.ex, typedOther.ex); + if (lastComparison != 0) { + return lastComparison; + } + } + return 0; + } + + public _Fields fieldForId(int fieldId) { + return _Fields.findByThriftId(fieldId); + } + + public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol iprot) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + schemes.get(iprot.getScheme()).getScheme().read(iprot, this); + } + + public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol oprot) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + schemes.get(oprot.getScheme()).getScheme().write(oprot, this); + } + + @Override + public String toString() { + StringBuilder sb = new StringBuilder("recordFrequency_result("); + boolean first = true; + + sb.append("success:"); + sb.append(this.success); + first = false; + if (!first) sb.append(", "); + sb.append("ex:"); + if (this.ex == null) { + sb.append("null"); + } else { + sb.append(this.ex); + } + first = false; + sb.append(")"); + return sb.toString(); + } + + public void validate() throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + // check for required fields + // check for sub-struct validity + } + + private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException { + try { + write(new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TCompactProtocol(new org.apache.blur.thirdparty.thrift_0_9_0.transport.TIOStreamTransport(out))); + } catch (org.apache.blur.thirdparty.thrift_0_9_0.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.blur.thirdparty.thrift_0_9_0.protocol.TCompactProtocol(new org.apache.blur.thirdparty.thrift_0_9_0.transport.TIOStreamTransport(in))); + } catch (org.apache.blur.thirdparty.thrift_0_9_0.TException te) { + throw new java.io.IOException(te); + } + } + + private static class recordFrequency_resultStandardSchemeFactory implements SchemeFactory { + public recordFrequency_resultStandardScheme getScheme() { + return new recordFrequency_resultStandardScheme(); + } + } + + private static class recordFrequency_resultStandardScheme extends StandardScheme<recordFrequency_result> { + + public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol iprot, recordFrequency_result struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField schemeField; + iprot.readStructBegin(); + while (true) + { + schemeField = iprot.readFieldBegin(); + if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STOP) { + break; + } + switch (schemeField.id) { + case 0: // SUCCESS + if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I64) { + struct.success = iprot.readI64(); + struct.setSuccessIsSet(true); + } else { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 1: // EX + if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT) { + struct.ex = new BlurException(); + struct.ex.read(iprot); + struct.setExIsSet(true); + } else { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + default: + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + iprot.readFieldEnd(); + } + iprot.readStructEnd(); + + // check for required fields of primitive type, which can't be checked in the validate method + struct.validate(); + } + + public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol oprot, recordFrequency_result struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + struct.validate(); + + oprot.writeStructBegin(STRUCT_DESC); + if (struct.isSetSuccess()) { + oprot.writeFieldBegin(SUCCESS_FIELD_DESC); + oprot.writeI64(struct.success); + oprot.writeFieldEnd(); + } + if (struct.ex != null) { + oprot.writeFieldBegin(EX_FIELD_DESC); + struct.ex.write(oprot); + oprot.writeFieldEnd(); + } + oprot.writeFieldStop(); + oprot.writeStructEnd(); + } + + } + + private static class recordFrequency_resultTupleSchemeFactory implements SchemeFactory { + public recordFrequency_resultTupleScheme getScheme() { + return new recordFrequency_resultTupleScheme(); + } + } + + private static class recordFrequency_resultTupleScheme extends TupleScheme<recordFrequency_result> { + + @Override + public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, recordFrequency_result struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + TTupleProtocol oprot = (TTupleProtocol) prot; + BitSet optionals = new BitSet(); + if (struct.isSetSuccess()) { + optionals.set(0); + } + if (struct.isSetEx()) { + optionals.set(1); + } + oprot.writeBitSet(optionals, 2); + if (struct.isSetSuccess()) { + oprot.writeI64(struct.success); + } + if (struct.isSetEx()) { + struct.ex.write(oprot); + } + } + + @Override + public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, recordFrequency_result struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + TTupleProtocol iprot = (TTupleProtocol) prot; + BitSet incoming = iprot.readBitSet(2); + if (incoming.get(0)) { + struct.success = iprot.readI64(); + struct.setSuccessIsSet(true); + } + if (incoming.get(1)) { + struct.ex = new BlurException(); + struct.ex.read(iprot); + struct.setExIsSet(true); + } + } + } + + } + + public static class shardClusterList_args implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<shardClusterList_args, shardClusterList_args._Fields>, java.io.Serializable, Cloneable { + private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TStruct STRUCT_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TStruct("shardClusterList_args"); + + + private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); + static { + schemes.put(StandardScheme.class, new shardClusterList_argsStandardSchemeFactory()); + schemes.put(TupleScheme.class, new shardClusterList_argsTupleSchemeFactory()); + } + + + /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ + public enum _Fields implements org.apache.blur.thirdparty.thrift_0_9_0.TFieldIdEnum { +; + + 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) { + default: + return null; + } + } + + /** + * Find the _Fields constant that matches fieldId, throwing an exception + * if it is not found. + */ + public static _Fields findByThriftIdOrThrow(int fieldId) { + _Fields fields = findByThriftId(fieldId); + if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!"); + return fields; + } + + /** + * Find the _Fields constant that matches name, or null if its not found. + */ + public static _Fields findByName(String name) { + return byName.get(name); + } + + private final short _thriftId; + private final String _fieldName; + + _Fields(short thriftId, String fieldName) { + _thriftId = thriftId; + _fieldName = fieldName; + } + + public short getThriftFieldId() { + return _thriftId; + } + + public String getFieldName() { + return _fieldName; + } + } + public static final Map<_Fields, org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData> metaDataMap; + static { + Map<_Fields, org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData>(_Fields.class); + metaDataMap = Collections.unmodifiableMap(tmpMap); + org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData.addStructMetaDataMap(shardClusterList_args.class, metaDataMap); + } + + public shardClusterList_args() { + } + + /** + * Performs a deep copy on <i>other</i>. + */ + public shardClusterList_args(shardClusterList_args other) { + } + + public shardClusterList_args deepCopy() { + return new shardClusterList_args(this); + } + + @Override + public void clear() { + } + + public void setFieldValue(_Fields field, Object value) { + switch (field) { + } + } + + public Object getFieldValue(_Fields field) { + switch (field) { + } + 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) { + } + throw new IllegalStateException(); + } + + @Override + public boolean equals(Object that) { + if (that == null) + return false; + if (that instanceof shardClusterList_args) + return this.equals((shardClusterList_args)that); + return false; + } + + public boolean equals(shardClusterList_args that) { + if (that == null) + return false; + + return true; + } + + @Override + public int hashCode() { + return 0; + } + + public int compareTo(shardClusterList_args other) { + if (!getClass().equals(other.getClass())) { + return getClass().getName().compareTo(other.getClass().getName()); + } + + int lastComparison = 0; + shardClusterList_args typedOther = (shardClusterList_args)other; + + return 0; + } + + public _Fields fieldForId(int fieldId) { + return _Fields.findByThriftId(fieldId); + } + + public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol iprot) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + schemes.get(iprot.getScheme()).getScheme().read(iprot, this); + } + + public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol oprot) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + schemes.get(oprot.getScheme()).getScheme().write(oprot, this); + } + + @Override + public String toString() { + StringBuilder sb = new StringBuilder("shardClusterList_args("); + boolean first = true; + + sb.append(")"); + return sb.toString(); + } + + public void validate() throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + // check for required fields + // check for sub-struct validity + } + + private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException { + try { + write(new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TCompactProtocol(new org.apache.blur.thirdparty.thrift_0_9_0.transport.TIOStreamTransport(out))); + } catch (org.apache.blur.thirdparty.thrift_0_9_0.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.blur.thirdparty.thrift_0_9_0.protocol.TCompactProtocol(new org.apache.blur.thirdparty.thrift_0_9_0.transport.TIOStreamTransport(in))); + } catch (org.apache.blur.thirdparty.thrift_0_9_0.TException te) { + throw new java.io.IOException(te); + } + } + + private static class shardClusterList_argsStandardSchemeFactory implements SchemeFactory { + public shardClusterList_argsStandardScheme getScheme() { + return new shardClusterList_argsStandardScheme(); + } + } + + private static class shardClusterList_argsStandardScheme extends StandardScheme<shardClusterList_args> { + + public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol iprot, shardClusterList_args struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField schemeField; + iprot.readStructBegin(); + while (true) + { + schemeField = iprot.readFieldBegin(); + if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STOP) { + break; + } + switch (schemeField.id) { + default: + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + iprot.readFieldEnd(); + } + iprot.readStructEnd(); + + // check for required fields of primitive type, which can't be checked in the validate method + struct.validate(); + } + + public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol oprot, shardClusterList_args struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + struct.validate(); + + oprot.writeStructBegin(STRUCT_DESC); + oprot.writeFieldStop(); + oprot.writeStructEnd(); + } + + } + + private static class shardClusterList_argsTupleSchemeFactory implements SchemeFactory { + public shardClusterList_argsTupleScheme getScheme() { + return new shardClusterList_argsTupleScheme(); + } + } + + private static class shardClusterList_argsTupleScheme extends TupleScheme<shardClusterList_args> { + + @Override + public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, shardClusterList_args struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + TTupleProtocol oprot = (TTupleProtocol) prot; + } + + @Override + public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, shardClusterList_args struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + TTupleProtocol iprot = (TTupleProtocol) prot; + } + } + + } + + public static class shardClusterList_result implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<shardClusterList_result, shardClusterList_result._Fields>, java.io.Serializable, Cloneable { + private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TStruct STRUCT_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TStruct("shardClusterList_result"); + + private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField SUCCESS_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("success", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.LIST, (short)0); + private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField EX_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("ex", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT, (short)1); + + private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); + static { + schemes.put(StandardScheme.class, new shardClusterList_resultStandardSchemeFactory()); + schemes.put(TupleScheme.class, new shardClusterList_resultTupleSchemeFactory()); + } + + public List<String> success; // required + public BlurException ex; // required + + /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ + public enum _Fields implements org.apache.blur.thirdparty.thrift_0_9_0.TFieldIdEnum { + SUCCESS((short)0, "success"), + EX((short)1, "ex"); + + 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 0: // SUCCESS + return SUCCESS; + case 1: // EX + return EX; + 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.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData> metaDataMap; static { Map<_Fields, org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData>(_Fields.class); tmpMap.put(_Fields.SUCCESS, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("success", org.apache.blur.thirdparty.thrift_0_9_0.TFieldRequirementType.DEFAULT, - new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldValueMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I64))); + new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.ListMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.LIST, + new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldValueMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING)))); tmpMap.put(_Fields.EX, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("ex", org.apache.blur.thirdparty.thrift_0_9_0.TFieldRequirementType.DEFAULT, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldValueMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT))); metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData.addStructMetaDataMap(recordFrequency_result.class, metaDataMap); + org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData.addStructMetaDataMap(shardClusterList_result.class, metaDataMap); } - public recordFrequency_result() { + public shardClusterList_result() { } - public recordFrequency_result( - long success, + public shardClusterList_result( + List<String> success, BlurException ex) { this(); this.success = success; - setSuccessIsSet(true); this.ex = ex; } /** * Performs a deep copy on <i>other</i>. */ - public recordFrequency_result(recordFrequency_result other) { - __isset_bitfield = other.__isset_bitfield; - this.success = other.success; + public shardClusterList_result(shardClusterList_result other) { + if (other.isSetSuccess()) { + List<String> __this__success = new ArrayList<String>(); + for (String other_element : other.success) { + __this__success.add(other_element); + } + this.success = __this__success; + } if (other.isSetEx()) { this.ex = new BlurException(other.ex); } } - public recordFrequency_result deepCopy() { - return new recordFrequency_result(this); + public shardClusterList_result deepCopy() { + return new shardClusterList_result(this); } @Override public void clear() { - setSuccessIsSet(false); - this.success = 0; + this.success = null; this.ex = null; } - public long getSuccess() { + public int getSuccessSize() { + return (this.success == null) ? 0 : this.success.size(); + } + + public java.util.Iterator<String> getSuccessIterator() { + return (this.success == null) ? null : this.success.iterator(); + } + + public void addToSuccess(String elem) { + if (this.success == null) { + this.success = new ArrayList<String>(); + } + this.success.add(elem); + } + + public List<String> getSuccess() { return this.success; } - public recordFrequency_result setSuccess(long success) { + public shardClusterList_result setSuccess(List<String> success) { this.success = success; - setSuccessIsSet(true); return this; } public void unsetSuccess() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __SUCCESS_ISSET_ID); + this.success = null; } /** Returns true if field success is set (has been assigned a value) and false otherwise */ public boolean isSetSuccess() { - return EncodingUtils.testBit(__isset_bitfield, __SUCCESS_ISSET_ID); + return this.success != null; } public void setSuccessIsSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __SUCCESS_ISSET_ID, value); + if (!value) { + this.success = null; + } } public BlurException getEx() { return this.ex; } - public recordFrequency_result setEx(BlurException ex) { + public shardClusterList_result setEx(BlurException ex) { this.ex = ex; return this; } @@ -38571,7 +39389,7 @@ public class Blur { if (value == null) { unsetSuccess(); } else { - setSuccess((Long)value); + setSuccess((List<String>)value); } break; @@ -38589,7 +39407,7 @@ public class Blur { public Object getFieldValue(_Fields field) { switch (field) { case SUCCESS: - return Long.valueOf(getSuccess()); + return getSuccess(); case EX: return getEx(); @@ -38617,21 +39435,21 @@ public class Blur { public boolean equals(Object that) { if (that == null) return false; - if (that instanceof recordFrequency_result) - return this.equals((recordFrequency_result)that); + if (that instanceof shardClusterList_result) + return this.equals((shardClusterList_result)that); return false; } - public boolean equals(recordFrequency_result that) { + public boolean equals(shardClusterList_result that) { if (that == null) return false; - boolean this_present_success = true; - boolean that_present_success = true; + boolean this_present_success = true && this.isSetSuccess(); + boolean that_present_success = true && that.isSetSuccess(); if (this_present_success || that_present_success) { if (!(this_present_success && that_present_success)) return false; - if (this.success != that.success) + if (!this.success.equals(that.success)) return false; } @@ -38652,13 +39470,13 @@ public class Blur { return 0; } - public int compareTo(recordFrequency_result other) { + public int compareTo(shardClusterList_result other) { if (!getClass().equals(other.getClass())) { return getClass().getName().compareTo(other.getClass().getName()); } int lastComparison = 0; - recordFrequency_result typedOther = (recordFrequency_result)other; + shardClusterList_result typedOther = (shardClusterList_result)other; lastComparison = Boolean.valueOf(isSetSuccess()).compareTo(typedOther.isSetSuccess()); if (lastComparison != 0) { @@ -38697,11 +39515,15 @@ public class Blur { @Override public String toString() { - StringBuilder sb = new StringBuilder("recordFrequency_result("); + StringBuilder sb = new StringBuilder("shardClusterList_result("); boolean first = true; sb.append("success:"); - sb.append(this.success); + if (this.success == null) { + sb.append("null"); + } else { + sb.append(this.success); + } first = false; if (!first) sb.append(", "); sb.append("ex:"); @@ -38730,23 +39552,21 @@ public class Blur { 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.blur.thirdparty.thrift_0_9_0.protocol.TCompactProtocol(new org.apache.blur.thirdparty.thrift_0_9_0.transport.TIOStreamTransport(in))); } catch (org.apache.blur.thirdparty.thrift_0_9_0.TException te) { throw new java.io.IOException(te); } } - private static class recordFrequency_resultStandardSchemeFactory implements SchemeFactory { - public recordFrequency_resultStandardScheme getScheme() { - return new recordFrequency_resultStandardScheme(); + private static class shardClusterList_resultStandardSchemeFactory implements SchemeFactory { + public shardClusterList_resultStandardScheme getScheme() { + return new shardClusterList_resultStandardScheme(); } } - private static class recordFrequency_resultStandardScheme extends StandardScheme<recordFrequency_result> { + private static class shardClusterList_resultStandardScheme extends StandardScheme<shardClusterList_result> { - public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol iprot, recordFrequency_result struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol iprot, shardClusterList_result struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField schemeField; iprot.readStructBegin(); while (true) @@ -38757,8 +39577,18 @@ public class Blur { } switch (schemeField.id) { case 0: // SUCCESS - if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I64) { - struct.success = iprot.readI64(); + if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.LIST) { + { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list396 = iprot.readListBegin(); + struct.success = new ArrayList<String>(_list396.size); + for (int _i397 = 0; _i397 < _list396.size; ++_i397) + { + String _elem398; // required + _elem398 = iprot.readString(); + struct.success.add(_elem398); + } + iprot.readListEnd(); + } struct.setSuccessIsSet(true); } else { org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, schemeField.type); @@ -38784,13 +39614,20 @@ public class Blur { struct.validate(); } - public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol oprot, recordFrequency_result struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol oprot, shardClusterList_result struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { struct.validate(); oprot.writeStructBegin(STRUCT_DESC); - if (struct.isSetSuccess()) { + if (struct.success != null) { oprot.writeFieldBegin(SUCCESS_FIELD_DESC); - oprot.writeI64(struct.success); + { + oprot.writeListBegin(new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, struct.success.size())); + for (String _iter399 : struct.success) + { + oprot.writeString(_iter399); + } + oprot.writeListEnd(); + } oprot.writeFieldEnd(); } if (struct.ex != null) { @@ -38804,16 +39641,16 @@ public class Blur { } - private static class recordFrequency_resultTupleSchemeFactory implements SchemeFactory { - public recordFrequency_resultTupleScheme getScheme() { - return new recordFrequency_resultTupleScheme(); + private static class shardClusterList_resultTupleSchemeFactory implements SchemeFactory { + public shardClusterList_resultTupleScheme getScheme() { + return new shardClusterList_resultTupleScheme(); } } - private static class recordFrequency_resultTupleScheme extends TupleScheme<recordFrequency_result> { + private static class shardClusterList_resultTupleScheme extends TupleScheme<shardClusterList_result> { @Override - public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, recordFrequency_result struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, shardClusterList_result struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { TTupleProtocol oprot = (TTupleProtocol) prot; BitSet optionals = new BitSet(); if (struct.isSetSuccess()) { @@ -38824,7 +39661,13 @@ public class Blur { } oprot.writeBitSet(optionals, 2); if (struct.isSetSuccess()) { - oprot.writeI64(struct.success); + { + oprot.writeI32(struct.success.size()); + for (String _iter400 : struct.success) + { + oprot.writeString(_iter400); + } + } } if (struct.isSetEx()) { struct.ex.write(oprot); @@ -38832,11 +39675,20 @@ public class Blur { } @Override - public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, recordFrequency_result struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, shardClusterList_result struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { TTupleProtocol iprot = (TTupleProtocol) prot; BitSet incoming = iprot.readBitSet(2); if (incoming.get(0)) { - struct.success = iprot.readI64(); + { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list401 = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, iprot.readI32()); + struct.success = new ArrayList<String>(_list401.size); + for (int _i402 = 0; _i402 < _list401.size; ++_i402) + { + String _elem403; // required + _elem403 = iprot.readString(); + struct.success.add(_elem403); + } + } struct.setSuccessIsSet(true); } if (incoming.get(1)) { @@ -38849,20 +39701,28 @@ public class Blur { } - public static class shardClusterList_args implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<shardClusterList_args, shardClusterList_args._Fields>, java.io.Serializable, Cloneable { - private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TStruct STRUCT_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TStruct("shardClusterList_args"); + public static class shardServerList_args implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<shardServerList_args, shardServerList_args._Fields>, java.io.Serializable, Cloneable { + private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TStruct STRUCT_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TStruct("shardServerList_args"); + private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField CLUSTER_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("cluster", org.apache.blur.thirdparty.thrift_0_9_0.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 shardClusterList_argsStandardSchemeFactory()); - schemes.put(TupleScheme.class, new shardClusterList_argsTupleSchemeFactory()); + schemes.put(StandardScheme.class, new shardServerList_argsStandardSchemeFactory()); + schemes.put(TupleScheme.class, new shardServerList_argsTupleSchemeFactory()); } + /** + * the cluster name. + */ + public String cluster; // required /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ public enum _Fields implements org.apache.blur.thirdparty.thrift_0_9_0.TFieldIdEnum { -; + /** + * the cluster name. + */ + CLUSTER((short)1, "cluster"); private static final Map<String, _Fields> byName = new HashMap<String, _Fields>(); @@ -38877,6 +39737,8 @@ public class Blur { */ public static _Fields findByThriftId(int fieldId) { switch(fieldId) { + case 1: // CLUSTER + return CLUSTER; default: return null; } @@ -38915,37 +39777,93 @@ public class Blur { return _fieldName; } } + + // isset id assignments public static final Map<_Fields, org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData> metaDataMap; static { Map<_Fields, org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData>(_Fields.class); + tmpMap.put(_Fields.CLUSTER, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("cluster", org.apache.blur.thirdparty.thrift_0_9_0.TFieldRequirementType.DEFAULT, + new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldValueMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING))); metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData.addStructMetaDataMap(shardClusterList_args.class, metaDataMap); + org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData.addStructMetaDataMap(shardServerList_args.class, metaDataMap); } - public shardClusterList_args() { + public shardServerList_args() { + } + + public shardServerList_args( + String cluster) + { + this(); + this.cluster = cluster; } /** * Performs a deep copy on <i>other</i>. */ - public shardClusterList_args(shardClusterList_args other) { + public shardServerList_args(shardServerList_args other) { + if (other.isSetCluster()) { + this.cluster = other.cluster; + } } - public shardClusterList_args deepCopy() { - return new shardClusterList_args(this); + public shardServerList_args deepCopy() { + return new shardServerList_args(this); } @Override public void clear() { + this.cluster = null; + } + + /** + * the cluster name. + */ + public String getCluster() { + return this.cluster; + } + + /** + * the cluster name. + */ + public shardServerList_args setCluster(String cluster) { + this.cluster = cluster; + return this; + } + + public void unsetCluster() { + this.cluster = null; + } + + /** Returns true if field cluster is set (has been assigned a value) and false otherwise */ + public boolean isSetCluster() { + return this.cluster != null; + } + + public void setClusterIsSet(boolean value) { + if (!value) { + this.cluster = null; + } } public void setFieldValue(_Fields field, Object value) { switch (field) { + case CLUSTER: + if (value == null) { + unsetCluster(); + } else { + setCluster((String)value); + } + break; + } } public Object getFieldValue(_Fields field) { switch (field) { + case CLUSTER: + return getCluster(); + } throw new IllegalStateException(); } @@ -38957,6 +39875,8 @@ public class Blur { } switch (field) { + case CLUSTER: + return isSetCluster(); } throw new IllegalStateException(); } @@ -38965,15 +39885,24 @@ public class Blur { public boolean equals(Object that) { if (that == null) return false; - if (that instanceof shardClusterList_args) - return this.equals((shardClusterList_args)that); + if (that instanceof shardServerList_args) + return this.equals((shardServerList_args)that); return false; } - public boolean equals(shardClusterList_args that) { + public boolean equals(shardServerList_args that) { if (that == null) return false; + boolean this_present_cluster = true && this.isSetCluster(); + boolean that_present_cluster = true && that.isSetCluster(); + if (this_present_cluster || that_present_cluster) { + if (!(this_present_cluster && that_present_cluster)) + return false; + if (!this.cluster.equals(that.cluster)) + return false; + } + return true; } @@ -38982,14 +39911,24 @@ public class Blur { return 0; } - public int compareTo(shardClusterList_args other) { + public int compareTo(shardServerList_args other) { if (!getClass().equals(other.getClass())) { return getClass().getName().compareTo(other.getClass().getName()); } int lastComparison = 0; - shardClusterList_args typedOther = (shardClusterList_args)other; + shardServerList_args typedOther = (shardServerList_args)other; + lastComparison = Boolean.valueOf(isSetCluster()).compareTo(typedOther.isSetCluster()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetCluster()) { + lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.cluster, typedOther.cluster); + if (lastComparison != 0) { + return lastComparison; + } + } return 0; } @@ -39007,9 +39946,16 @@ public class Blur { @Override public String toString() { - StringBuilder sb = new StringBuilder("shardClusterList_args("); + StringBuilder sb = new StringBuilder("shardServerList_args("); boolean first = true; + sb.append("cluster:"); + if (this.cluster == null) { + sb.append("null"); + } else { + sb.append(this.cluster); + } + first = false; sb.append(")"); return sb.toString(); } @@ -39035,15 +39981,15 @@ public class Blur { } } - private static class shardClusterList_argsStandardSchemeFactory implements SchemeFactory { - public shardClusterList_argsStandardScheme getScheme() { - return new shardClusterList_argsStandardScheme(); + private static class shardServerList_argsStandardSchemeFactory implements SchemeFactory { + public shardServerList_argsStandardScheme getScheme() { + return new shardServerList_argsStandardScheme(); } } - private static class shardClusterList_argsStandardScheme extends StandardScheme<shardClusterList_args> { + private static class shardServerList_argsStandardScheme extends StandardScheme<shardServerList_args> { - public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol iprot, shardClusterList_args struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol iprot, shardServerList_args struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField schemeField; iprot.readStructBegin(); while (true) @@ -39053,6 +39999,14 @@ public class Blur { break; } switch (schemeField.id) { + case 1: // CLUSTER + if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING) { + struct.cluster = iprot.readString(); + struct.setClusterIsSet(true); + } else { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; default: org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, schemeField.type); } @@ -39064,47 +40018,65 @@ public class Blur { struct.validate(); } - public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol oprot, shardClusterList_args struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol oprot, shardServerList_args struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { struct.validate(); oprot.writeStructBegin(STRUCT_DESC); + if (struct.cluster != null) { + oprot.writeFieldBegin(CLUSTER_FIELD_DESC); + oprot.writeString(struct.cluster); + oprot.writeFieldEnd(); + } oprot.writeFieldStop(); oprot.writeStructEnd(); } } - private static class shardClusterList_argsTupleSchemeFactory implements SchemeFactory { - public shardClusterList_argsTupleScheme getScheme() { - return new shardClusterList_argsTupleScheme(); + private static class shardServerList_argsTupleSchemeFactory implements SchemeFactory { + public shardServerList_argsTupleScheme getScheme() { + return new shardServerList_argsTupleScheme(); } } - private static class shardClusterList_argsTupleScheme extends TupleScheme<shardClusterList_args> { + private static class shardServerList_argsTupleScheme extends TupleScheme<shardServerList_args> { @Override - public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, shardClusterList_args struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, shardServerList_args struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { TTupleProtocol oprot = (TTupleProtocol) prot; + BitSet optionals = new BitSet(); + if (struct.isSetCluster()) { + optionals.set(0); + } + oprot.writeBitSet(optionals, 1); + if (struct.isSetCluster()) { + oprot.writeString(struct.cluster); + } } @Override - public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, shardClusterList_args struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, shardServerList_args struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { TTupleProtocol iprot = (TTupleProtocol) prot; + BitSet incoming = iprot.readBitSet(1); + if (incoming.get(0)) { + struct.cluster = iprot.readString(); + struct.setClusterIsSet(true); + } } } } - public static class shardClusterList_result implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<shardClusterList_result, shardClusterList_result._Fields>, java.io.Serializable, Cloneable { - private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TStruct STRUCT_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TStruct("shardClusterList_result"); + public static class shardServerList_result implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<shardServerList_result, shardServerList_result._Fields>, java.io.Serializable, Cloneable { + private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TStruct STRUCT_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TStruct("shardServerList_result"); private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField SUCCESS_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("success", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.LIST, (short)0); private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField EX_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("ex", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT, (short)1); private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); static { - schemes.put(StandardScheme.class, new shardClusterList_resultStandardSchemeFactory()); - schemes.put(TupleScheme.class, new shardClusterList_resultTupleSchemeFactory()); + schemes.put(StandardScheme.class, new shardServerList_resultStandardSchemeFactory()); + schemes.put(TupleScheme.class, new shardServerList_resultTupleSchemeFactory()); } public List<String> success; // required @@ -39181,13 +40153,13 @@ public class Blur { tmpMap.put(_Fields.EX, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("ex", org.apache.blur.thirdparty.thrift_0_9_0.TFieldRequirementType.DEFAULT, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldValueMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT))); metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData.addStructMetaDataMap(shardClusterList_result.class, metaDataMap); + org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData.addStructMetaDataMap(shardServerList_result.class, metaDataMap); } - public shardClusterList_result() { + public shardServerList_result() { } - public shardClusterList_result( + public shardServerList_result( List<String> success, BlurException ex) { @@ -39199,7 +40171,7 @@ public class Blur { /** * Performs a deep copy on <i>other</i>. */ - public shardClusterList_result(shardClusterList_result other) { + public shardServerList_result(shardServerList_result other) { if (other.isSetSuccess()) { List<String> __this__success = new ArrayList<String>(); for (String other_element : other.success) { @@ -39212,8 +40184,8 @@ public class Blur { } } - public shardClusterList_result deepCopy() { - return new shardClusterList_result(this); + public shardServerList_result deepCopy() { + return new shardServerList_result(this); } @Override @@ -39241,7 +40213,7 @@ public class Blur { return this.success; } - public shardClusterList_result setSuccess(List<String> success) { + public shardServerList_result setSuccess(List<String> success) { this.success = success; return this; } @@ -39265,7 +40237,7 @@ public class Blur { return this.ex; } - public shardClusterList_result setEx(BlurException ex) { + public shardServerList_result setEx(BlurException ex) { this.ex = ex; return this; } @@ -39337,12 +40309,12 @@ public class Blur { public boolean equals(Object that) { if (that == null) return false; - if (that instanceof shardClusterList_result) - return this.equals((shardClusterList_result)that); + if (that instanceof shardServerList_result) + return this.equals((shardServerList_result)that); return false; } - public boolean equals(shardClusterList_result that) { + public boolean equals(shardServerList_result that) { if (that == null) return false; @@ -39372,13 +40344,13 @@ public class Blur { return 0; } - public int compareTo(shardClusterList_result other) { + public int compareTo(shardServerList_result other) { if (!getClass().equals(other.getClass())) { return getClass().getName().compareTo(other.getClass().getName()); } int lastComparison = 0; - shardClusterList_result typedOther = (shardClusterList_result)other; + shardServerList_result typedOther = (shardServerList_result)other; lastComparison = Boolean.valueOf(isSetSuccess()).compareTo(typedOther.isSetSuccess()); if (lastComparison != 0) { @@ -39417,7 +40389,7 @@ public class Blur { @Override public String toString() { - StringBuilder sb = new StringBuilder("shardClusterList_result("); + StringBuilder sb = new StringBuilder("shardServerList_result("); boolean first = true; sb.append("success:"); @@ -39460,15 +40432,15 @@ public class Blur { } } - private static class shardClusterList_resultStandardSchemeFactory implements SchemeFactory { - public shardClusterList_resultStandardScheme getScheme() { - return new shardClusterList_resultStandardScheme(); + private static class shardServerList_resultStandardSchemeFactory implements SchemeFactory { + public shardServerList_resultStandardScheme getScheme() { + return new shardServerList_resultStandardScheme(); } } - private static class shardClusterList_resultStandardScheme extends StandardScheme<shardClusterList_result> { + private static class shardServerList_resultStandardScheme extends StandardScheme<shardServerList_result> { - public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol iprot, shardClusterList_result struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol iprot, shardServerList_result struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField schemeField; iprot.readStructBegin(); while (true) @@ -39481,13 +40453,13 @@ public class Blur { case 0: // SUCCESS if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.LIST) { { - org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list396 = iprot.readListBegin(); - struct.success = new ArrayList<String>(_list396.size); - for (int _i397 = 0; _i397 < _list396.size; ++_i397) + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list404 = iprot.readListBegin(); + struct.success = new ArrayList<String>(_list404.size); + for (int _i405 = 0; _i405 < _list404.size; ++_i405) { - String _elem398; // required - _elem398 = iprot.readString(); - struct.success.add(_elem398); + String _elem406; // required + _elem406 = iprot.readString(); + struct.success.add(_elem406); } iprot.readListEnd(); } @@ -39516,7 +40488,7 @@ public class Blur { struct.validate(); } - public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol oprot, shardClusterList_result struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol oprot, shardServerList_result struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { struct.validate(); oprot.writeStructBegin(STRUCT_DESC); @@ -39524,9 +40496,9 @@ public class Blur { oprot.writeFieldBegin(SUCCESS_FIELD_DESC); { oprot.writeListBegin(new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, struct.success.size())); - for (String _iter399 : struct.success) + for (String _iter407 : struct.success) { - oprot.writeString(_iter399); + oprot.writeString(_iter407); } oprot.writeListEnd(); } @@ -39543,16 +40515,16 @@ public class Blur { } - private static class shardClusterList_resultTupleSchemeFactory implements SchemeFactory { - public shardClusterList_resultTupleScheme getScheme() { - return new shardClusterList_resultTupleScheme(); + private static class shardServerList_resultTupleSchemeFactory implements SchemeFactory { + public shardServerList_resultTupleScheme getScheme() { + return new shardServerList_resultTupleScheme(); } } - private static class shardClusterList_resultTupleScheme extends TupleScheme<shardClusterList_result> { + private static class shardServerList_resultTupleScheme extends TupleScheme<shardServerList_result> { @Override - public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, shardClusterList_result struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, shardServerList_result struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { TTupleProtocol oprot = (TTupleProtocol) prot; BitSet optionals = new BitSet(); if (struct.isSetSuccess()) { @@ -39565,9 +40537,9 @@ public class Blur { if (struct.isSetSuccess()) { { oprot.writeI32(struct.success.size()); - for (String _iter400 : struct.success) + for (String _iter408 : struct.success) { - oprot.writeString(_iter400); + oprot.writeString(_iter408); } } } @@ -39577,18 +40549,18 @@ public class Blur { } @Override - public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, shardClusterList_result struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, shardServerList_result struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { TTupleProtocol iprot = (TTupleProtocol) prot; BitSet incoming = iprot.readBitSet(2); if (incoming.get(0)) { { - org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list401 = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, iprot.readI32()); - struct.success = new ArrayList<String>(_list401.size); - for (int _i402 = 0; _i402 < _list401.size; ++_i402) + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list409 = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, iprot.readI32()); + struct.success = new ArrayList<String>(_list409.size); + for (int _i410 = 0; _i410 < _list409.size; ++_i410) { - String _elem403; // required - _elem403 = iprot.readString(); - struct.success.add(_elem403); + String _elem411; // required + _elem411 = iprot.readString(); + struct.success.add(_elem411); } } struct.setSuccessIsSet(true); @@ -39603,28 +40575,20 @@ public class Blur { } - public static class shardServerList_args implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<shardServerList_args, shardServerList_args._Fields>, java.io.Serializable, Cloneable { - private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TStruct STRUCT_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TStruct("shardServerList_args"); + public static class controllerServerList_args implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<controllerServerList_args, controllerServerList_args._Fields>, java.io.Serializable, Cloneable { + private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TStruct STRUCT_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TStruct("controllerServerList_args"); - private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField CLUSTER_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("cluster", org.apache.blur.thirdparty.thrift_0_9_0.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 shardServerList_argsStandardSchemeFactory()); - schemes.put(TupleScheme.class, new shardServerList_argsTupleSchemeFactory()); + schemes.put(StandardScheme.class, new controllerServerList_argsStandardSchemeFactory()); + schemes.put(TupleScheme.class, new controllerServerList_argsTupleSchemeFactory()); } - /** - * the cluster name. - */ - public String cluster; // required /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ public enum _Fields implements org.apache.blur.thirdparty.thrift_0_9_0.TFieldIdEnum { - /** - * the cluster name. - */ - CLUSTER((short)1, "cluster"); +; private static final Map<String, _Fields> byName = new HashMap<String, _Fields>(); @@ -39639,8 +40603,6 @@ public class Blur { */ public static _Fields findByThriftId(int fieldId) { switch(fieldId) { - case 1: // CLUSTER - return CLUSTER; default: return null; } @@ -39679,93 +40641,37 @@ public class Blur { return _fieldName; } } - - // isset id assignments public static final Map<_Fields, org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData> metaDataMap; static { Map<_Fields, org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData>(_Fields.class); - tmpMap.put(_Fields.CLUSTER, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("cluster", org.apache.blur.thirdparty.thrift_0_9_0.TFieldRequirementType.DEFAULT, - new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldValueMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING))); metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData.addStructMetaDataMap(shardServerList_args.class, metaDataMap); - } - - public shardServerList_args() { + org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData.addStructMetaDataMap(controllerServerList_args.class, metaDataMap); } - public shardServerList_args( - String cluster) - { - this(); - this.cluster = cluster; + public controllerServerList_args() { } /** * Performs a deep copy on <i>other</i>. */ - public shardServerList_args(shardServerList_args other) { - if (other.isSetCluster()) { - this.cluster = other.cluster; - } + public controllerServerList_args(controllerServerList_args other) { } - public shardServerList_args deepCopy() { - return new shardServerList_args(this); + public controllerServerList_args deepCopy() { + return new controllerServerList_args(this); } @Override public void clear() { - this.cluster = null; - } - - /** - * the cluster name. - */ - public String getCluster() { - return this.cluster; - } - - /** - * the cluster name. - */ - public shardServerList_args setCluster(String cluster) { - this.cluster = cluster; - return this; - } - - public void unsetCluster() { - this.cluster = null; - } - - /** Returns true if field cluster is set (has been assigned a value) and false otherwise */ - public boolean isSetCluster() { - return this.cluster != null; - } - - public void setClusterIsSet(boolean value) { - if (!value) { - this.cluster = null; - } } public void setFieldValue(_Fields field, Object value) { switch (field) { - case CLUSTER: - if (value == null) { - unsetCluster(); - } else { - setCluster((String)value); - } - break; - } } public Object getFieldValue(_Fields field) { switch (field) { - case CLUSTER: - return getCluster(); - } throw new IllegalStateException(); } @@ -39777,8 +40683,6 @@ public class Blur { } switch (field) { - case CLUSTER: - return isSetCluster(); } throw new IllegalStateException(); } @@ -39787,24 +40691,15 @@ public class Blur { public boolean equals(Object that) { if (that == null) return false; - if (that instanceof shardServerList_args) - return this.equals((shardServerList_args)that); + if (that instanceof controllerServerList_args) + return this.equals((controllerServerList_args)that); return false; } - public boolean equals(shardServerList_args that) { + public boolean equals(controllerServerList_args that) { if (that == null) return false; - boolean this_present_cluster = true && this.isSetCluster(); - boolean that_present_cluster = true && that.isSetCluster(); - if (this_present_cluster || that_present_cluster) { - if (!(this_present_cluster && that_present_cluster)) - return false; - if (!this.cluster.equals(that.cluster)) - return false; - } - return true; } @@ -39813,24 +40708,14 @@ public class Blur { return 0; } - public int compareTo(shardServerList_args other) { + public int compareTo(controllerServerList_args other) { if (!getClass().equals(other.getClass())) { return getClass().getName().compareTo(other.getClass().getName()); } int lastComparison = 0; - shardServerList_args typedOther = (shardServerList_args)other; + controllerServerList_args typedOther = (controllerServerList_args)other; - lastComparison = Boolean.valueOf(isSetCluster()).compareTo(typedOther.isSetCluster()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetCluster()) { - lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.cluster, typedOther.cluster); - if (lastComparison != 0) { - return lastComparison; - } - } return 0; } @@ -39848,16 +40733,9 @@ public class Blur { @Override public String toString() { - StringBuilder sb = new StringBuilder("shardServerList_args("); + StringBuilder sb = new StringBuilder("controllerServerList_args("); boolean first = true; - sb.append("cluster:"); - if (this.cluster == null) { - sb.append("null"); - } else { - sb.append(this.cluster); - } - first = false; sb.append(")"); return sb.toString(); } @@ -39883,15 +40761,15 @@ public class Blur { } } - private static class shardServerList_argsStandardSchemeFactory implements SchemeFactory { - public shardServerList_argsStandardScheme getScheme() { - return new shardServerList_argsStandardScheme(); + private static class controllerServerList_argsStandardSchemeFactory implements SchemeFactory { + public controllerServerList_argsStandardScheme getScheme() { + return new controllerServerList_argsStandardScheme(); } } - private static class shardServerList_argsStandardScheme extends StandardScheme<shardServerList_args> { + private static class controllerServerList_argsStandardScheme extends StandardScheme<controllerServerList_args> { - public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol iprot, shardServerList_args struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol iprot, controllerServerList_args struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField schemeField; iprot.readStructBegin(); while (true) @@ -39901,14 +40779,6 @@ public class Blur { break; } switch (schemeField.id) { - case 1: // CLUSTER - if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING) { - struct.cluster = iprot.readString(); - struct.setClusterIsSet(true); - } else { - org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; default: org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, schemeField.type); } @@ -39920,65 +40790,47 @@ public class Blur { struct.validate(); } - public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol oprot, shardServerList_args struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol oprot, controllerServerList_args struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { struct.validate(); oprot.writeStructBegin(STRUCT_DESC); - if (struct.cluster != null) { - oprot.writeFieldBegin(CLUSTER_FIELD_DESC); - oprot.writeString(struct.cluster); - oprot.writeFieldEnd(); - } oprot.writeFieldStop(); oprot.writeStructEnd(); } } - private static class shardServerList_argsTupleSchemeFactory implements SchemeFactory { - public shardServerList_argsTupleScheme getScheme() { - return new shardServerList_argsTupleScheme(); + private static class controllerServerList_argsTupleSchemeFactory implements SchemeFactory { + public controllerServerList_argsTupleScheme getScheme() { + return new controllerServerList_argsTupleScheme(); } } - private static class shardServerList_argsTupleScheme extends TupleScheme<shardServerList_args> { + private static class controllerServerList_argsTupleScheme extends TupleScheme<controllerServerList_args> { @Override - public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, shardServerList_args struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, controllerServerList_args struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { TTupleProtocol oprot = (TTupleProtocol) prot; - BitSet optionals = new BitSet(); - if (struct.isSetCluster()) { - optionals.set(0); - } - oprot.writeBitSet(optionals, 1); - if (struct.isSetCluster()) { - oprot.writeString(struct.cluster); - } } @Override - public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, shardServerList_args struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, controllerServerList_args struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { TTupleProtocol iprot = (TTupleProtocol) prot; - BitSet incoming = iprot.readBitSet(1); - if (incoming.get(0)) { - struct.cluster = iprot.readString(); - struct.setClusterIsSet(true); - } } } } - public static class shardServerList_result implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<shardServerList_result, shardServerList_result._Fields>, java.io.Serializable, Cloneable { - private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TStruct STRUCT_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TStruct("shardServerList_result"); + public static class controllerServerList_result implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<controllerServerList_result, controllerServerList_result._Fields>, java.io.Serializable, Cloneable { + private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TStruct STRUCT_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TStruct("controllerServerList_result"); private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField SUCCESS_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("success", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.LIST, (short)0); private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField EX_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("ex", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT, (short)1); private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); static { - schemes.put(StandardScheme.class, new shardServerList_resultStandardSchemeFactory()); - schemes.put(TupleScheme.class, new shardServerList_resultTupleSchemeFactory()); + schemes.put(StandardScheme.class, new controllerServerList_resultStandardSchemeFactory()); + schemes.put(TupleScheme.class, new controllerServerList_resultTupleSchemeFactory()); } public List<String> success; // required @@ -40055,13 +40907,13 @@ public class Blur { tmpMap.put(_Fields.EX, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("ex", org.apache.blur.thirdparty.thrift_0_9_0.TFieldRequirementType.DEFAULT, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldValueMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT))); metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData.addStructMetaDataMap(shardServerList_result.class, metaDataMap); + org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData.addStructMetaDataMap(controllerServerList_result.class, metaDataMap); } - public shardServerList_result() { + public controllerServerList_result() { } - public shardServerList_result( + public controllerServerList_result( List<String> success, BlurException ex) { @@ -40073,7 +40925,7 @@ public class Blur { /** * Performs a deep copy on <i>other</i>. */ - public shardServerList_result(shardServerList_result other) { + public controllerServerList_result(controllerServerList_result other) { if (other.isSetSuccess()) { List<String> __this__success = new ArrayList<String>(); for (String other_element : other.success) { @@ -40086,8 +40938,8 @@ public class Blur { } } - public shardServerList_result deepCopy() { - return new shardServerList_result(this); + public controllerServerList_result deepCopy() { + return new controllerServerList_result(this); } @Override @@ -40115,7 +40967,7 @@ public class Blur { return this.success; } - public shardServerList_result setSuccess(List<String> success) { + public controllerServerList_result s
<TRUNCATED>
