incubator-blur-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From amccu...@apache.org
Subject [5/6] Adding thrift api calls for getting status of executing commands and the cancel api as well.
Date Mon, 08 Sep 2014 12:48:43 GMT
http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/77a4f849/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 674238d..285c697 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
@@ -76,6 +76,29 @@ public class Blur {
     public Response reconnect(String executionId) throws BlurException, TimeoutException, org.apache.blur.thirdparty.thrift_0_9_0.TException;
 
     /**
+     * Fetches the command status ids in the order they were submitted.
+     * 
+     * @param startingAt
+     * @param fetch
+     * @param state
+     */
+    public List<String> commandStatusList(int startingAt, short fetch, CommandStatusState state) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException;
+
+    /**
+     * Retrieves the command status by the given execution id.
+     * 
+     * @param executionId
+     */
+    public CommandStatus commandStatus(String executionId) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException;
+
+    /**
+     * Cancels the command with the given execution id.
+     * 
+     * @param executionId
+     */
+    public void commandCancel(String executionId) throws BlurException, 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.
      */
@@ -471,6 +494,12 @@ public class Blur {
 
     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 commandStatusList(int startingAt, short fetch, CommandStatusState state, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.commandStatusList_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException;
+
+    public void commandStatus(String executionId, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.commandStatus_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException;
+
+    public void commandCancel(String executionId, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.commandCancel_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;
@@ -643,6 +672,83 @@ public class Blur {
       throw new org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException(org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException.MISSING_RESULT, "reconnect failed: unknown result");
     }
 
+    public List<String> commandStatusList(int startingAt, short fetch, CommandStatusState state) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException
+    {
+      send_commandStatusList(startingAt, fetch, state);
+      return recv_commandStatusList();
+    }
+
+    public void send_commandStatusList(int startingAt, short fetch, CommandStatusState state) throws org.apache.blur.thirdparty.thrift_0_9_0.TException
+    {
+      commandStatusList_args args = new commandStatusList_args();
+      args.setStartingAt(startingAt);
+      args.setFetch(fetch);
+      args.setState(state);
+      sendBase("commandStatusList", args);
+    }
+
+    public List<String> recv_commandStatusList() throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException
+    {
+      commandStatusList_result result = new commandStatusList_result();
+      receiveBase(result, "commandStatusList");
+      if (result.isSetSuccess()) {
+        return result.success;
+      }
+      if (result.ex != null) {
+        throw result.ex;
+      }
+      throw new org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException(org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException.MISSING_RESULT, "commandStatusList failed: unknown result");
+    }
+
+    public CommandStatus commandStatus(String executionId) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException
+    {
+      send_commandStatus(executionId);
+      return recv_commandStatus();
+    }
+
+    public void send_commandStatus(String executionId) throws org.apache.blur.thirdparty.thrift_0_9_0.TException
+    {
+      commandStatus_args args = new commandStatus_args();
+      args.setExecutionId(executionId);
+      sendBase("commandStatus", args);
+    }
+
+    public CommandStatus recv_commandStatus() throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException
+    {
+      commandStatus_result result = new commandStatus_result();
+      receiveBase(result, "commandStatus");
+      if (result.isSetSuccess()) {
+        return result.success;
+      }
+      if (result.ex != null) {
+        throw result.ex;
+      }
+      throw new org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException(org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException.MISSING_RESULT, "commandStatus failed: unknown result");
+    }
+
+    public void commandCancel(String executionId) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException
+    {
+      send_commandCancel(executionId);
+      recv_commandCancel();
+    }
+
+    public void send_commandCancel(String executionId) throws org.apache.blur.thirdparty.thrift_0_9_0.TException
+    {
+      commandCancel_args args = new commandCancel_args();
+      args.setExecutionId(executionId);
+      sendBase("commandCancel", args);
+    }
+
+    public void recv_commandCancel() throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException
+    {
+      commandCancel_result result = new commandCancel_result();
+      receiveBase(result, "commandCancel");
+      if (result.ex != null) {
+        throw result.ex;
+      }
+      return;
+    }
+
     public void refresh() throws org.apache.blur.thirdparty.thrift_0_9_0.TException
     {
       send_refresh();
@@ -1821,6 +1927,108 @@ public class Blur {
       }
     }
 
+    public void commandStatusList(int startingAt, short fetch, CommandStatusState state, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<commandStatusList_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+      checkReady();
+      commandStatusList_call method_call = new commandStatusList_call(startingAt, fetch, state, resultHandler, this, ___protocolFactory, ___transport);
+      this.___currentMethod = method_call;
+      ___manager.call(method_call);
+    }
+
+    public static class commandStatusList_call extends org.apache.blur.thirdparty.thrift_0_9_0.async.TAsyncMethodCall {
+      private int startingAt;
+      private short fetch;
+      private CommandStatusState state;
+      public commandStatusList_call(int startingAt, short fetch, CommandStatusState state, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<commandStatusList_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.startingAt = startingAt;
+        this.fetch = fetch;
+        this.state = state;
+      }
+
+      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("commandStatusList", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMessageType.CALL, 0));
+        commandStatusList_args args = new commandStatusList_args();
+        args.setStartingAt(startingAt);
+        args.setFetch(fetch);
+        args.setState(state);
+        args.write(prot);
+        prot.writeMessageEnd();
+      }
+
+      public List<String> getResult() throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+        if (getState() != org.apache.blur.thirdparty.thrift_0_9_0.async.TAsyncMethodCall.State.RESPONSE_READ) {
+          throw new IllegalStateException("Method call not finished!");
+        }
+        org.apache.blur.thirdparty.thrift_0_9_0.transport.TMemoryInputTransport memoryTransport = new org.apache.blur.thirdparty.thrift_0_9_0.transport.TMemoryInputTransport(getFrameBuffer().array());
+        org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
+        return (new Client(prot)).recv_commandStatusList();
+      }
+    }
+
+    public void commandStatus(String executionId, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<commandStatus_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+      checkReady();
+      commandStatus_call method_call = new commandStatus_call(executionId, resultHandler, this, ___protocolFactory, ___transport);
+      this.___currentMethod = method_call;
+      ___manager.call(method_call);
+    }
+
+    public static class commandStatus_call extends org.apache.blur.thirdparty.thrift_0_9_0.async.TAsyncMethodCall {
+      private String executionId;
+      public commandStatus_call(String executionId, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<commandStatus_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("commandStatus", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMessageType.CALL, 0));
+        commandStatus_args args = new commandStatus_args();
+        args.setExecutionId(executionId);
+        args.write(prot);
+        prot.writeMessageEnd();
+      }
+
+      public CommandStatus getResult() throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+        if (getState() != org.apache.blur.thirdparty.thrift_0_9_0.async.TAsyncMethodCall.State.RESPONSE_READ) {
+          throw new IllegalStateException("Method call not finished!");
+        }
+        org.apache.blur.thirdparty.thrift_0_9_0.transport.TMemoryInputTransport memoryTransport = new org.apache.blur.thirdparty.thrift_0_9_0.transport.TMemoryInputTransport(getFrameBuffer().array());
+        org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
+        return (new Client(prot)).recv_commandStatus();
+      }
+    }
+
+    public void commandCancel(String executionId, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<commandCancel_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+      checkReady();
+      commandCancel_call method_call = new commandCancel_call(executionId, resultHandler, this, ___protocolFactory, ___transport);
+      this.___currentMethod = method_call;
+      ___manager.call(method_call);
+    }
+
+    public static class commandCancel_call extends org.apache.blur.thirdparty.thrift_0_9_0.async.TAsyncMethodCall {
+      private String executionId;
+      public commandCancel_call(String executionId, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<commandCancel_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("commandCancel", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMessageType.CALL, 0));
+        commandCancel_args args = new commandCancel_args();
+        args.setExecutionId(executionId);
+        args.write(prot);
+        prot.writeMessageEnd();
+      }
+
+      public void getResult() throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+        if (getState() != org.apache.blur.thirdparty.thrift_0_9_0.async.TAsyncMethodCall.State.RESPONSE_READ) {
+          throw new IllegalStateException("Method call not finished!");
+        }
+        org.apache.blur.thirdparty.thrift_0_9_0.transport.TMemoryInputTransport memoryTransport = new org.apache.blur.thirdparty.thrift_0_9_0.transport.TMemoryInputTransport(getFrameBuffer().array());
+        org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
+        (new Client(prot)).recv_commandCancel();
+      }
+    }
+
     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);
