http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/b434b067/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/Blur.java ---------------------------------------------------------------------- diff --git a/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/Blur.java b/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/Blur.java index 6ddace7..c6e5ec2 100644 --- a/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/Blur.java +++ b/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/Blur.java @@ -57,7 +57,29 @@ public class Blur { */ public interface Iface { - public Response execute(String table, String commandName, Arguments arguments) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException; + /** + * Executes the given command by name on the table with the provided arguments. + * + * @param table + * @param commandName + * @param arguments + */ + public Response execute(String table, String commandName, Arguments arguments) throws BlurException, TimeoutException, org.apache.blur.thirdparty.thrift_0_9_0.TException; + + /** + * If the execute command times out due to command taking longer than the configured + * network tcp timeout this method allows the client to reconnect to the already + * executing command. + * + * @param executionId + */ + public Response reconnect(String executionId) throws BlurException, TimeoutException, org.apache.blur.thirdparty.thrift_0_9_0.TException; + + /** + * Releases and refreshes the read snapshots of the indexes in the session for the + * current connection. + */ + public void refresh() throws org.apache.blur.thirdparty.thrift_0_9_0.TException; /** * Creates a table with the given TableDescriptor. @@ -447,6 +469,10 @@ public class Blur { public void execute(String table, String commandName, Arguments arguments, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.execute_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException; + public void reconnect(String executionId, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.reconnect_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException; + + public void refresh(org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.refresh_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException; + public void createTable(TableDescriptor tableDescriptor, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.createTable_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException; public void enableTable(String table, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.enableTable_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException; @@ -557,7 +583,7 @@ public class Blur { super(iprot, oprot); } - public Response execute(String table, String commandName, Arguments arguments) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + public Response execute(String table, String commandName, Arguments arguments) throws BlurException, TimeoutException, org.apache.blur.thirdparty.thrift_0_9_0.TException { send_execute(table, commandName, arguments); return recv_execute(); @@ -572,19 +598,62 @@ public class Blur { sendBase("execute", args); } - public Response recv_execute() throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + public Response recv_execute() throws BlurException, TimeoutException, org.apache.blur.thirdparty.thrift_0_9_0.TException { execute_result result = new execute_result(); receiveBase(result, "execute"); if (result.isSetSuccess()) { return result.success; } - if (result.ex != null) { - throw result.ex; + if (result.bex != null) { + throw result.bex; + } + if (result.tex != null) { + throw result.tex; } throw new org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException(org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException.MISSING_RESULT, "execute failed: unknown result"); } + public Response reconnect(String executionId) throws BlurException, TimeoutException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + send_reconnect(executionId); + return recv_reconnect(); + } + + public void send_reconnect(String executionId) throws org.apache.blur.thirdparty.thrift_0_9_0.TException + { + reconnect_args args = new reconnect_args(); + args.setExecutionId(executionId); + sendBase("reconnect", args); + } + + public Response recv_reconnect() throws BlurException, TimeoutException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + reconnect_result result = new reconnect_result(); + receiveBase(result, "reconnect"); + if (result.isSetSuccess()) { + return result.success; + } + if (result.bex != null) { + throw result.bex; + } + if (result.tex != null) { + throw result.tex; + } + throw new org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException(org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException.MISSING_RESULT, "reconnect failed: unknown result"); + } + + public void refresh() throws org.apache.blur.thirdparty.thrift_0_9_0.TException + { + send_refresh(); + } + + public void send_refresh() throws org.apache.blur.thirdparty.thrift_0_9_0.TException + { + refresh_args args = new refresh_args(); + sendBase("refresh", args); + } + public void createTable(TableDescriptor tableDescriptor) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { send_createTable(tableDescriptor); @@ -1710,7 +1779,7 @@ public class Blur { prot.writeMessageEnd(); } - public Response getResult() throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { + public Response getResult() throws BlurException, TimeoutException, 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!"); } @@ -1720,6 +1789,66 @@ public class Blur { } } + public void reconnect(String executionId, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<reconnect_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + checkReady(); + reconnect_call method_call = new reconnect_call(executionId, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class reconnect_call extends org.apache.blur.thirdparty.thrift_0_9_0.async.TAsyncMethodCall { + private String executionId; + public reconnect_call(String executionId, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<reconnect_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.executionId = executionId; + } + + 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("reconnect", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMessageType.CALL, 0)); + reconnect_args args = new reconnect_args(); + args.setExecutionId(executionId); + args.write(prot); + prot.writeMessageEnd(); + } + + public Response getResult() throws BlurException, TimeoutException, 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_reconnect(); + } + } + + public void refresh(org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<refresh_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + checkReady(); + refresh_call method_call = new refresh_call(resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class refresh_call extends org.apache.blur.thirdparty.thrift_0_9_0.async.TAsyncMethodCall { + public refresh_call(org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<refresh_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, true); + } + + 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("refresh", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMessageType.CALL, 0)); + refresh_args args = new refresh_args(); + args.write(prot); + prot.writeMessageEnd(); + } + + public void getResult() throws 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); + } + } + public void createTable(TableDescriptor tableDescriptor, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<createTable_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { checkReady(); createTable_call method_call = new createTable_call(tableDescriptor, resultHandler, this, ___protocolFactory, ___transport); @@ -3182,6 +3311,8 @@ public class Blur { private static <I extends Iface> Map<String, org.apache.blur.thirdparty.thrift_0_9_0.ProcessFunction<I, ? extends org.apache.blur.thirdparty.thrift_0_9_0.TBase>> getProcessMap(Map<String, org.apache.blur.thirdparty.thrift_0_9_0.ProcessFunction<I, ? extends org.apache.blur.thirdparty.thrift_0_9_0.TBase>> processMap) { processMap.put("execute", new execute()); + processMap.put("reconnect", new reconnect()); + processMap.put("refresh", new refresh()); processMap.put("createTable", new createTable()); processMap.put("enableTable", new enableTable()); processMap.put("disableTable", new disableTable()); @@ -3246,13 +3377,60 @@ public class Blur { execute_result result = new execute_result(); try { result.success = iface.execute(args.table, args.commandName, args.arguments); - } catch (BlurException ex) { - result.ex = ex; + } catch (BlurException bex) { + result.bex = bex; + } catch (TimeoutException tex) { + result.tex = tex; + } + return result; + } + } + + public static class reconnect<I extends Iface> extends org.apache.blur.thirdparty.thrift_0_9_0.ProcessFunction<I, reconnect_args> { + public reconnect() { + super("reconnect"); + } + + public reconnect_args getEmptyArgsInstance() { + return new reconnect_args(); + } + + protected boolean isOneway() { + return false; + } + + public reconnect_result getResult(I iface, reconnect_args args) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + reconnect_result result = new reconnect_result(); + try { + result.success = iface.reconnect(args.executionId); + } catch (BlurException bex) { + result.bex = bex; + } catch (TimeoutException tex) { + result.tex = tex; } return result; } } + public static class refresh<I extends Iface> extends org.apache.blur.thirdparty.thrift_0_9_0.ProcessFunction<I, refresh_args> { + public refresh() { + super("refresh"); + } + + public refresh_args getEmptyArgsInstance() { + return new refresh_args(); + } + + protected boolean isOneway() { + return true; + } + + public org.apache.blur.thirdparty.thrift_0_9_0.TBase getResult(I iface, refresh_args args) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + iface.refresh(); + return null; + } + } + public static class createTable<I extends Iface> extends org.apache.blur.thirdparty.thrift_0_9_0.ProcessFunction<I, createTable_args> { public createTable() { super("createTable"); @@ -4863,7 +5041,8 @@ public class Blur { 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("execute_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.STRUCT, (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 org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField BEX_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("bex", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT, (short)1); + private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField TEX_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("tex", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT, (short)2); private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); static { @@ -4872,12 +5051,14 @@ public class Blur { } public Response success; // required - public BlurException ex; // required + public BlurException bex; // required + public TimeoutException tex; // 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"); + BEX((short)1, "bex"), + TEX((short)2, "tex"); private static final Map<String, _Fields> byName = new HashMap<String, _Fields>(); @@ -4894,8 +5075,10 @@ public class Blur { switch(fieldId) { case 0: // SUCCESS return SUCCESS; - case 1: // EX - return EX; + case 1: // BEX + return BEX; + case 2: // TEX + return TEX; default: return null; } @@ -4941,7 +5124,9 @@ public class Blur { 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.StructMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT, Response.class))); - 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, + tmpMap.put(_Fields.BEX, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("bex", 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))); + tmpMap.put(_Fields.TEX, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("tex", 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(execute_result.class, metaDataMap); @@ -4952,11 +5137,13 @@ public class Blur { public execute_result( Response success, - BlurException ex) + BlurException bex, + TimeoutException tex) { this(); this.success = success; - this.ex = ex; + this.bex = bex; + this.tex = tex; } /** @@ -4966,8 +5153,11 @@ public class Blur { if (other.isSetSuccess()) { this.success = new Response(other.success); } - if (other.isSetEx()) { - this.ex = new BlurException(other.ex); + if (other.isSetBex()) { + this.bex = new BlurException(other.bex); + } + if (other.isSetTex()) { + this.tex = new TimeoutException(other.tex); } } @@ -4978,7 +5168,8 @@ public class Blur { @Override public void clear() { this.success = null; - this.ex = null; + this.bex = null; + this.tex = null; } public Response getSuccess() { @@ -5005,27 +5196,51 @@ public class Blur { } } - public BlurException getEx() { - return this.ex; + public BlurException getBex() { + return this.bex; } - public execute_result setEx(BlurException ex) { - this.ex = ex; + public execute_result setBex(BlurException bex) { + this.bex = bex; return this; } - public void unsetEx() { - this.ex = null; + public void unsetBex() { + this.bex = null; } - /** Returns true if field ex is set (has been assigned a value) and false otherwise */ - public boolean isSetEx() { - return this.ex != null; + /** Returns true if field bex is set (has been assigned a value) and false otherwise */ + public boolean isSetBex() { + return this.bex != null; } - public void setExIsSet(boolean value) { + public void setBexIsSet(boolean value) { if (!value) { - this.ex = null; + this.bex = null; + } + } + + public TimeoutException getTex() { + return this.tex; + } + + public execute_result setTex(TimeoutException tex) { + this.tex = tex; + return this; + } + + public void unsetTex() { + this.tex = null; + } + + /** Returns true if field tex is set (has been assigned a value) and false otherwise */ + public boolean isSetTex() { + return this.tex != null; + } + + public void setTexIsSet(boolean value) { + if (!value) { + this.tex = null; } } @@ -5039,11 +5254,19 @@ public class Blur { } break; - case EX: + case BEX: if (value == null) { - unsetEx(); + unsetBex(); } else { - setEx((BlurException)value); + setBex((BlurException)value); + } + break; + + case TEX: + if (value == null) { + unsetTex(); + } else { + setTex((TimeoutException)value); } break; @@ -5055,8 +5278,11 @@ public class Blur { case SUCCESS: return getSuccess(); - case EX: - return getEx(); + case BEX: + return getBex(); + + case TEX: + return getTex(); } throw new IllegalStateException(); @@ -5071,8 +5297,10 @@ public class Blur { switch (field) { case SUCCESS: return isSetSuccess(); - case EX: - return isSetEx(); + case BEX: + return isSetBex(); + case TEX: + return isSetTex(); } throw new IllegalStateException(); } @@ -5099,12 +5327,21 @@ public class Blur { 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)) + boolean this_present_bex = true && this.isSetBex(); + boolean that_present_bex = true && that.isSetBex(); + if (this_present_bex || that_present_bex) { + if (!(this_present_bex && that_present_bex)) return false; - if (!this.ex.equals(that.ex)) + if (!this.bex.equals(that.bex)) + return false; + } + + boolean this_present_tex = true && this.isSetTex(); + boolean that_present_tex = true && that.isSetTex(); + if (this_present_tex || that_present_tex) { + if (!(this_present_tex && that_present_tex)) + return false; + if (!this.tex.equals(that.tex)) return false; } @@ -5134,12 +5371,22 @@ public class Blur { return lastComparison; } } - lastComparison = Boolean.valueOf(isSetEx()).compareTo(typedOther.isSetEx()); + lastComparison = Boolean.valueOf(isSetBex()).compareTo(typedOther.isSetBex()); if (lastComparison != 0) { return lastComparison; } - if (isSetEx()) { - lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.ex, typedOther.ex); + if (isSetBex()) { + lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.bex, typedOther.bex); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetTex()).compareTo(typedOther.isSetTex()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetTex()) { + lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.tex, typedOther.tex); if (lastComparison != 0) { return lastComparison; } @@ -5172,11 +5419,933 @@ public class Blur { } first = false; if (!first) sb.append(", "); - sb.append("ex:"); - if (this.ex == null) { + sb.append("bex:"); + if (this.bex == null) { sb.append("null"); } else { - sb.append(this.ex); + sb.append(this.bex); + } + first = false; + if (!first) sb.append(", "); + sb.append("tex:"); + if (this.tex == null) { + sb.append("null"); + } else { + sb.append(this.tex); + } + 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 { + 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 execute_resultStandardSchemeFactory implements SchemeFactory { + public execute_resultStandardScheme getScheme() { + return new execute_resultStandardScheme(); + } + } + + private static class execute_resultStandardScheme extends StandardScheme<execute_result> { + + public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol iprot, execute_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.STRUCT) { + struct.success = new Response(); + struct.success.read(iprot); + struct.setSuccessIsSet(true); + } else { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 1: // BEX + if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT) { + struct.bex = new BlurException(); + struct.bex.read(iprot); + struct.setBexIsSet(true); + } else { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 2: // TEX + if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT) { + struct.tex = new TimeoutException(); + struct.tex.read(iprot); + struct.setTexIsSet(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, execute_result struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + struct.validate(); + + oprot.writeStructBegin(STRUCT_DESC); + if (struct.success != null) { + oprot.writeFieldBegin(SUCCESS_FIELD_DESC); + struct.success.write(oprot); + oprot.writeFieldEnd(); + } + if (struct.bex != null) { + oprot.writeFieldBegin(BEX_FIELD_DESC); + struct.bex.write(oprot); + oprot.writeFieldEnd(); + } + if (struct.tex != null) { + oprot.writeFieldBegin(TEX_FIELD_DESC); + struct.tex.write(oprot); + oprot.writeFieldEnd(); + } + oprot.writeFieldStop(); + oprot.writeStructEnd(); + } + + } + + private static class execute_resultTupleSchemeFactory implements SchemeFactory { + public execute_resultTupleScheme getScheme() { + return new execute_resultTupleScheme(); + } + } + + private static class execute_resultTupleScheme extends TupleScheme<execute_result> { + + @Override + public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, execute_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.isSetBex()) { + optionals.set(1); + } + if (struct.isSetTex()) { + optionals.set(2); + } + oprot.writeBitSet(optionals, 3); + if (struct.isSetSuccess()) { + struct.success.write(oprot); + } + if (struct.isSetBex()) { + struct.bex.write(oprot); + } + if (struct.isSetTex()) { + struct.tex.write(oprot); + } + } + + @Override + public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, execute_result struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + TTupleProtocol iprot = (TTupleProtocol) prot; + BitSet incoming = iprot.readBitSet(3); + if (incoming.get(0)) { + struct.success = new Response(); + struct.success.read(iprot); + struct.setSuccessIsSet(true); + } + if (incoming.get(1)) { + struct.bex = new BlurException(); + struct.bex.read(iprot); + struct.setBexIsSet(true); + } + if (incoming.get(2)) { + struct.tex = new TimeoutException(); + struct.tex.read(iprot); + struct.setTexIsSet(true); + } + } + } + + } + + public static class reconnect_args implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<reconnect_args, reconnect_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("reconnect_args"); + + private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField EXECUTION_ID_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("executionId", 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 reconnect_argsStandardSchemeFactory()); + schemes.put(TupleScheme.class, new reconnect_argsTupleSchemeFactory()); + } + + public String executionId; // 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 { + EXECUTION_ID((short)1, "executionId"); + + 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: // EXECUTION_ID + return EXECUTION_ID; + 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.EXECUTION_ID, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("executionId", 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(reconnect_args.class, metaDataMap); + } + + public reconnect_args() { + } + + public reconnect_args( + String executionId) + { + this(); + this.executionId = executionId; + } + + /** + * Performs a deep copy on <i>other</i>. + */ + public reconnect_args(reconnect_args other) { + if (other.isSetExecutionId()) { + this.executionId = other.executionId; + } + } + + public reconnect_args deepCopy() { + return new reconnect_args(this); + } + + @Override + public void clear() { + this.executionId = null; + } + + public String getExecutionId() { + return this.executionId; + } + + public reconnect_args setExecutionId(String executionId) { + this.executionId = executionId; + return this; + } + + public void unsetExecutionId() { + this.executionId = null; + } + + /** Returns true if field executionId is set (has been assigned a value) and false otherwise */ + public boolean isSetExecutionId() { + return this.executionId != null; + } + + public void setExecutionIdIsSet(boolean value) { + if (!value) { + this.executionId = null; + } + } + + public void setFieldValue(_Fields field, Object value) { + switch (field) { + case EXECUTION_ID: + if (value == null) { + unsetExecutionId(); + } else { + setExecutionId((String)value); + } + break; + + } + } + + public Object getFieldValue(_Fields field) { + switch (field) { + case EXECUTION_ID: + return getExecutionId(); + + } + 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 EXECUTION_ID: + return isSetExecutionId(); + } + throw new IllegalStateException(); + } + + @Override + public boolean equals(Object that) { + if (that == null) + return false; + if (that instanceof reconnect_args) + return this.equals((reconnect_args)that); + return false; + } + + public boolean equals(reconnect_args that) { + if (that == null) + return false; + + boolean this_present_executionId = true && this.isSetExecutionId(); + boolean that_present_executionId = true && that.isSetExecutionId(); + if (this_present_executionId || that_present_executionId) { + if (!(this_present_executionId && that_present_executionId)) + return false; + if (!this.executionId.equals(that.executionId)) + return false; + } + + return true; + } + + @Override + public int hashCode() { + return 0; + } + + public int compareTo(reconnect_args other) { + if (!getClass().equals(other.getClass())) { + return getClass().getName().compareTo(other.getClass().getName()); + } + + int lastComparison = 0; + reconnect_args typedOther = (reconnect_args)other; + + lastComparison = Boolean.valueOf(isSetExecutionId()).compareTo(typedOther.isSetExecutionId()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetExecutionId()) { + lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.executionId, typedOther.executionId); + 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("reconnect_args("); + boolean first = true; + + sb.append("executionId:"); + if (this.executionId == null) { + sb.append("null"); + } else { + sb.append(this.executionId); + } + 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 { + 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 reconnect_argsStandardSchemeFactory implements SchemeFactory { + public reconnect_argsStandardScheme getScheme() { + return new reconnect_argsStandardScheme(); + } + } + + private static class reconnect_argsStandardScheme extends StandardScheme<reconnect_args> { + + public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol iprot, reconnect_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) { + case 1: // EXECUTION_ID + if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING) { + struct.executionId = iprot.readString(); + struct.setExecutionIdIsSet(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, reconnect_args struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + struct.validate(); + + oprot.writeStructBegin(STRUCT_DESC); + if (struct.executionId != null) { + oprot.writeFieldBegin(EXECUTION_ID_FIELD_DESC); + oprot.writeString(struct.executionId); + oprot.writeFieldEnd(); + } + oprot.writeFieldStop(); + oprot.writeStructEnd(); + } + + } + + private static class reconnect_argsTupleSchemeFactory implements SchemeFactory { + public reconnect_argsTupleScheme getScheme() { + return new reconnect_argsTupleScheme(); + } + } + + private static class reconnect_argsTupleScheme extends TupleScheme<reconnect_args> { + + @Override + public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, reconnect_args struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + TTupleProtocol oprot = (TTupleProtocol) prot; + BitSet optionals = new BitSet(); + if (struct.isSetExecutionId()) { + optionals.set(0); + } + oprot.writeBitSet(optionals, 1); + if (struct.isSetExecutionId()) { + oprot.writeString(struct.executionId); + } + } + + @Override + public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, reconnect_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.executionId = iprot.readString(); + struct.setExecutionIdIsSet(true); + } + } + } + + } + + public static class reconnect_result implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<reconnect_result, reconnect_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("reconnect_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.STRUCT, (short)0); + private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField BEX_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("bex", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT, (short)1); + private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField TEX_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("tex", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT, (short)2); + + private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); + static { + schemes.put(StandardScheme.class, new reconnect_resultStandardSchemeFactory()); + schemes.put(TupleScheme.class, new reconnect_resultTupleSchemeFactory()); + } + + public Response success; // required + public BlurException bex; // required + public TimeoutException tex; // 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"), + BEX((short)1, "bex"), + TEX((short)2, "tex"); + + 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: // BEX + return BEX; + case 2: // TEX + return TEX; + 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.StructMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT, Response.class))); + tmpMap.put(_Fields.BEX, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("bex", 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))); + tmpMap.put(_Fields.TEX, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("tex", 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(reconnect_result.class, metaDataMap); + } + + public reconnect_result() { + } + + public reconnect_result( + Response success, + BlurException bex, + TimeoutException tex) + { + this(); + this.success = success; + this.bex = bex; + this.tex = tex; + } + + /** + * Performs a deep copy on <i>other</i>. + */ + public reconnect_result(reconnect_result other) { + if (other.isSetSuccess()) { + this.success = new Response(other.success); + } + if (other.isSetBex()) { + this.bex = new BlurException(other.bex); + } + if (other.isSetTex()) { + this.tex = new TimeoutException(other.tex); + } + } + + public reconnect_result deepCopy() { + return new reconnect_result(this); + } + + @Override + public void clear() { + this.success = null; + this.bex = null; + this.tex = null; + } + + public Response getSuccess() { + return this.success; + } + + public reconnect_result setSuccess(Response success) { + this.success = success; + return this; + } + + public void unsetSuccess() { + this.success = null; + } + + /** Returns true if field success is set (has been assigned a value) and false otherwise */ + public boolean isSetSuccess() { + return this.success != null; + } + + public void setSuccessIsSet(boolean value) { + if (!value) { + this.success = null; + } + } + + public BlurException getBex() { + return this.bex; + } + + public reconnect_result setBex(BlurException bex) { + this.bex = bex; + return this; + } + + public void unsetBex() { + this.bex = null; + } + + /** Returns true if field bex is set (has been assigned a value) and false otherwise */ + public boolean isSetBex() { + return this.bex != null; + } + + public void setBexIsSet(boolean value) { + if (!value) { + this.bex = null; + } + } + + public TimeoutException getTex() { + return this.tex; + } + + public reconnect_result setTex(TimeoutException tex) { + this.tex = tex; + return this; + } + + public void unsetTex() { + this.tex = null; + } + + /** Returns true if field tex is set (has been assigned a value) and false otherwise */ + public boolean isSetTex() { + return this.tex != null; + } + + public void setTexIsSet(boolean value) { + if (!value) { + this.tex = null; + } + } + + public void setFieldValue(_Fields field, Object value) { + switch (field) { + case SUCCESS: + if (value == null) { + unsetSuccess(); + } else { + setSuccess((Response)value); + } + break; + + case BEX: + if (value == null) { + unsetBex(); + } else { + setBex((BlurException)value); + } + break; + + case TEX: + if (value == null) { + unsetTex(); + } else { + setTex((TimeoutException)value); + } + break; + + } + } + + public Object getFieldValue(_Fields field) { + switch (field) { + case SUCCESS: + return getSuccess(); + + case BEX: + return getBex(); + + case TEX: + return getTex(); + + } + 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 BEX: + return isSetBex(); + case TEX: + return isSetTex(); + } + throw new IllegalStateException(); + } + + @Override + public boolean equals(Object that) { + if (that == null) + return false; + if (that instanceof reconnect_result) + return this.equals((reconnect_result)that); + return false; + } + + public boolean equals(reconnect_result that) { + if (that == null) + return false; + + 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.equals(that.success)) + return false; + } + + boolean this_present_bex = true && this.isSetBex(); + boolean that_present_bex = true && that.isSetBex(); + if (this_present_bex || that_present_bex) { + if (!(this_present_bex && that_present_bex)) + return false; + if (!this.bex.equals(that.bex)) + return false; + } + + boolean this_present_tex = true && this.isSetTex(); + boolean that_present_tex = true && that.isSetTex(); + if (this_present_tex || that_present_tex) { + if (!(this_present_tex && that_present_tex)) + return false; + if (!this.tex.equals(that.tex)) + return false; + } + + return true; + } + + @Override + public int hashCode() { + return 0; + } + + public int compareTo(reconnect_result other) { + if (!getClass().equals(other.getClass())) { + return getClass().getName().compareTo(other.getClass().getName()); + } + + int lastComparison = 0; + reconnect_result typedOther = (reconnect_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(isSetBex()).compareTo(typedOther.isSetBex()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetBex()) { + lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.bex, typedOther.bex); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetTex()).compareTo(typedOther.isSetTex()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetTex()) { + lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.tex, typedOther.tex); + 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("reconnect_result("); + boolean first = true; + + sb.append("success:"); + if (this.success == null) { + sb.append("null"); + } else { + sb.append(this.success); + } + first = false; + if (!first) sb.append(", "); + sb.append("bex:"); + if (this.bex == null) { + sb.append("null"); + } else { + sb.append(this.bex); + } + first = false; + if (!first) sb.append(", "); + sb.append("tex:"); + if (this.tex == null) { + sb.append("null"); + } else { + sb.append(this.tex); } first = false; sb.append(")"); @@ -5204,15 +6373,15 @@ public class Blur { } } - private static class execute_resultStandardSchemeFactory implements SchemeFactory { - public execute_resultStandardScheme getScheme() { - return new execute_resultStandardScheme(); + private static class reconnect_resultStandardSchemeFactory implements SchemeFactory { + public reconnect_resultStandardScheme getScheme() { + return new reconnect_resultStandardScheme(); } } - private static class execute_resultStandardScheme extends StandardScheme<execute_result> { + private static class reconnect_resultStandardScheme extends StandardScheme<reconnect_result> { - public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol iprot, execute_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, reconnect_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) @@ -5231,11 +6400,20 @@ public class Blur { org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, schemeField.type); } break; - case 1: // EX + case 1: // BEX 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); + struct.bex = new BlurException(); + struct.bex.read(iprot); + struct.setBexIsSet(true); + } else { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 2: // TEX + if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT) { + struct.tex = new TimeoutException(); + struct.tex.read(iprot); + struct.setTexIsSet(true); } else { org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, schemeField.type); } @@ -5251,7 +6429,7 @@ public class Blur { struct.validate(); } - public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol oprot, execute_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, reconnect_result struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { struct.validate(); oprot.writeStructBegin(STRUCT_DESC); @@ -5260,9 +6438,14 @@ public class Blur { struct.success.write(oprot); oprot.writeFieldEnd(); } - if (struct.ex != null) { - oprot.writeFieldBegin(EX_FIELD_DESC); - struct.ex.write(oprot); + if (struct.bex != null) { + oprot.writeFieldBegin(BEX_FIELD_DESC); + struct.bex.write(oprot); + oprot.writeFieldEnd(); + } + if (struct.tex != null) { + oprot.writeFieldBegin(TEX_FIELD_DESC); + struct.tex.write(oprot); oprot.writeFieldEnd(); } oprot.writeFieldStop(); @@ -5271,47 +6454,304 @@ public class Blur { } - private static class execute_resultTupleSchemeFactory implements SchemeFactory { - public execute_resultTupleScheme getScheme() { - return new execute_resultTupleScheme(); + private static class reconnect_resultTupleSchemeFactory implements SchemeFactory { + public reconnect_resultTupleScheme getScheme() { + return new reconnect_resultTupleScheme(); } } - private static class execute_resultTupleScheme extends TupleScheme<execute_result> { + private static class reconnect_resultTupleScheme extends TupleScheme<reconnect_result> { @Override - public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, execute_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, reconnect_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()) { + if (struct.isSetBex()) { optionals.set(1); } - oprot.writeBitSet(optionals, 2); + if (struct.isSetTex()) { + optionals.set(2); + } + oprot.writeBitSet(optionals, 3); if (struct.isSetSuccess()) { struct.success.write(oprot); } - if (struct.isSetEx()) { - struct.ex.write(oprot); + if (struct.isSetBex()) { + struct.bex.write(oprot); + } + if (struct.isSetTex()) { + struct.tex.write(oprot); } } @Override - public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, execute_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, reconnect_result struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { TTupleProtocol iprot = (TTupleProtocol) prot; - BitSet incoming = iprot.readBitSet(2); + BitSet incoming = iprot.readBitSet(3); if (incoming.get(0)) { struct.success = new Response(); struct.success.read(iprot); struct.setSuccessIsSet(true); } if (incoming.get(1)) { - struct.ex = new BlurException(); - struct.ex.read(iprot); - struct.setExIsSet(true); + struct.bex = new BlurException(); + struct.bex.read(iprot); + struct.setBexIsSet(true); + } + if (incoming.get(2)) { + struct.tex = new TimeoutException(); + struct.tex.read(iprot); + struct.setTexIsSet(true); + } + } + } + + } + + public static class refresh_args implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<refresh_args, refresh_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("refresh_args"); + + + private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); + static { + schemes.put(StandardScheme.class, new refresh_argsStandardSchemeFactory()); + schemes.put(TupleScheme.class, new refresh_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(refresh_args.class, metaDataMap); + } + + public refresh_args() { + } + + /** + * Performs a deep copy on <i>other</i>. + */ + public refresh_args(refresh_args other) { + } + + public refresh_args deepCopy() { + return new refresh_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 refresh_args) + return this.equals((refresh_args)that); + return false; + } + + public boolean equals(refresh_args that) { + if (that == null) + return false; + + return true; + } + + @Override + public int hashCode() { + return 0; + } + + public int compareTo(refresh_args other) { + if (!getClass().equals(other.getClass())) { + return getClass().getName().compareTo(other.getClass().getName()); + } + + int lastComparison = 0; + refresh_args typedOther = (refresh_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("refresh_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 refresh_argsStandardSchemeFactory implements SchemeFactory { + public refresh_argsStandardScheme getScheme() { + return new refresh_argsStandardScheme(); + } + } + + private static class refresh_argsStandardScheme extends StandardScheme<refresh_args> { + + public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol iprot, refresh_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, refresh_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 refresh_argsTupleSchemeFactory implements SchemeFactory { + public refresh_argsTupleScheme getScheme() { + return new refresh_argsTupleScheme(); + } + } + + private static class refresh_argsTupleScheme extends TupleScheme<refresh_args> { + + @Override + public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, refresh_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, refresh_args struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + TTupleProtocol iprot = (TTupleProtocol) prot; } } @@ -9891,13 +11331,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 _list252 = iprot.readListBegin(); - struct.success = new ArrayList<String>(_list252.size); - for (int _i253 = 0; _i253 < _list252.size; ++_i253) + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list262 = iprot.readListBegin(); + struct.success = new ArrayList<String>(_list262.size); + for (int _i263 = 0; _i263 < _list262.size; ++_i263) { - String _elem254; // required - _elem254 = iprot.readString(); - struct.success.add(_elem254); + String _elem264; // required + _elem264 = iprot.readString(); + struct.success.add(_elem264); } iprot.readListEnd(); } @@ -9934,9 +11374,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 _iter255 : struct.success) + for (String _iter265 : struct.success) { - oprot.writeString(_iter255); + oprot.writeString(_iter265); } oprot.writeListEnd(); } @@ -9975,9 +11415,9 @@ public class Blur { if (struct.isSetSuccess()) { { oprot.writeI32(struct.success.size()); - for (String _iter256 : struct.success) + for (String _iter266 : struct.success) { - oprot.writeString(_iter256); + oprot.writeString(_iter266); } } } @@ -9992,13 +11432,13 @@ public class Blur { BitSet incoming = iprot.readBitSet(2); if (incoming.get(0)) { { - org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list257 = 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>(_list257.size); - for (int _i258 = 0; _i258 < _list257.size; ++_i258) + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list267 = 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>(_list267.size); + for (int _i268 = 0; _i268 < _list267.size; ++_i268) { - String _elem259; // required - _elem259 = iprot.readString(); - struct.success.add(_elem259); + String _elem269; // required + _elem269 = iprot.readString(); + struct.success.add(_elem269); } } struct.setSuccessIsSet(true); @@ -10765,13 +12205,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 _list260 = iprot.readListBegin(); - struct.success = new ArrayList<String>(_list260.size); - for (int _i261 = 0; _i261 < _list260.size; ++_i261) + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list270 = iprot.readListBegin(); + struct.success = new ArrayList<String>(_list270.size); + for (int _i271 = 0; _i271 < _list270.size; ++_i271) { - String _elem262; // required - _elem262 = iprot.readString(); - struct.success.add(_elem262); + String _elem272; // required + _elem272 = iprot.readString(); + struct.success.add(_elem272); } iprot.readListEnd(); } @@ -10808,9 +12248,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 _iter263 : struct.success) + for (String _iter273 : struct.success) { - oprot.writeString(_iter263); + oprot.writeString(_iter273); } oprot.writeListEnd(); } @@ -10849,9 +12289,9 @@ public class Blur { if (struct.isSetSuccess()) { { oprot.writeI32(struct.success.size()); - for (String _iter264 : struct.success) + for (String _iter274 : struct.success) { - oprot.writeString(_iter264); + oprot.writeString(_iter274); } } } @@ -10866,13 +12306,13 @@ public class Blur { BitSet incoming = iprot.readBitSet(2); if (incoming.get(0)) { { - org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list265 = 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>(_list265.size); - for (int _i266 = 0; _i266 < _list265.size; ++_i266) + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list275 = 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>(_list275.size); + for (int _i276 = 0; _i276 < _list275.size; ++_i276) { - String _elem267; // required - _elem267 = iprot.readString(); - struct.success.add(_elem267); + String _elem277; // required + _elem277 = iprot.readString(); + struct.success.add(_elem277); } } struct.setSuccessIsSet(true); @@ -17508,25 +18948,25 @@ public class Blur { case 0: // SUCCESS if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.MAP) { { - org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap _map268 = iprot.readMapBegin(); - struct.success = new HashMap<String,List<String>>(2*_map268.size); - for (int _i269 = 0; _i269 < _map268.size; ++_i269) + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap _map278 = iprot.readMapBegin(); + struct.success = new HashMap<String,List<String>>(2*_map278.size); + for (int _i279 = 0; _i279 < _map278.size; ++_i279) { - String _key270; // optional - List<String> _val271; // required - _key270 = iprot.readString(); + String _key280; // optional + List<String> _val281; // required + _key280 = iprot.readString(); { - org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list272 = iprot.readListBegin(); - _val271 = new ArrayList<String>(_list272.size); - for (int _i273 = 0; _i273 < _list272.size; ++_i273) + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list282 = iprot.readListBegin(); + _val281 = new ArrayList<String>(_list282.size); + for (int _i283 = 0; _i283 < _list282.size; ++_i283) { - String _elem274; // required - _elem274 = iprot.readString(); - _val271.add(_elem274); + String _elem284; // required + _elem284 = iprot.readString(); + _val281.add(_elem284); } iprot.readListEnd(); } - struct.success.put(_key270, _val271); + struct.success.put(_key280, _val281); } iprot.readMapEnd(); } @@ -17563,14 +19003,14 @@ public class Blur { oprot.writeFieldBegin(SUCCESS_FIELD_DESC); { oprot.writeMapBegin(new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.LIST, struct.success.size())); - for (Map.Entry<String, List<String>> _iter275 : struct.success.entrySet()) + for (Map.Entry<String, List<String>> _iter285 : struct.success.entrySet()) { - oprot.writeString(_iter275.getKey()); + oprot.writeString(_iter285.getKey()); { - oprot.writeListBegin(new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, _iter275.getValue().size())); - for (String _iter276 : _iter275.getValue()) + oprot.writeListBegin(new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, _iter285.getValue().size())); + for (String _iter286 : _iter285.getValue()) { - oprot.writeString(_iter276); + oprot.writeString(_iter286); } oprot.writeListEnd(); } @@ -17612,14 +19052,14 @@ public class Blur { if (struct.isSetSuccess()) { { oprot.writeI32(struct.success.size()); - for (Map.Entry<String, List<String>> _iter277 : struct.success.entrySet()) + for (Map.Entry<String, List<String>> _iter287 : struct.success.entrySet()) { - oprot.writeString(_iter277.getKey()); + oprot.writeString(_iter287.getKey()); { - oprot.writeI32(_iter277.getValue().size()); - for (String _iter278 : _iter277.getValue()) + oprot.writeI32(_iter287.getValue().size()); + for (String _iter288 : _iter287.getValue()) { - oprot.writeString(_iter278); + oprot.writeString(_iter288); } } } @@ -17636,24 +19076,24 @@ public class Blur { BitSet incoming = iprot.readBitSet(2); if (incoming.get(0)) { { - org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap _map279 = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.LIST, iprot.readI32()); - struct.success = new HashMap<String,List<String>>(2*_map279.size); - for (int _i280 = 0; _i280 < _map279.size; ++_i280) + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap _map289 = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.LIST, iprot.readI32()); + struct.success = new HashMap<String,List<String>>(2*_map289.size); + for (int _i290 = 0; _i290 < _map289.size; ++_i290) { - String _key281; // optional - List<String> _val282; // required - _key281 = iprot.readString(); + String _key291; // optional + List<String> _val292; // required + _key291 = iprot.readString(); { - org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list283 = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, iprot.readI32()); - _val282 = new ArrayList<String>(_list283.size); - for (int _i284 = 0; _i284 < _list283.size; ++_i284) + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list293 = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, iprot.readI32()); + _val292 = new ArrayList<String>(_list293.size); + for (int _i294 = 0; _i294 < _list293.size; ++_i294) { - String _elem285; // required - _elem285 = iprot.readString(); - _val282.add(_elem285); + String _elem295; // required + _elem295 = iprot.readString(); + _val292.add(_elem295); } } - struct.success.put(_key281, _val282); + struct.success.put(_key291, _val292); } } struct.setSuccessIsSet(true); @@ -20345,14 +21785,14 @@ public class Blur { case 2: // SELECTORS if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.LIST) { { - org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list286 = iprot.readListBegin(); - struct.selectors = new ArrayList<Selector>(_list286.size); - for (int _i287 = 0; _i287 < _list286.size; ++_i287) + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list296 = iprot.readListBegin(); + struct.selectors = new ArrayList<Selector>(_list296.size); + for (int _i297 = 0; _i297 < _list296.size; ++_i297) { - Selector _elem288; // required - _elem288 = new Selector(); - _elem288.read(iprot); - struct.selectors.add(_elem288); + Selector _elem298; // required + _elem298 = new Selector(); + _elem298.read(iprot); + struct.selectors.add(_elem298); } iprot.readListEnd(); } @@ -20385,9 +21825,9 @@ public class Blur { oprot.writeFieldBegin(SELECTORS_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.STRUCT, struct.selectors.size())); - for (Selector _iter289 : struct.selectors) + for (Selector _iter299 : struct.selectors) { - _iter289.write(oprot); + _iter299.write(oprot); } oprot.writeListEnd(); } @@ -20424,9 +21864,9 @@ public class Blur { if (struct.isSetSelectors()) { { oprot.writeI32(struct.selectors.size()); - for (Selector _iter290 : struct.selectors) + for (Selector _iter300 : struct.selectors) { - _iter290.write(oprot); + _iter300.write(oprot); } } } @@ -20442,14 +21882,14 @@ public class Blur { } if (incoming.get(1)) { { - org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list291 = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT, iprot.readI32()); - struct.selectors = new ArrayList<Selector>(_list291.size); - for (int _i292 = 0; _i292 < _list291.size; ++_i292) + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list301 = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT, iprot.readI32()); + struct.selectors = new ArrayList<Selector>(_list301.size); + for (int _i302 = 0; _i302 < _list301.size; ++_i302) { - Selector _elem293; // required - _elem293 = new Selector(); - _elem293.read(iprot); - struct.selectors.add(_elem293); + Selector _elem303; // required + _elem303 = new Selector(); + _elem303.read(iprot); + struct.selectors.add(_elem303); } } struct.setSelectorsIsSet(true); @@ -20845,14 +22285,14 @@ 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 _list294 = iprot.readListBegin(); - struct.success = new ArrayList<FetchResult>(_list294.size); - for (int _i295 = 0; _i295 < _list294.size; ++_i295) + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list304 = iprot.readListBegin(); + struct.success = new ArrayList<FetchResult>(_list304.size); + for (int _i305 = 0; _i305 < _list304.size; ++_i305) { - FetchResult _elem296; // required - _elem296 = new FetchResult(); - _elem296.read(iprot); - struct.success.add(_elem296); + FetchResult _elem306; // required + _elem306 = new Fetc
<TRUNCATED>
