http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/64437cf0/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 8edfa10..119b055 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 @@ -109,6 +109,13 @@ public class Blur { public void refresh() throws org.apache.blur.thirdparty.thrift_0_9_0.TException; /** + * Executes command. + * + * @param commandRequest + */ + public void executeCommand(CommandRequest commandRequest) throws org.apache.blur.thirdparty.thrift_0_9_0.TException; + + /** * Creates a table with the given TableDescriptor. * * @param tableDescriptor the TableDescriptor. @@ -566,6 +573,8 @@ public class Blur { 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 executeCommand(CommandRequest commandRequest, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.executeCommand_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; @@ -864,6 +873,18 @@ public class Blur { sendBase("refresh", args); } + public void executeCommand(CommandRequest commandRequest) throws org.apache.blur.thirdparty.thrift_0_9_0.TException + { + send_executeCommand(commandRequest); + } + + public void send_executeCommand(CommandRequest commandRequest) throws org.apache.blur.thirdparty.thrift_0_9_0.TException + { + executeCommand_args args = new executeCommand_args(); + args.setCommandRequest(commandRequest); + sendBase("executeCommand", args); + } + public void createTable(TableDescriptor tableDescriptor) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { send_createTable(tableDescriptor); @@ -2382,6 +2403,37 @@ public class Blur { } } + public void executeCommand(CommandRequest commandRequest, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<executeCommand_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + checkReady(); + executeCommand_call method_call = new executeCommand_call(commandRequest, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class executeCommand_call extends org.apache.blur.thirdparty.thrift_0_9_0.async.TAsyncMethodCall { + private CommandRequest commandRequest; + public executeCommand_call(CommandRequest commandRequest, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<executeCommand_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); + this.commandRequest = commandRequest; + } + + 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("executeCommand", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMessageType.CALL, 0)); + executeCommand_args args = new executeCommand_args(); + args.setCommandRequest(commandRequest); + 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); @@ -4130,6 +4182,7 @@ public class Blur { processMap.put("commandStatus", new commandStatus()); processMap.put("commandCancel", new commandCancel()); processMap.put("refresh", new refresh()); + processMap.put("executeCommand", new executeCommand()); processMap.put("createTable", new createTable()); processMap.put("enableTable", new enableTable()); processMap.put("disableTable", new disableTable()); @@ -4352,6 +4405,25 @@ public class Blur { } } + public static class executeCommand<I extends Iface> extends org.apache.blur.thirdparty.thrift_0_9_0.ProcessFunction<I, executeCommand_args> { + public executeCommand() { + super("executeCommand"); + } + + public executeCommand_args getEmptyArgsInstance() { + return new executeCommand_args(); + } + + protected boolean isOneway() { + return true; + } + + public org.apache.blur.thirdparty.thrift_0_9_0.TBase getResult(I iface, executeCommand_args args) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + iface.executeCommand(args.commandRequest); + 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"); @@ -6223,14 +6295,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 _list290 = iprot.readListBegin(); - struct.success = new ArrayList<CommandDescriptor>(_list290.size); - for (int _i291 = 0; _i291 < _list290.size; ++_i291) + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list306 = iprot.readListBegin(); + struct.success = new ArrayList<CommandDescriptor>(_list306.size); + for (int _i307 = 0; _i307 < _list306.size; ++_i307) { - CommandDescriptor _elem292; // required - _elem292 = new CommandDescriptor(); - _elem292.read(iprot); - struct.success.add(_elem292); + CommandDescriptor _elem308; // required + _elem308 = new CommandDescriptor(); + _elem308.read(iprot); + struct.success.add(_elem308); } iprot.readListEnd(); } @@ -6267,9 +6339,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.STRUCT, struct.success.size())); - for (CommandDescriptor _iter293 : struct.success) + for (CommandDescriptor _iter309 : struct.success) { - _iter293.write(oprot); + _iter309.write(oprot); } oprot.writeListEnd(); } @@ -6308,9 +6380,9 @@ public class Blur { if (struct.isSetSuccess()) { { oprot.writeI32(struct.success.size()); - for (CommandDescriptor _iter294 : struct.success) + for (CommandDescriptor _iter310 : struct.success) { - _iter294.write(oprot); + _iter310.write(oprot); } } } @@ -6325,14 +6397,14 @@ public class Blur { BitSet incoming = iprot.readBitSet(2); if (incoming.get(0)) { { - org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list295 = 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.success = new ArrayList<CommandDescriptor>(_list295.size); - for (int _i296 = 0; _i296 < _list295.size; ++_i296) + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list311 = 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.success = new ArrayList<CommandDescriptor>(_list311.size); + for (int _i312 = 0; _i312 < _list311.size; ++_i312) { - CommandDescriptor _elem297; // required - _elem297 = new CommandDescriptor(); - _elem297.read(iprot); - struct.success.add(_elem297); + CommandDescriptor _elem313; // required + _elem313 = new CommandDescriptor(); + _elem313.read(iprot); + struct.success.add(_elem313); } } struct.setSuccessIsSet(true); @@ -9226,13 +9298,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 _list298 = iprot.readListBegin(); - struct.success = new ArrayList<String>(_list298.size); - for (int _i299 = 0; _i299 < _list298.size; ++_i299) + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list314 = iprot.readListBegin(); + struct.success = new ArrayList<String>(_list314.size); + for (int _i315 = 0; _i315 < _list314.size; ++_i315) { - String _elem300; // required - _elem300 = iprot.readString(); - struct.success.add(_elem300); + String _elem316; // required + _elem316 = iprot.readString(); + struct.success.add(_elem316); } iprot.readListEnd(); } @@ -9269,9 +9341,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 _iter301 : struct.success) + for (String _iter317 : struct.success) { - oprot.writeString(_iter301); + oprot.writeString(_iter317); } oprot.writeListEnd(); } @@ -9310,9 +9382,9 @@ public class Blur { if (struct.isSetSuccess()) { { oprot.writeI32(struct.success.size()); - for (String _iter302 : struct.success) + for (String _iter318 : struct.success) { - oprot.writeString(_iter302); + oprot.writeString(_iter318); } } } @@ -9327,13 +9399,13 @@ public class Blur { BitSet incoming = iprot.readBitSet(2); if (incoming.get(0)) { { - org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list303 = 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>(_list303.size); - for (int _i304 = 0; _i304 < _list303.size; ++_i304) + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list319 = 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>(_list319.size); + for (int _i320 = 0; _i320 < _list319.size; ++_i320) { - String _elem305; // required - _elem305 = iprot.readString(); - struct.success.add(_elem305); + String _elem321; // required + _elem321 = iprot.readString(); + struct.success.add(_elem321); } } struct.setSuccessIsSet(true); @@ -11119,6 +11191,365 @@ public class Blur { } + public static class executeCommand_args implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<executeCommand_args, executeCommand_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("executeCommand_args"); + + private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField COMMAND_REQUEST_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("commandRequest", 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 executeCommand_argsStandardSchemeFactory()); + schemes.put(TupleScheme.class, new executeCommand_argsTupleSchemeFactory()); + } + + public CommandRequest commandRequest; // 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 { + COMMAND_REQUEST((short)1, "commandRequest"); + + 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: // COMMAND_REQUEST + return COMMAND_REQUEST; + 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.COMMAND_REQUEST, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("commandRequest", 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, CommandRequest.class))); + metaDataMap = Collections.unmodifiableMap(tmpMap); + org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData.addStructMetaDataMap(executeCommand_args.class, metaDataMap); + } + + public executeCommand_args() { + } + + public executeCommand_args( + CommandRequest commandRequest) + { + this(); + this.commandRequest = commandRequest; + } + + /** + * Performs a deep copy on <i>other</i>. + */ + public executeCommand_args(executeCommand_args other) { + if (other.isSetCommandRequest()) { + this.commandRequest = new CommandRequest(other.commandRequest); + } + } + + public executeCommand_args deepCopy() { + return new executeCommand_args(this); + } + + @Override + public void clear() { + this.commandRequest = null; + } + + public CommandRequest getCommandRequest() { + return this.commandRequest; + } + + public executeCommand_args setCommandRequest(CommandRequest commandRequest) { + this.commandRequest = commandRequest; + return this; + } + + public void unsetCommandRequest() { + this.commandRequest = null; + } + + /** Returns true if field commandRequest is set (has been assigned a value) and false otherwise */ + public boolean isSetCommandRequest() { + return this.commandRequest != null; + } + + public void setCommandRequestIsSet(boolean value) { + if (!value) { + this.commandRequest = null; + } + } + + public void setFieldValue(_Fields field, Object value) { + switch (field) { + case COMMAND_REQUEST: + if (value == null) { + unsetCommandRequest(); + } else { + setCommandRequest((CommandRequest)value); + } + break; + + } + } + + public Object getFieldValue(_Fields field) { + switch (field) { + case COMMAND_REQUEST: + return getCommandRequest(); + + } + 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 COMMAND_REQUEST: + return isSetCommandRequest(); + } + throw new IllegalStateException(); + } + + @Override + public boolean equals(Object that) { + if (that == null) + return false; + if (that instanceof executeCommand_args) + return this.equals((executeCommand_args)that); + return false; + } + + public boolean equals(executeCommand_args that) { + if (that == null) + return false; + + boolean this_present_commandRequest = true && this.isSetCommandRequest(); + boolean that_present_commandRequest = true && that.isSetCommandRequest(); + if (this_present_commandRequest || that_present_commandRequest) { + if (!(this_present_commandRequest && that_present_commandRequest)) + return false; + if (!this.commandRequest.equals(that.commandRequest)) + return false; + } + + return true; + } + + @Override + public int hashCode() { + return 0; + } + + public int compareTo(executeCommand_args other) { + if (!getClass().equals(other.getClass())) { + return getClass().getName().compareTo(other.getClass().getName()); + } + + int lastComparison = 0; + executeCommand_args typedOther = (executeCommand_args)other; + + lastComparison = Boolean.valueOf(isSetCommandRequest()).compareTo(typedOther.isSetCommandRequest()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetCommandRequest()) { + lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.commandRequest, typedOther.commandRequest); + 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("executeCommand_args("); + boolean first = true; + + sb.append("commandRequest:"); + if (this.commandRequest == null) { + sb.append("null"); + } else { + sb.append(this.commandRequest); + } + 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 + if (commandRequest != null) { + commandRequest.validate(); + } + } + + 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 executeCommand_argsStandardSchemeFactory implements SchemeFactory { + public executeCommand_argsStandardScheme getScheme() { + return new executeCommand_argsStandardScheme(); + } + } + + private static class executeCommand_argsStandardScheme extends StandardScheme<executeCommand_args> { + + public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol iprot, executeCommand_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: // COMMAND_REQUEST + if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT) { + struct.commandRequest = new CommandRequest(); + struct.commandRequest.read(iprot); + struct.setCommandRequestIsSet(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, executeCommand_args struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + struct.validate(); + + oprot.writeStructBegin(STRUCT_DESC); + if (struct.commandRequest != null) { + oprot.writeFieldBegin(COMMAND_REQUEST_FIELD_DESC); + struct.commandRequest.write(oprot); + oprot.writeFieldEnd(); + } + oprot.writeFieldStop(); + oprot.writeStructEnd(); + } + + } + + private static class executeCommand_argsTupleSchemeFactory implements SchemeFactory { + public executeCommand_argsTupleScheme getScheme() { + return new executeCommand_argsTupleScheme(); + } + } + + private static class executeCommand_argsTupleScheme extends TupleScheme<executeCommand_args> { + + @Override + public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, executeCommand_args struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + TTupleProtocol oprot = (TTupleProtocol) prot; + BitSet optionals = new BitSet(); + if (struct.isSetCommandRequest()) { + optionals.set(0); + } + oprot.writeBitSet(optionals, 1); + if (struct.isSetCommandRequest()) { + struct.commandRequest.write(oprot); + } + } + + @Override + public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, executeCommand_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.commandRequest = new CommandRequest(); + struct.commandRequest.read(iprot); + struct.setCommandRequestIsSet(true); + } + } + } + + } + public static class createTable_args implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<createTable_args, createTable_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("createTable_args"); @@ -15693,13 +16124,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 _list306 = iprot.readListBegin(); - struct.success = new ArrayList<String>(_list306.size); - for (int _i307 = 0; _i307 < _list306.size; ++_i307) + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list322 = iprot.readListBegin(); + struct.success = new ArrayList<String>(_list322.size); + for (int _i323 = 0; _i323 < _list322.size; ++_i323) { - String _elem308; // required - _elem308 = iprot.readString(); - struct.success.add(_elem308); + String _elem324; // required + _elem324 = iprot.readString(); + struct.success.add(_elem324); } iprot.readListEnd(); } @@ -15736,9 +16167,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 _iter309 : struct.success) + for (String _iter325 : struct.success) { - oprot.writeString(_iter309); + oprot.writeString(_iter325); } oprot.writeListEnd(); } @@ -15777,9 +16208,9 @@ public class Blur { if (struct.isSetSuccess()) { { oprot.writeI32(struct.success.size()); - for (String _iter310 : struct.success) + for (String _iter326 : struct.success) { - oprot.writeString(_iter310); + oprot.writeString(_iter326); } } } @@ -15794,13 +16225,13 @@ public class Blur { BitSet incoming = iprot.readBitSet(2); if (incoming.get(0)) { { - org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list311 = 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>(_list311.size); - for (int _i312 = 0; _i312 < _list311.size; ++_i312) + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list327 = 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>(_list327.size); + for (int _i328 = 0; _i328 < _list327.size; ++_i328) { - String _elem313; // required - _elem313 = iprot.readString(); - struct.success.add(_elem313); + String _elem329; // required + _elem329 = iprot.readString(); + struct.success.add(_elem329); } } struct.setSuccessIsSet(true); @@ -16567,13 +16998,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 _list314 = iprot.readListBegin(); - struct.success = new ArrayList<String>(_list314.size); - for (int _i315 = 0; _i315 < _list314.size; ++_i315) + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list330 = iprot.readListBegin(); + struct.success = new ArrayList<String>(_list330.size); + for (int _i331 = 0; _i331 < _list330.size; ++_i331) { - String _elem316; // required - _elem316 = iprot.readString(); - struct.success.add(_elem316); + String _elem332; // required + _elem332 = iprot.readString(); + struct.success.add(_elem332); } iprot.readListEnd(); } @@ -16610,9 +17041,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 _iter317 : struct.success) + for (String _iter333 : struct.success) { - oprot.writeString(_iter317); + oprot.writeString(_iter333); } oprot.writeListEnd(); } @@ -16651,9 +17082,9 @@ public class Blur { if (struct.isSetSuccess()) { { oprot.writeI32(struct.success.size()); - for (String _iter318 : struct.success) + for (String _iter334 : struct.success) { - oprot.writeString(_iter318); + oprot.writeString(_iter334); } } } @@ -16668,13 +17099,13 @@ public class Blur { BitSet incoming = iprot.readBitSet(2); if (incoming.get(0)) { { - org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list319 = 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>(_list319.size); - for (int _i320 = 0; _i320 < _list319.size; ++_i320) + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list335 = 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>(_list335.size); + for (int _i336 = 0; _i336 < _list335.size; ++_i336) { - String _elem321; // required - _elem321 = iprot.readString(); - struct.success.add(_elem321); + String _elem337; // required + _elem337 = iprot.readString(); + struct.success.add(_elem337); } } struct.setSuccessIsSet(true); @@ -23310,25 +23741,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 _map322 = iprot.readMapBegin(); - struct.success = new HashMap<String,List<String>>(2*_map322.size); - for (int _i323 = 0; _i323 < _map322.size; ++_i323) + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap _map338 = iprot.readMapBegin(); + struct.success = new HashMap<String,List<String>>(2*_map338.size); + for (int _i339 = 0; _i339 < _map338.size; ++_i339) { - String _key324; // required - List<String> _val325; // required - _key324 = iprot.readString(); + String _key340; // required + List<String> _val341; // required + _key340 = iprot.readString(); { - org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list326 = iprot.readListBegin(); - _val325 = new ArrayList<String>(_list326.size); - for (int _i327 = 0; _i327 < _list326.size; ++_i327) + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list342 = iprot.readListBegin(); + _val341 = new ArrayList<String>(_list342.size); + for (int _i343 = 0; _i343 < _list342.size; ++_i343) { - String _elem328; // required - _elem328 = iprot.readString(); - _val325.add(_elem328); + String _elem344; // required + _elem344 = iprot.readString(); + _val341.add(_elem344); } iprot.readListEnd(); } - struct.success.put(_key324, _val325); + struct.success.put(_key340, _val341); } iprot.readMapEnd(); } @@ -23365,14 +23796,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>> _iter329 : struct.success.entrySet()) + for (Map.Entry<String, List<String>> _iter345 : struct.success.entrySet()) { - oprot.writeString(_iter329.getKey()); + oprot.writeString(_iter345.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, _iter329.getValue().size())); - for (String _iter330 : _iter329.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, _iter345.getValue().size())); + for (String _iter346 : _iter345.getValue()) { - oprot.writeString(_iter330); + oprot.writeString(_iter346); } oprot.writeListEnd(); } @@ -23414,14 +23845,14 @@ public class Blur { if (struct.isSetSuccess()) { { oprot.writeI32(struct.success.size()); - for (Map.Entry<String, List<String>> _iter331 : struct.success.entrySet()) + for (Map.Entry<String, List<String>> _iter347 : struct.success.entrySet()) { - oprot.writeString(_iter331.getKey()); + oprot.writeString(_iter347.getKey()); { - oprot.writeI32(_iter331.getValue().size()); - for (String _iter332 : _iter331.getValue()) + oprot.writeI32(_iter347.getValue().size()); + for (String _iter348 : _iter347.getValue()) { - oprot.writeString(_iter332); + oprot.writeString(_iter348); } } } @@ -23438,24 +23869,24 @@ public class Blur { BitSet incoming = iprot.readBitSet(2); if (incoming.get(0)) { { - org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap _map333 = 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*_map333.size); - for (int _i334 = 0; _i334 < _map333.size; ++_i334) + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap _map349 = 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*_map349.size); + for (int _i350 = 0; _i350 < _map349.size; ++_i350) { - String _key335; // required - List<String> _val336; // required - _key335 = iprot.readString(); + String _key351; // required + List<String> _val352; // required + _key351 = iprot.readString(); { - org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list337 = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, iprot.readI32()); - _val336 = new ArrayList<String>(_list337.size); - for (int _i338 = 0; _i338 < _list337.size; ++_i338) + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list353 = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, iprot.readI32()); + _val352 = new ArrayList<String>(_list353.size); + for (int _i354 = 0; _i354 < _list353.size; ++_i354) { - String _elem339; // required - _elem339 = iprot.readString(); - _val336.add(_elem339); + String _elem355; // required + _elem355 = iprot.readString(); + _val352.add(_elem355); } } - struct.success.put(_key335, _val336); + struct.success.put(_key351, _val352); } } struct.setSuccessIsSet(true); @@ -26147,14 +26578,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 _list340 = iprot.readListBegin(); - struct.selectors = new ArrayList<Selector>(_list340.size); - for (int _i341 = 0; _i341 < _list340.size; ++_i341) + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list356 = iprot.readListBegin(); + struct.selectors = new ArrayList<Selector>(_list356.size); + for (int _i357 = 0; _i357 < _list356.size; ++_i357) { - Selector _elem342; // required - _elem342 = new Selector(); - _elem342.read(iprot); - struct.selectors.add(_elem342); + Selector _elem358; // required + _elem358 = new Selector(); + _elem358.read(iprot); + struct.selectors.add(_elem358); } iprot.readListEnd(); } @@ -26187,9 +26618,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 _iter343 : struct.selectors) + for (Selector _iter359 : struct.selectors) { - _iter343.write(oprot); + _iter359.write(oprot); } oprot.writeListEnd(); } @@ -26226,9 +26657,9 @@ public class Blur { if (struct.isSetSelectors()) { { oprot.writeI32(struct.selectors.size()); - for (Selector _iter344 : struct.selectors) + for (Selector _iter360 : struct.selectors) { - _iter344.write(oprot); + _iter360.write(oprot); } } } @@ -26244,14 +26675,14 @@ public class Blur { } if (incoming.get(1)) { { - org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list345 = 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>(_list345.size); - for (int _i346 = 0; _i346 < _list345.size; ++_i346) + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list361 = 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>(_list361.size); + for (int _i362 = 0; _i362 < _list361.size; ++_i362) { - Selector _elem347; // required - _elem347 = new Selector(); - _elem347.read(iprot); - struct.selectors.add(_elem347); + Selector _elem363; // required + _elem363 = new Selector(); + _elem363.read(iprot); + struct.selectors.add(_elem363); } } struct.setSelectorsIsSet(true); @@ -26647,14 +27078,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 _list348 = iprot.readListBegin(); - struct.success = new ArrayList<FetchResult>(_list348.size); - for (int _i349 = 0; _i349 < _list348.size; ++_i349) + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list364 = iprot.readListBegin(); + struct.success = new ArrayList<FetchResult>(_list364.size); + for (int _i365 = 0; _i365 < _list364.size; ++_i365) { - FetchResult _elem350; // required - _elem350 = new FetchResult(); - _elem350.read(iprot); - struct.success.add(_elem350); + FetchResult _elem366; // required + _elem366 = new FetchResult(); + _elem366.read(iprot); + struct.success.add(_elem366); } iprot.readListEnd(); } @@ -26691,9 +27122,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.STRUCT, struct.success.size())); - for (FetchResult _iter351 : struct.success) + for (FetchResult _iter367 : struct.success) { - _iter351.write(oprot); + _iter367.write(oprot); } oprot.writeListEnd(); } @@ -26732,9 +27163,9 @@ public class Blur { if (struct.isSetSuccess()) { { oprot.writeI32(struct.success.size()); - for (FetchResult _iter352 : struct.success) + for (FetchResult _iter368 : struct.success) { - _iter352.write(oprot); + _iter368.write(oprot); } } } @@ -26749,14 +27180,14 @@ public class Blur { BitSet incoming = iprot.readBitSet(2); if (incoming.get(0)) { { - org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list353 = 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.success = new ArrayList<FetchResult>(_list353.size); - for (int _i354 = 0; _i354 < _list353.size; ++_i354) + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list369 = 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.success = new ArrayList<FetchResult>(_list369.size); + for (int _i370 = 0; _i370 < _list369.size; ++_i370) { - FetchResult _elem355; // required - _elem355 = new FetchResult(); - _elem355.read(iprot); - struct.success.add(_elem355); + FetchResult _elem371; // required + _elem371 = new FetchResult(); + _elem371.read(iprot); + struct.success.add(_elem371); } } struct.setSuccessIsSet(true); @@ -27999,13 +28430,13 @@ public class Blur { case 2: // EXTERNAL_INDEX_PATHS if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.LIST) { { - org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list356 = iprot.readListBegin(); - struct.externalIndexPaths = new ArrayList<String>(_list356.size); - for (int _i357 = 0; _i357 < _list356.size; ++_i357) + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list372 = iprot.readListBegin(); + struct.externalIndexPaths = new ArrayList<String>(_list372.size); + for (int _i373 = 0; _i373 < _list372.size; ++_i373) { - String _elem358; // required - _elem358 = iprot.readString(); - struct.externalIndexPaths.add(_elem358); + String _elem374; // required + _elem374 = iprot.readString(); + struct.externalIndexPaths.add(_elem374); } iprot.readListEnd(); } @@ -28038,9 +28469,9 @@ public class Blur { oprot.writeFieldBegin(EXTERNAL_INDEX_PATHS_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.externalIndexPaths.size())); - for (String _iter359 : struct.externalIndexPaths) + for (String _iter375 : struct.externalIndexPaths) { - oprot.writeString(_iter359); + oprot.writeString(_iter375); } oprot.writeListEnd(); } @@ -28077,9 +28508,9 @@ public class Blur { if (struct.isSetExternalIndexPaths()) { { oprot.writeI32(struct.externalIndexPaths.size()); - for (String _iter360 : struct.externalIndexPaths) + for (String _iter376 : struct.externalIndexPaths) { - oprot.writeString(_iter360); + oprot.writeString(_iter376); } } } @@ -28095,13 +28526,13 @@ public class Blur { } if (incoming.get(1)) { { - org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list361 = 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.externalIndexPaths = new ArrayList<String>(_list361.size); - for (int _i362 = 0; _i362 < _list361.size; ++_i362) + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list377 = 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.externalIndexPaths = new ArrayList<String>(_list377.size); + for (int _i378 = 0; _i378 < _list377.size; ++_i378) { - String _elem363; // required - _elem363 = iprot.readString(); - struct.externalIndexPaths.add(_elem363); + String _elem379; // required + _elem379 = iprot.readString(); + struct.externalIndexPaths.add(_elem379); } } struct.setExternalIndexPathsIsSet(true); @@ -28861,13 +29292,13 @@ public class Blur { case 2: // EXTERNAL_INDEX_PATHS if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.LIST) { { - org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list364 = iprot.readListBegin(); - struct.externalIndexPaths = new ArrayList<String>(_list364.size); - for (int _i365 = 0; _i365 < _list364.size; ++_i365) + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list380 = iprot.readListBegin(); + struct.externalIndexPaths = new ArrayList<String>(_list380.size); + for (int _i381 = 0; _i381 < _list380.size; ++_i381) { - String _elem366; // required - _elem366 = iprot.readString(); - struct.externalIndexPaths.add(_elem366); + String _elem382; // required + _elem382 = iprot.readString(); + struct.externalIndexPaths.add(_elem382); } iprot.readListEnd(); } @@ -28900,9 +29331,9 @@ public class Blur { oprot.writeFieldBegin(EXTERNAL_INDEX_PATHS_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.externalIndexPaths.size())); - for (String _iter367 : struct.externalIndexPaths) + for (String _iter383 : struct.externalIndexPaths) { - oprot.writeString(_iter367); + oprot.writeString(_iter383); } oprot.writeListEnd(); } @@ -28939,9 +29370,9 @@ public class Blur { if (struct.isSetExternalIndexPaths()) { { oprot.writeI32(struct.externalIndexPaths.size()); - for (String _iter368 : struct.externalIndexPaths) + for (String _iter384 : struct.externalIndexPaths) { - oprot.writeString(_iter368); + oprot.writeString(_iter384); } } } @@ -28957,13 +29388,13 @@ public class Blur { } if (incoming.get(1)) { { - org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list369 = 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.externalIndexPaths = new ArrayList<String>(_list369.size); - for (int _i370 = 0; _i370 < _list369.size; ++_i370) + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list385 = 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.externalIndexPaths = new ArrayList<String>(_list385.size); + for (int _i386 = 0; _i386 < _list385.size; ++_i386) { - String _elem371; // required - _elem371 = iprot.readString(); - struct.externalIndexPaths.add(_elem371); + String _elem387; // required + _elem387 = iprot.readString(); + struct.externalIndexPaths.add(_elem387); } } struct.setExternalIndexPathsIsSet(true); @@ -31104,14 +31535,14 @@ public class Blur { case 1: // MUTATIONS if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.LIST) { { - org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list372 = iprot.readListBegin(); - struct.mutations = new ArrayList<RowMutation>(_list372.size); - for (int _i373 = 0; _i373 < _list372.size; ++_i373) + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list388 = iprot.readListBegin(); + struct.mutations = new ArrayList<RowMutation>(_list388.size); + for (int _i389 = 0; _i389 < _list388.size; ++_i389) { - RowMutation _elem374; // required - _elem374 = new RowMutation(); - _elem374.read(iprot); - struct.mutations.add(_elem374); + RowMutation _elem390; // required + _elem390 = new RowMutation(); + _elem390.read(iprot); + struct.mutations.add(_elem390); } iprot.readListEnd(); } @@ -31139,9 +31570,9 @@ public class Blur { oprot.writeFieldBegin(MUTATIONS_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.mutations.size())); - for (RowMutation _iter375 : struct.mutations) + for (RowMutation _iter391 : struct.mutations) { - _iter375.write(oprot); + _iter391.write(oprot); } oprot.writeListEnd(); } @@ -31172,9 +31603,9 @@ public class Blur { if (struct.isSetMutations()) { { oprot.writeI32(struct.mutations.size()); - for (RowMutation _iter376 : struct.mutations) + for (RowMutation _iter392 : struct.mutations) { - _iter376.write(oprot); + _iter392.write(oprot); } } } @@ -31186,14 +31617,14 @@ public class Blur { BitSet incoming = iprot.readBitSet(1); if (incoming.get(0)) { { - org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list377 = 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.mutations = new ArrayList<RowMutation>(_list377.size); - for (int _i378 = 0; _i378 < _list377.size; ++_i378) + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list393 = 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.mutations = new ArrayList<RowMutation>(_list393.size); + for (int _i394 = 0; _i394 < _list393.size; ++_i394) { - RowMutation _elem379; // required - _elem379 = new RowMutation(); - _elem379.read(iprot); - struct.mutations.add(_elem379); + RowMutation _elem395; // required + _elem395 = new RowMutation(); + _elem395.read(iprot); + struct.mutations.add(_elem395); } } struct.setMutationsIsSet(true); @@ -31880,14 +32311,14 @@ public class Blur { case 1: // MUTATIONS if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.LIST) { { - org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list380 = iprot.readListBegin(); - struct.mutations = new ArrayList<RowMutation>(_list380.size); - for (int _i381 = 0; _i381 < _list380.size; ++_i381) + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list396 = iprot.readListBegin(); + struct.mutations = new ArrayList<RowMutation>(_list396.size); + for (int _i397 = 0; _i397 < _list396.size; ++_i397) { - RowMutation _elem382; // required - _elem382 = new RowMutation(); - _elem382.read(iprot); - struct.mutations.add(_elem382); + RowMutation _elem398; // required + _elem398 = new RowMutation(); + _elem398.read(iprot); + struct.mutations.add(_elem398); } iprot.readListEnd(); } @@ -31915,9 +32346,9 @@ public class Blur { oprot.writeFieldBegin(MUTATIONS_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.mutations.size())); - for (RowMutation _iter383 : struct.mutations) + for (RowMutation _iter399 : struct.mutations) { - _iter383.write(oprot); + _iter399.write(oprot); } oprot.writeListEnd(); } @@ -31948,9 +32379,9 @@ public class Blur { if (struct.isSetMutations()) { { oprot.writeI32(struct.mutations.size()); - for (RowMutation _iter384 : struct.mutations) + for (RowMutation _iter400 : struct.mutations) { - _iter384.write(oprot); + _iter400.write(oprot); } } } @@ -31962,14 +32393,14 @@ public class Blur { BitSet incoming = iprot.readBitSet(1); if (incoming.get(0)) { { - org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list385 = 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.mutations = new ArrayList<RowMutation>(_list385.size); - for (int _i386 = 0; _i386 < _list385.size; ++_i386) + 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.STRUCT, iprot.readI32()); + struct.mutations = new ArrayList<RowMutation>(_list401.size); + for (int _i402 = 0; _i402 < _list401.size; ++_i402) { - RowMutation _elem387; // required - _elem387 = new RowMutation(); - _elem387.read(iprot); - struct.mutations.add(_elem387); + RowMutation _elem403; // required + _elem403 = new RowMutation(); + _elem403.read(iprot); + struct.mutations.add(_elem403); } } struct.setMutationsIsSet(true); @@ -34314,14 +34745,14 @@ public class Blur { case 2: // ROW_MUTATIONS if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.LIST) { { - org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list388 = iprot.readListBegin(); - struct.rowMutations = new ArrayList<RowMutation>(_list388.size); - for (int _i389 = 0; _i389 < _list388.size; ++_i389) + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list404 = iprot.readListBegin(); + struct.rowMutations = new ArrayList<RowMutation>(_list404.size); + for (int _i405 = 0; _i405 < _list404.size; ++_i405) { - RowMutation _elem390; // required - _elem390 = new RowMutation(); - _elem390.read(iprot); - struct.rowMutations.add(_elem390); + RowMutation _elem406; // required + _elem406 = new RowMutation(); + _elem406.read(iprot); + struct.rowMutations.add(_elem406); } iprot.readListEnd(); } @@ -34354,9 +34785,9 @@ public class Blur { oprot.writeFieldBegin(ROW_MUTATIONS_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.rowMutations.size())); - for (RowMutation _iter391 : struct.rowMutations) + for (RowMutation _iter407 : struct.rowMutations) { - _iter391.write(oprot); + _iter407.write(oprot); } oprot.writeListEnd(); } @@ -34393,9 +34824,9 @@ public class Blur { if (struct.isSetRowMutations()) { { oprot.writeI32(struct.rowMutations.size()); - for (RowMutation _iter392 : struct.rowMutations) + for (RowMutation _iter408 : struct.rowMutations) { - _iter392.write(oprot); + _iter408.write(oprot); } } } @@ -34411,14 +34842,14 @@ public class Blur { } if (incoming.get(1)) { { - org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list393 = 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.rowMutations = new ArrayList<RowMutation>(_list393.size); - for (int _i394 = 0; _i394 < _list393.size; ++_i394) + 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.STRUCT, iprot.readI32()); + struct.rowMutations = new ArrayList<RowMutation>(_list409.size); + for (int _i410 = 0; _i410 < _list409.size; ++_i410) { - RowMutation _elem395; // required - _elem395 = new RowMutation(); - _elem395.read(iprot); - struct.rowMutations.add(_elem395); + RowMutation _elem411; // required + _elem411 = new RowMutation(); + _elem411.read(iprot); + struct.rowMutations.add(_elem411); } } struct.setRowMutationsIsSet(true); @@ -37308,13 +37739,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 _list412 = iprot.readListBegin(); + struct.success = new ArrayList<String>(_list412.size); + for (int _i413 = 0; _i413 < _list412.size; ++_i413) { - String _elem398; // required - _elem398 = iprot.readString(); - struct.success.add(_elem398); + String _elem414; // required + _elem414 = iprot.readString(); + struct.success.add(_elem414); } iprot.readListEnd(); } @@ -37351,9 +37782,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 _iter415 : struct.success) { - oprot.writeString(_iter399); + oprot.writeString(_iter415); } oprot.writeListEnd(); } @@ -37392,9 +37823,9 @@ public class Blur { if (struct.isSetSuccess()) { { oprot.writeI32(struct.success.size()); - for (String _iter400 : struct.success) + for (String _iter416 : struct.success) { - oprot.writeString(_iter400); + oprot.writeString(_iter416); } } } @@ -37409,13 +37840,13 @@ public class Blur { 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 _list417 = 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>(_list417.size); + for (int _i418 = 0; _i418 < _list417.size; ++_i418) { - String _elem403; // required - _elem403 = iprot.readString(); - struct.success.add(_elem403); + String _elem419; // required + _elem419 = iprot.readString(); + struct.success.add(_elem419); } } struct.setSuccessIsSet(true); @@ -39567,13 +39998,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 _list404 = iprot.readListBegin(); - struct.success = new ArrayList<String>(_list404.size); - for (int _i405 = 0; _i405 < _list404.size; ++_i405) + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list420 = iprot.readListBegin(); + struct.success = new ArrayList<String>(_list420.size); + for (int _i421 = 0; _i421 < _list420.size; ++_i421) { - String _elem406; // required - _elem406 = iprot.readString(); - struct.success.add(_elem406); + String _elem422; // required + _elem422 = iprot.readString(); + struct.success.add(_elem422); } iprot.readListEnd(); } @@ -39610,9 +40041,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 _iter407 : struct.success) + for (String _iter423 : struct.success) { - oprot.writeString(_iter407); + oprot.writeString(_iter423); } oprot.writeListEnd(); } @@ -39651,9 +40082,9 @@ public class Blur { if (struct.isSetSuccess()) { { oprot.writeI32(struct.success.size()); - for (String _iter408 : struct.success) + for (String _iter424 : struct.success) { - oprot.writeString(_iter408); + oprot.writeString(_iter424); } } } @@ -39668,13 +40099,13 @@ public class Blur { BitSet incoming = iprot.readBitSet(2); if (incoming.get(0)) { { - 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) + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list425 = 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>(_list425.size); + for (int _i426 = 0; _i426 < _list425.size; ++_i426) { - String _elem411; // required - _elem411 = iprot.readString(); - struct.success.add(_elem411); + String _elem427; // required + _elem427 = iprot.readString(); + struct.success.add(_elem427); } } struct.setSuccessIsSet(true); @@ -41479,13 +41910,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 _list412 = iprot.readListBegin(); - struct.success = new ArrayList<String>(_list412.size); - for (int _i413 = 0; _i413 < _list412.size; ++_i413) + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list428 = iprot.readListBegin(); + struct.success = new ArrayList<String>(_list428.size); + for (int _i429 = 0; _i429 < _list428.size; ++_i429) { - String _elem414; // required - _elem414 = iprot.readString(); - struct.success.add(_elem414); + String _elem430; // required + _elem430 = iprot.readString(); + struct.success.add(_elem430); } iprot.readListEnd(); } @@ -41522,9 +41953,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 _iter415 : struct.success) + for (String _iter431 : struct.success) { - oprot.writeString(_iter415); + oprot.writeString(_iter431); } oprot.writeListEnd(); } @@ -41563,9 +41994,9 @@ public class Blur { if (struct.isSetSuccess()) { { oprot.writeI32(struct.success.size()); - for (String _iter416 : struct.success) + for (String _iter432 : struct.success) { - oprot.writeString(_iter416); + oprot.writeString(_iter432); } } } @@ -41580,13 +42011,13 @@ public class Blur { BitSet incoming = iprot.readBitSet(2); if (incoming.get(0)) { { - org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list417 = 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>(_list417.size); - for (int _i418 = 0; _i418 < _list417.size; ++_i418) + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list433 = 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>(_list433.size); + for (int _i434 = 0; _i434 < _list433.size; ++_i434) { - String _elem419; // required - _elem419 = iprot.readString(); - struct.success.add(_elem419); + String _elem435; // required + _elem435 = iprot.readString(); + struct.success.add(_elem435); } } struct.setSuccessIsSet(true); @@ -42353,13 +42784,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 _list420 = iprot.readListBegin(); - struct.success = new ArrayList<String>(_list420.size); - for (int _i421 = 0; _i421 < _list420.size; ++_i421) + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list436 = iprot.readListBegin(); + struct.success = new ArrayList<String>(_list436.size); + for (int _i437 = 0; _i437 < _list436.size; ++_i437) { - String _elem422; // required - _elem422 = iprot.readString(); - struct.success.add(_elem422); + String _elem438; // required + _elem438 = iprot.readString(); + struct.success.add(_elem438); } iprot.readListEnd(); } @@ -42396,9 +42827,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 _iter423 : struct.success) + for (String _iter439 : struct.success) { - oprot.writeString(_iter423); + oprot.writeString(_iter439); } oprot.writeListEnd(); } @@ -42437,9 +42868,9 @@ public class Blur { if (struct.isSetSuccess()) { { oprot.writeI32(struct.success.size()); - for (String _iter424 : struct.success) + for (String _iter440 : struct.success) { - oprot.writeString(_iter424); + oprot.writeString(_iter440); } } } @@ -42454,13 +42885,13 @@ public class Blur { BitSet incoming = iprot.readBitSet(2); if (incoming.get(0)) { { - org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list425 = 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>(_list425.size); - for (int _i426 = 0; _i426 < _list425.size; ++_i426) + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list441 = 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>(_list441.size); + for (int _i442 = 0; _i442 < _list441.size; ++_i442) { - String _elem427; // required - _elem427 = iprot.readString(); - struct.success.add(_elem427); + String _elem443; // required + _elem443 = iprot.readString(); + struct.success.add(_elem443); } } struct.setSuccessIsSet(true); @@ -43107,13 +43538,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 _list428 = iprot.readListBegin(); - struct.success = new ArrayList<String>(_list428.size); - for (int _i429 = 0; _i429 < _list428.size; ++_i429) + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list444 = iprot.readListBegin(); + struct.success = new ArrayList<String>(_list444.size); + for (int _i445 = 0; _i445 < _list444.size; ++_i445) { - String _elem430; // required - _elem430 = iprot.readString(); - struct.success.add(_elem430); + String _elem446; // required + _elem446 = iprot.readString(); + struct.success.add(_elem446); } iprot.readListEnd(); } @@ -43150,9 +43581,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 _iter431 : struct.success) + for (String _iter447 : struct.success) { - oprot.writeString(_iter431); + oprot.writeString(_iter447); } oprot.writeListEnd(); } @@ -43191,9 +43622,9 @@ public class Blur { if (struct.isSetSuccess()) { { oprot.writeI32(struct.success.size()); - for (String _iter432 : struct.success) + for (String _iter448 : struct.success) { - oprot.writeString(_iter432); + oprot.writeString(_iter448); } } } @@ -43208,13 +43639,13 @@ public class Blur { BitSet incoming = iprot.readBitSet(2); if (incoming.get(0)) { { - org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list433 = 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>(_list433.size); - for (int _i434 = 0; _i434 < _list433.size; ++_i434) + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list449 = 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>(_list449.size); + for (int _i450 = 0; _i450 < _list449.size; ++_i450) { - String _elem435; // required - _elem435 = iprot.readString(); - struct.success.add(_elem435); + String _elem451; // required + _elem451 = iprot.readString(); + struct.success.add(_elem451); } } struct.setSuccessIsSet(true); @@ -43986,15 +44417,15 @@ 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 _map436 = iprot.readMapBegin(); - struct.success = new HashMap<String,String>(2*_map436.size); - for (int _i437 = 0; _i437 < _map436.size; ++_i437) + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap _map452 = iprot.readMapBegin(); + struct.success = new HashMap<String,String>(2*_map452.size); + for (int _i453 = 0; _i453 < _map452.size; ++_i453) { - String _key438; // required - String _val439; // required - _key438 = iprot.readString(); - _val439 = iprot.readString(); - struct.success.put(_key438, _val439); + String _key454; // required + String _val455; // required + _key454 = iprot.readString(); + _val455 = iprot.readString(); + struct.success.put(_key454, _val455); } iprot.readMapEnd(); } @@ -44031,10 +44462,10 @@ 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.STRING, struct.success.size())); - for (Map.Entry<String, String> _iter440 : struct.success.entrySet()) + for (Map.Entry<String, String> _iter456 : struct.success.entrySet()) { - oprot.writeString(_iter440.getKey()); - oprot.writeString(_iter440.getValue()); + oprot.writeString(_iter456.getKey()); + oprot.writeString(_iter456.getValue()); } oprot.writeMapEnd(); } @@ -44073,10 +44504,10 @@ public class Blur { if (struct.isSetSuccess()) { { oprot.writeI32(struct.success.size()); - for (Map.Entry<String, String> _iter441 : struct.success.entrySet()) + for (Map.Entry<String, String> _iter457 : struct.success.entrySet()) { - oprot.writeString(_iter441.getKey()); - oprot.writeString(_iter441.getValue()); + oprot.writeString(_iter457.getKey()); + oprot.writeString(_iter457.getValue()); } } } @@ -44091,15 +44522,15 @@ public class Blur { BitSet incoming = iprot.readBitSet(2); if (incoming.get(0)) { { - org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap _map442 = 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.STRING, iprot.readI32()); - struct.success = new HashMap<String,String>(2*_map442.size); - for (int _i443 = 0; _i443 < _map442.size; ++_i443) + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap _map458 = 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.STRING, iprot.readI32()); + struct.success = new HashMap<String,String>(2*_map458.size); + for (int _i459 = 0; _i459 < _map458.size; ++_i459) { - String _key444; // required - String _val445; // required - _key444 = iprot.readString(); - _val445 = iprot.readString(); - struct.success.put(_key444, _val445); + String _key460; // required + String _val461; // required + _key460 = iprot.readString(); + _val461 = iprot.readString(); + struct.success.put(_key460, _val461); } } struct.setSuccessIsSet(true); @@ -44884,27 +45315,27 @@ 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 _map446 = iprot.readMapBegin(); - struct.success = new HashMap<String,Map<String,ShardState>>(2*_map446.size); - for (int _i447 = 0; _i447 < _map446.size; ++_i447) + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap _map462 = iprot.readMapBegin(); + struct.success = new HashMap<String,Map<String,ShardState>>(2*_map462.size); + for (int _i463 = 0; _i463 < _map462.size; ++_i463) { - String _key448; // required - Map<String,ShardState> _val449; // required - _key448 = iprot.readString(); + String _key464; // required + Map<String,ShardState> _val465; // required + _key464 = iprot.readString(); { - org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap _map450 = iprot.readMapBegin(); - _val449 = new HashMap<String,ShardState>(2*_map450.size); - for (int _i451 = 0; _i451 < _map450.size; ++_i451) + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap _map466 = iprot.readMapBegin(); + _val465 = new HashMap<String,ShardState>(2*_map466.size); + for (int _i467 = 0; _i467 < _map466.size; ++_i467) { - String _key452; // required - ShardState _val453; // required - _key452 = iprot.readString(); - _val453 = ShardState.findByValue(iprot.readI32()); - _val449.put(_key452, _val453); + String _key468; // required + ShardState _val469; // required + _key468 = iprot.readString(); + _val469 = ShardState.findByValue(iprot.readI32()); + _val465.put(_key468, _val469); } iprot.readMapEnd(); } - struct.success.put(_key448, _val449); + struct.success.put(_key464, _val465); } iprot.readMapEnd(); } @@ -44941,15 +45372,15 @@ 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.MAP, struct.success.size())); - for (Map.Entry<String, Map<String,ShardState>> _iter454 : struct.success.entrySet()) + for (Map.Entry<String, Map<String,ShardState>> _iter470 : struct.success.entrySet()) { - oprot.writeString(_iter454.getKey()); + oprot.writeString(_iter470.getKey()); { - 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.I32, _iter454.getValue().size())); - for (Map.Entry<String, ShardState> _iter455 : _iter454.getValue().entrySet()) + 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.I32, _iter470.getValue().size())); + for (Map.Entry<S
<TRUNCATED>