@@ -3312,6 +3520,9 @@ 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("commandStatusList", new commandStatusList());
+      processMap.put("commandStatus", new commandStatus());
+      processMap.put("commandCancel", new commandCancel());
       processMap.put("refresh", new refresh());
       processMap.put("createTable", new createTable());
       processMap.put("enableTable", new enableTable());
@@ -3412,6 +3623,78 @@ public class Blur {
       }
     }
 
+    public static class commandStatusList<I extends Iface> extends org.apache.blur.thirdparty.thrift_0_9_0.ProcessFunction<I, commandStatusList_args> {
+      public commandStatusList() {
+        super("commandStatusList");
+      }
+
+      public commandStatusList_args getEmptyArgsInstance() {
+        return new commandStatusList_args();
+      }
+
+      protected boolean isOneway() {
+        return false;
+      }
+
+      public commandStatusList_result getResult(I iface, commandStatusList_args args) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+        commandStatusList_result result = new commandStatusList_result();
+        try {
+          result.success = iface.commandStatusList(args.startingAt, args.fetch, args.state);
+        } catch (BlurException ex) {
+          result.ex = ex;
+        }
+        return result;
+      }
+    }
+
+    public static class commandStatus<I extends Iface> extends org.apache.blur.thirdparty.thrift_0_9_0.ProcessFunction<I, commandStatus_args> {
+      public commandStatus() {
+        super("commandStatus");
+      }
+
+      public commandStatus_args getEmptyArgsInstance() {
+        return new commandStatus_args();
+      }
+
+      protected boolean isOneway() {
+        return false;
+      }
+
+      public commandStatus_result getResult(I iface, commandStatus_args args) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+        commandStatus_result result = new commandStatus_result();
+        try {
+          result.success = iface.commandStatus(args.executionId);
+        } catch (BlurException ex) {
+          result.ex = ex;
+        }
+        return result;
+      }
+    }
+
+    public static class commandCancel<I extends Iface> extends org.apache.blur.thirdparty.thrift_0_9_0.ProcessFunction<I, commandCancel_args> {
+      public commandCancel() {
+        super("commandCancel");
+      }
+
+      public commandCancel_args getEmptyArgsInstance() {
+        return new commandCancel_args();
+      }
+
+      protected boolean isOneway() {
+        return false;
+      }
+
+      public commandCancel_result getResult(I iface, commandCancel_args args) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+        commandCancel_result result = new commandCancel_result();
+        try {
+          iface.commandCancel(args.executionId);
+        } catch (BlurException ex) {
+          result.ex = ex;
+        }
+        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");
@@ -5123,60 +5406,2945 @@ public class Blur {
     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.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(execute_result.class, metaDataMap);
+    }
+
+    public execute_result() {
+    }
+
+    public execute_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 execute_result(execute_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 execute_result deepCopy() {
+      return new execute_result(this);
+    }
+
+    @Override
+    public void clear() {
+      this.success = null;
+      this.bex = null;
+      this.tex = null;
+    }
+
+    public Response getSuccess() {
+      return this.success;
+    }
+
+    public execute_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 execute_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 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;
+      }
+    }
+
+    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 execute_result)
+        return this.equals((execute_result)that);
+      return false;
+    }
+
+    public boolean equals(execute_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(execute_result other) {
+      if (!getClass().equals(other.getClass())) {
+        return getClass().getName().compareTo(other.getClass().getName());
+      }
+
+      int lastComparison = 0;
+      execute_result typedOther = (execute_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("execute_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(")");
+      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(")");
+      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_resultStandardSchemeFactory implements SchemeFactory {
+      public reconnect_resultStandardScheme getScheme() {
+        return new reconnect_resultStandardScheme();
+      }
+    }
+
+    private static class reconnect_resultStandardScheme extends StandardScheme<reconnect_result> {
+
+      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)
+        {
+          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, reconnect_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 reconnect_resultTupleSchemeFactory implements SchemeFactory {
+      public reconnect_resultTupleScheme getScheme() {
+        return new reconnect_resultTupleScheme();
+      }
+    }
+
+    private static class reconnect_resultTupleScheme extends TupleScheme<reconnect_result> {
+
+      @Override
+      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.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, reconnect_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 commandStatusList_args implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<commandStatusList_args, commandStatusList_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("commandStatusList_args");
+
+    private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField STARTING_AT_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("startingAt", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I32, (short)1);
+    private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField FETCH_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("fetch", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I16, (short)2);
+    private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField STATE_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("state", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I32, (short)3);
+
+    private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
+    static {
+      schemes.put(StandardScheme.class, new commandStatusList_argsStandardSchemeFactory());
+      schemes.put(TupleScheme.class, new commandStatusList_argsTupleSchemeFactory());
+    }
+
+    public int startingAt; // required
+    public short fetch; // required
+    /**
+     * 
+     * @see CommandStatusState
+     */
+    public CommandStatusState state; // 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 {
+      STARTING_AT((short)1, "startingAt"),
+      FETCH((short)2, "fetch"),
+      /**
+       * 
+       * @see CommandStatusState
+       */
+      STATE((short)3, "state");
+
+      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: // STARTING_AT
+            return STARTING_AT;
+          case 2: // FETCH
+            return FETCH;
+          case 3: // STATE
+            return STATE;
+          default:
+            return null;
+        }
+      }
+
+      /**
+       * Find the _Fields constant that matches fieldId, throwing an exception
+       * if it is not found.
+       */
+      public static _Fields findByThriftIdOrThrow(int fieldId) {
+        _Fields fields = findByThriftId(fieldId);
+        if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
+        return fields;
+      }
+
+      /**
+       * Find the _Fields constant that matches name, or null if its not found.
+       */
+      public static _Fields findByName(String name) {
+        return byName.get(name);
+      }
+
+      private final short _thriftId;
+      private final String _fieldName;
+
+      _Fields(short thriftId, String fieldName) {
+        _thriftId = thriftId;
+        _fieldName = fieldName;
+      }
+
+      public short getThriftFieldId() {
+        return _thriftId;
+      }
+
+      public String getFieldName() {
+        return _fieldName;
+      }
+    }
+
+    // isset id assignments
+    private static final int __STARTINGAT_ISSET_ID = 0;
+    private static final int __FETCH_ISSET_ID = 1;
+    private byte __isset_bitfield = 0;
+    public static final Map<_Fields, org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData> metaDataMap;
+    static {
+      Map<_Fields, org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData>(_Fields.class);
+      tmpMap.put(_Fields.STARTING_AT, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("startingAt", 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.I32)));
+      tmpMap.put(_Fields.FETCH, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("fetch", 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.I16)));
+      tmpMap.put(_Fields.STATE, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("state", org.apache.blur.thirdparty.thrift_0_9_0.TFieldRequirementType.DEFAULT, 
+          new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.EnumMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.ENUM, CommandStatusState.class)));
+      metaDataMap = Collections.unmodifiableMap(tmpMap);
+      org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData.addStructMetaDataMap(commandStatusList_args.class, metaDataMap);
+    }
+
+    public commandStatusList_args() {
+    }
+
+    public commandStatusList_args(
+      int startingAt,
+      short fetch,
+      CommandStatusState state)
+    {
+      this();
+      this.startingAt = startingAt;
+      setStartingAtIsSet(true);
+      this.fetch = fetch;
+      setFetchIsSet(true);
+      this.state = state;
+    }
+
+    /**
+     * Performs a deep copy on <i>other</i>.
+     */
+    public commandStatusList_args(commandStatusList_args other) {
+      __isset_bitfield = other.__isset_bitfield;
+      this.startingAt = other.startingAt;
+      this.fetch = other.fetch;
+      if (other.isSetState()) {
+        this.state = other.state;
+      }
+    }
+
+    public commandStatusList_args deepCopy() {
+      return new commandStatusList_args(this);
+    }
+
+    @Override
+    public void clear() {
+      setStartingAtIsSet(false);
+      this.startingAt = 0;
+      setFetchIsSet(false);
+      this.fetch = 0;
+      this.state = null;
+    }
+
+    public int getStartingAt() {
+      return this.startingAt;
+    }
+
+    public commandStatusList_args setStartingAt(int startingAt) {
+      this.startingAt = startingAt;
+      setStartingAtIsSet(true);
+      return this;
+    }
+
+    public void unsetStartingAt() {
+      __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __STARTINGAT_ISSET_ID);
+    }
+
+    /** Returns true if field startingAt is set (has been assigned a value) and false otherwise */
+    public boolean isSetStartingAt() {
+      return EncodingUtils.testBit(__isset_bitfield, __STARTINGAT_ISSET_ID);
+    }
+
+    public void setStartingAtIsSet(boolean value) {
+      __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __STARTINGAT_ISSET_ID, value);
+    }
+
+    public short getFetch() {
+      return this.fetch;
+    }
+
+    public commandStatusList_args setFetch(short fetch) {
+      this.fetch = fetch;
+      setFetchIsSet(true);
+      return this;
+    }
+
+    public void unsetFetch() {
+      __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __FETCH_ISSET_ID);
+    }
+
+    /** Returns true if field fetch is set (has been assigned a value) and false otherwise */
+    public boolean isSetFetch() {
+      return EncodingUtils.testBit(__isset_bitfield, __FETCH_ISSET_ID);
+    }
+
+    public void setFetchIsSet(boolean value) {
+      __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __FETCH_ISSET_ID, value);
+    }
+
+    /**
+     * 
+     * @see CommandStatusState
+     */
+    public CommandStatusState getState() {
+      return this.state;
+    }
+
+    /**
+     * 
+     * @see CommandStatusState
+     */
+    public commandStatusList_args setState(CommandStatusState state) {
+      this.state = state;
+      return this;
+    }
+
+    public void unsetState() {
+      this.state = null;
+    }
+
+    /** Returns true if field state is set (has been assigned a value) and false otherwise */
+    public boolean isSetState() {
+      return this.state != null;
+    }
+
+    public void setStateIsSet(boolean value) {
+      if (!value) {
+        this.state = null;
+      }
+    }
+
+    public void setFieldValue(_Fields field, Object value) {
+      switch (field) {
+      case STARTING_AT:
+        if (value == null) {
+          unsetStartingAt();
+        } else {
+          setStartingAt((Integer)value);
+        }
+        break;
+
+      case FETCH:
+        if (value == null) {
+          unsetFetch();
+        } else {
+          setFetch((Short)value);
+        }
+        break;
+
+      case STATE:
+        if (value == null) {
+          unsetState();
+        } else {
+          setState((CommandStatusState)value);
+        }
+        break;
+
+      }
+    }
+
+    public Object getFieldValue(_Fields field) {
+      switch (field) {
+      case STARTING_AT:
+        return Integer.valueOf(getStartingAt());
+
+      case FETCH:
+        return Short.valueOf(getFetch());
+
+      case STATE:
+        return getState();
+
+      }
+      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 STARTING_AT:
+        return isSetStartingAt();
+      case FETCH:
+        return isSetFetch();
+      case STATE:
+        return isSetState();
+      }
+      throw new IllegalStateException();
+    }
+
+    @Override
+    public boolean equals(Object that) {
+      if (that == null)
+        return false;
+      if (that instanceof commandStatusList_args)
+        return this.equals((commandStatusList_args)that);
+      return false;
+    }
+
+    public boolean equals(commandStatusList_args that) {
+      if (that == null)
+        return false;
+
+      boolean this_present_startingAt = true;
+      boolean that_present_startingAt = true;
+      if (this_present_startingAt || that_present_startingAt) {
+        if (!(this_present_startingAt && that_present_startingAt))
+          return false;
+        if (this.startingAt != that.startingAt)
+          return false;
+      }
+
+      boolean this_present_fetch = true;
+      boolean that_present_fetch = true;
+      if (this_present_fetch || that_present_fetch) {
+        if (!(this_present_fetch && that_present_fetch))
+          return false;
+        if (this.fetch != that.fetch)
+          return false;
+      }
+
+      boolean this_present_state = true && this.isSetState();
+      boolean that_present_state = true && that.isSetState();
+      if (this_present_state || that_present_state) {
+        if (!(this_present_state && that_present_state))
+          return false;
+        if (!this.state.equals(that.state))
+          return false;
+      }
+
+      return true;
+    }
+
+    @Override
+    public int hashCode() {
+      return 0;
+    }
+
+    public int compareTo(commandStatusList_args other) {
+      if (!getClass().equals(other.getClass())) {
+        return getClass().getName().compareTo(other.getClass().getName());
+      }
+
+      int lastComparison = 0;
+      commandStatusList_args typedOther = (commandStatusList_args)other;
+
+      lastComparison = Boolean.valueOf(isSetStartingAt()).compareTo(typedOther.isSetStartingAt());
+      if (lastComparison != 0) {
+        return lastComparison;
+      }
+      if (isSetStartingAt()) {
+        lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.startingAt, typedOther.startingAt);
+        if (lastComparison != 0) {
+          return lastComparison;
+        }
+      }
+      lastComparison = Boolean.valueOf(isSetFetch()).compareTo(typedOther.isSetFetch());
+      if (lastComparison != 0) {
+        return lastComparison;
+      }
+      if (isSetFetch()) {
+        lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.fetch, typedOther.fetch);
+        if (lastComparison != 0) {
+          return lastComparison;
+        }
+      }
+      lastComparison = Boolean.valueOf(isSetState()).compareTo(typedOther.isSetState());
+      if (lastComparison != 0) {
+        return lastComparison;
+      }
+      if (isSetState()) {
+        lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.state, typedOther.state);
+        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("commandStatusList_args(");
+      boolean first = true;
+
+      sb.append("startingAt:");
+      sb.append(this.startingAt);
+      first = false;
+      if (!first) sb.append(", ");
+      sb.append("fetch:");
+      sb.append(this.fetch);
+      first = false;
+      if (!first) sb.append(", ");
+      sb.append("state:");
+      if (this.state == null) {
+        sb.append("null");
+      } else {
+        sb.append(this.state);
+      }
+      first = false;
+      sb.append(")");
+      return sb.toString();
+    }
+
+    public void validate() throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+      // check for required fields
+      // check for sub-struct validity
+    }
+
+    private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
+      try {
+        write(new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TCompactProtocol(new org.apache.blur.thirdparty.thrift_0_9_0.transport.TIOStreamTransport(out)));
+      } catch (org.apache.blur.thirdparty.thrift_0_9_0.TException te) {
+        throw new java.io.IOException(te);
+      }
+    }
+
+    private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
+      try {
+        // it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor.
+        __isset_bitfield = 0;
+        read(new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TCompactProtocol(new org.apache.blur.thirdparty.thrift_0_9_0.transport.TIOStreamTransport(in)));
+      } catch (org.apache.blur.thirdparty.thrift_0_9_0.TException te) {
+        throw new java.io.IOException(te);
+      }
+    }
+
+    private static class commandStatusList_argsStandardSchemeFactory implements SchemeFactory {
+      public commandStatusList_argsStandardScheme getScheme() {
+        return new commandStatusList_argsStandardScheme();
+      }
+    }
+
+    private static class commandStatusList_argsStandardScheme extends StandardScheme<commandStatusList_args> {
+
+      public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol iprot, commandStatusList_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: // STARTING_AT
+              if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I32) {
+                struct.startingAt = iprot.readI32();
+                struct.setStartingAtIsSet(true);
+              } else { 
+                org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+              }
+              break;
+            case 2: // FETCH
+              if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I16) {
+                struct.fetch = iprot.readI16();
+                struct.setFetchIsSet(true);
+              } else { 
+                org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+              }
+              break;
+            case 3: // STATE
+              if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I32) {
+                struct.state = CommandStatusState.findByValue(iprot.readI32());
+                struct.setStateIsSet(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, commandStatusList_args struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+        struct.validate();
+
+        oprot.writeStructBegin(STRUCT_DESC);
+        oprot.writeFieldBegin(STARTING_AT_FIELD_DESC);
+        oprot.writeI32(struct.startingAt);
+        oprot.writeFieldEnd();
+        oprot.writeFieldBegin(FETCH_FIELD_DESC);
+        oprot.writeI16(struct.fetch);
+        oprot.writeFieldEnd();
+        if (struct.state != null) {
+          oprot.writeFieldBegin(STATE_FIELD_DESC);
+          oprot.writeI32(struct.state.getValue());
+          oprot.writeFieldEnd();
+        }
+        oprot.writeFieldStop();
+        oprot.writeStructEnd();
+      }
+
+    }
+
+    private static class commandStatusList_argsTupleSchemeFactory implements SchemeFactory {
+      public commandStatusList_argsTupleScheme getScheme() {
+        return new commandStatusList_argsTupleScheme();
+      }
+    }
+
+    private static class commandStatusList_argsTupleScheme extends TupleScheme<commandStatusList_args> {
+
+      @Override
+      public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, commandStatusList_args struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+        TTupleProtocol oprot = (TTupleProtocol) prot;
+        BitSet optionals = new BitSet();
+        if (struct.isSetStartingAt()) {
+          optionals.set(0);
+        }
+        if (struct.isSetFetch()) {
+          optionals.set(1);
+        }
+        if (struct.isSetState()) {
+          optionals.set(2);
+        }
+        oprot.writeBitSet(optionals, 3);
+        if (struct.isSetStartingAt()) {
+          oprot.writeI32(struct.startingAt);
+        }
+        if (struct.isSetFetch()) {
+          oprot.writeI16(struct.fetch);
+        }
+        if (struct.isSetState()) {
+          oprot.writeI32(struct.state.getValue());
+        }
+      }
+
+      @Override
+      public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, commandStatusList_args 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.startingAt = iprot.readI32();
+          struct.setStartingAtIsSet(true);
+        }
+        if (incoming.get(1)) {
+          struct.fetch = iprot.readI16();
+          struct.setFetchIsSet(true);
+        }
+        if (incoming.get(2)) {
+          struct.state = CommandStatusState.findByValue(iprot.readI32());
+          struct.setStateIsSet(true);
+        }
+      }
+    }
+
+  }
+
+  public static class commandStatusList_result implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<commandStatusList_result, commandStatusList_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("commandStatusList_result");
+
+    private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField SUCCESS_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("success", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.LIST, (short)0);
+    private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField EX_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("ex", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT, (short)1);
+
+    private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
+    static {
+      schemes.put(StandardScheme.class, new commandStatusList_resultStandardSchemeFactory());
+      schemes.put(TupleScheme.class, new commandStatusList_resultTupleSchemeFactory());
+    }
+
+    public List<String> success; // required
+    public BlurException ex; // required
+
+    /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
+    public enum _Fields implements org.apache.blur.thirdparty.thrift_0_9_0.TFieldIdEnum {
+      SUCCESS((short)0, "success"),
+      EX((short)1, "ex");
+
+      private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
+
+      static {
+        for (_Fields field : EnumSet.allOf(_Fields.class)) {
+          byName.put(field.getFieldName(), field);
+        }
+      }
+
+      /**
+       * Find the _Fields constant that matches fieldId, or null if its not found.
+       */
+      public static _Fields findByThriftId(int fieldId) {
+        switch(fieldId) {
+          case 0: // SUCCESS
+            return SUCCESS;
+          case 1: // EX
+            return EX;
+          default:
+            return null;
+        }
+      }
+
+      /**

<TRUNCATED>

Mime
View raw message