accumulo-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ktur...@apache.org
Subject svn commit: r1456738 [2/3] - in /accumulo/branches/1.5: core/src/main/java/org/apache/accumulo/core/client/admin/ core/src/main/java/org/apache/accumulo/core/client/impl/ core/src/main/java/org/apache/accumulo/core/client/mock/ core/src/main/java/org/a...
Date Fri, 15 Mar 2013 01:09:24 GMT
Modified: accumulo/branches/1.5/proxy/src/main/java/org/apache/accumulo/proxy/thrift/AccumuloProxy.java
URL: http://svn.apache.org/viewvc/accumulo/branches/1.5/proxy/src/main/java/org/apache/accumulo/proxy/thrift/AccumuloProxy.java?rev=1456738&r1=1456737&r2=1456738&view=diff
==============================================================================
--- accumulo/branches/1.5/proxy/src/main/java/org/apache/accumulo/proxy/thrift/AccumuloProxy.java (original)
+++ accumulo/branches/1.5/proxy/src/main/java/org/apache/accumulo/proxy/thrift/AccumuloProxy.java Fri Mar 15 01:09:23 2013
@@ -86,12 +86,12 @@ import org.slf4j.LoggerFactory;
 
     public Map<String,String> getTableProperties(ByteBuffer login, String tableName) throws AccumuloException, TableNotFoundException, org.apache.thrift.TException;
 
-    public List<ByteBuffer> getSplits(ByteBuffer login, String tableName, int maxSplits) throws TableNotFoundException, org.apache.thrift.TException;
-
     public void importDirectory(ByteBuffer login, String tableName, String importDir, String failureDir, boolean setTime) throws TableNotFoundException, AccumuloException, AccumuloSecurityException, org.apache.thrift.TException;
 
     public void importTable(ByteBuffer login, String tableName, String importDir) throws TableExistsException, AccumuloException, AccumuloSecurityException, org.apache.thrift.TException;
 
+    public List<ByteBuffer> listSplits(ByteBuffer login, String tableName, int maxSplits) throws TableNotFoundException, AccumuloException, AccumuloSecurityException, org.apache.thrift.TException;
+
     public Set<String> listTables(ByteBuffer login) throws org.apache.thrift.TException;
 
     public Map<String,Set<IteratorScope>> listIterators(ByteBuffer login, String tableName) throws AccumuloSecurityException, AccumuloException, TableNotFoundException, org.apache.thrift.TException;
@@ -232,12 +232,12 @@ import org.slf4j.LoggerFactory;
 
     public void getTableProperties(ByteBuffer login, String tableName, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.getTableProperties_call> resultHandler) throws org.apache.thrift.TException;
 
-    public void getSplits(ByteBuffer login, String tableName, int maxSplits, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.getSplits_call> resultHandler) throws org.apache.thrift.TException;
-
     public void importDirectory(ByteBuffer login, String tableName, String importDir, String failureDir, boolean setTime, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.importDirectory_call> resultHandler) throws org.apache.thrift.TException;
 
     public void importTable(ByteBuffer login, String tableName, String importDir, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.importTable_call> resultHandler) throws org.apache.thrift.TException;
 
+    public void listSplits(ByteBuffer login, String tableName, int maxSplits, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.listSplits_call> resultHandler) throws org.apache.thrift.TException;
+
     public void listTables(ByteBuffer login, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.listTables_call> resultHandler) throws org.apache.thrift.TException;
 
     public void listIterators(ByteBuffer login, String tableName, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.listIterators_call> resultHandler) throws org.apache.thrift.TException;
@@ -927,34 +927,6 @@ import org.slf4j.LoggerFactory;
       throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getTableProperties failed: unknown result");
     }
 
-    public List<ByteBuffer> getSplits(ByteBuffer login, String tableName, int maxSplits) throws TableNotFoundException, org.apache.thrift.TException
-    {
-      send_getSplits(login, tableName, maxSplits);
-      return recv_getSplits();
-    }
-
-    public void send_getSplits(ByteBuffer login, String tableName, int maxSplits) throws org.apache.thrift.TException
-    {
-      getSplits_args args = new getSplits_args();
-      args.setLogin(login);
-      args.setTableName(tableName);
-      args.setMaxSplits(maxSplits);
-      sendBase("getSplits", args);
-    }
-
-    public List<ByteBuffer> recv_getSplits() throws TableNotFoundException, org.apache.thrift.TException
-    {
-      getSplits_result result = new getSplits_result();
-      receiveBase(result, "getSplits");
-      if (result.isSetSuccess()) {
-        return result.success;
-      }
-      if (result.ouch1 != null) {
-        throw result.ouch1;
-      }
-      throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getSplits failed: unknown result");
-    }
-
     public void importDirectory(ByteBuffer login, String tableName, String importDir, String failureDir, boolean setTime) throws TableNotFoundException, AccumuloException, AccumuloSecurityException, org.apache.thrift.TException
     {
       send_importDirectory(login, tableName, importDir, failureDir, setTime);
@@ -1019,6 +991,40 @@ import org.slf4j.LoggerFactory;
       return;
     }
 
+    public List<ByteBuffer> listSplits(ByteBuffer login, String tableName, int maxSplits) throws TableNotFoundException, AccumuloException, AccumuloSecurityException, org.apache.thrift.TException
+    {
+      send_listSplits(login, tableName, maxSplits);
+      return recv_listSplits();
+    }
+
+    public void send_listSplits(ByteBuffer login, String tableName, int maxSplits) throws org.apache.thrift.TException
+    {
+      listSplits_args args = new listSplits_args();
+      args.setLogin(login);
+      args.setTableName(tableName);
+      args.setMaxSplits(maxSplits);
+      sendBase("listSplits", args);
+    }
+
+    public List<ByteBuffer> recv_listSplits() throws TableNotFoundException, AccumuloException, AccumuloSecurityException, org.apache.thrift.TException
+    {
+      listSplits_result result = new listSplits_result();
+      receiveBase(result, "listSplits");
+      if (result.isSetSuccess()) {
+        return result.success;
+      }
+      if (result.ouch1 != null) {
+        throw result.ouch1;
+      }
+      if (result.ouch2 != null) {
+        throw result.ouch2;
+      }
+      if (result.ouch3 != null) {
+        throw result.ouch3;
+      }
+      throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "listSplits failed: unknown result");
+    }
+
     public Set<String> listTables(ByteBuffer login) throws org.apache.thrift.TException
     {
       send_listTables(login);
@@ -3178,123 +3184,123 @@ import org.slf4j.LoggerFactory;
       }
     }
 
-    public void getSplits(ByteBuffer login, String tableName, int maxSplits, org.apache.thrift.async.AsyncMethodCallback<getSplits_call> resultHandler) throws org.apache.thrift.TException {
+    public void importDirectory(ByteBuffer login, String tableName, String importDir, String failureDir, boolean setTime, org.apache.thrift.async.AsyncMethodCallback<importDirectory_call> resultHandler) throws org.apache.thrift.TException {
       checkReady();
-      getSplits_call method_call = new getSplits_call(login, tableName, maxSplits, resultHandler, this, ___protocolFactory, ___transport);
+      importDirectory_call method_call = new importDirectory_call(login, tableName, importDir, failureDir, setTime, resultHandler, this, ___protocolFactory, ___transport);
       this.___currentMethod = method_call;
       ___manager.call(method_call);
     }
 
-    public static class getSplits_call extends org.apache.thrift.async.TAsyncMethodCall {
+    public static class importDirectory_call extends org.apache.thrift.async.TAsyncMethodCall {
       private ByteBuffer login;
       private String tableName;
-      private int maxSplits;
-      public getSplits_call(ByteBuffer login, String tableName, int maxSplits, org.apache.thrift.async.AsyncMethodCallback<getSplits_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
+      private String importDir;
+      private String failureDir;
+      private boolean setTime;
+      public importDirectory_call(ByteBuffer login, String tableName, String importDir, String failureDir, boolean setTime, org.apache.thrift.async.AsyncMethodCallback<importDirectory_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
         super(client, protocolFactory, transport, resultHandler, false);
         this.login = login;
         this.tableName = tableName;
-        this.maxSplits = maxSplits;
+        this.importDir = importDir;
+        this.failureDir = failureDir;
+        this.setTime = setTime;
       }
 
       public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
-        prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getSplits", org.apache.thrift.protocol.TMessageType.CALL, 0));
-        getSplits_args args = new getSplits_args();
+        prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("importDirectory", org.apache.thrift.protocol.TMessageType.CALL, 0));
+        importDirectory_args args = new importDirectory_args();
         args.setLogin(login);
         args.setTableName(tableName);
-        args.setMaxSplits(maxSplits);
+        args.setImportDir(importDir);
+        args.setFailureDir(failureDir);
+        args.setSetTime(setTime);
         args.write(prot);
         prot.writeMessageEnd();
       }
 
-      public List<ByteBuffer> getResult() throws TableNotFoundException, org.apache.thrift.TException {
+      public void getResult() throws TableNotFoundException, AccumuloException, AccumuloSecurityException, org.apache.thrift.TException {
         if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
           throw new IllegalStateException("Method call not finished!");
         }
         org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
         org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
-        return (new Client(prot)).recv_getSplits();
+        (new Client(prot)).recv_importDirectory();
       }
     }
 
-    public void importDirectory(ByteBuffer login, String tableName, String importDir, String failureDir, boolean setTime, org.apache.thrift.async.AsyncMethodCallback<importDirectory_call> resultHandler) throws org.apache.thrift.TException {
+    public void importTable(ByteBuffer login, String tableName, String importDir, org.apache.thrift.async.AsyncMethodCallback<importTable_call> resultHandler) throws org.apache.thrift.TException {
       checkReady();
-      importDirectory_call method_call = new importDirectory_call(login, tableName, importDir, failureDir, setTime, resultHandler, this, ___protocolFactory, ___transport);
+      importTable_call method_call = new importTable_call(login, tableName, importDir, resultHandler, this, ___protocolFactory, ___transport);
       this.___currentMethod = method_call;
       ___manager.call(method_call);
     }
 
-    public static class importDirectory_call extends org.apache.thrift.async.TAsyncMethodCall {
+    public static class importTable_call extends org.apache.thrift.async.TAsyncMethodCall {
       private ByteBuffer login;
       private String tableName;
       private String importDir;
-      private String failureDir;
-      private boolean setTime;
-      public importDirectory_call(ByteBuffer login, String tableName, String importDir, String failureDir, boolean setTime, org.apache.thrift.async.AsyncMethodCallback<importDirectory_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
+      public importTable_call(ByteBuffer login, String tableName, String importDir, org.apache.thrift.async.AsyncMethodCallback<importTable_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
         super(client, protocolFactory, transport, resultHandler, false);
         this.login = login;
         this.tableName = tableName;
         this.importDir = importDir;
-        this.failureDir = failureDir;
-        this.setTime = setTime;
       }
 
       public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
-        prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("importDirectory", org.apache.thrift.protocol.TMessageType.CALL, 0));
-        importDirectory_args args = new importDirectory_args();
+        prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("importTable", org.apache.thrift.protocol.TMessageType.CALL, 0));
+        importTable_args args = new importTable_args();
         args.setLogin(login);
         args.setTableName(tableName);
         args.setImportDir(importDir);
-        args.setFailureDir(failureDir);
-        args.setSetTime(setTime);
         args.write(prot);
         prot.writeMessageEnd();
       }
 
-      public void getResult() throws TableNotFoundException, AccumuloException, AccumuloSecurityException, org.apache.thrift.TException {
+      public void getResult() throws TableExistsException, AccumuloException, AccumuloSecurityException, org.apache.thrift.TException {
         if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
           throw new IllegalStateException("Method call not finished!");
         }
         org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
         org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
-        (new Client(prot)).recv_importDirectory();
+        (new Client(prot)).recv_importTable();
       }
     }
 
-    public void importTable(ByteBuffer login, String tableName, String importDir, org.apache.thrift.async.AsyncMethodCallback<importTable_call> resultHandler) throws org.apache.thrift.TException {
+    public void listSplits(ByteBuffer login, String tableName, int maxSplits, org.apache.thrift.async.AsyncMethodCallback<listSplits_call> resultHandler) throws org.apache.thrift.TException {
       checkReady();
-      importTable_call method_call = new importTable_call(login, tableName, importDir, resultHandler, this, ___protocolFactory, ___transport);
+      listSplits_call method_call = new listSplits_call(login, tableName, maxSplits, resultHandler, this, ___protocolFactory, ___transport);
       this.___currentMethod = method_call;
       ___manager.call(method_call);
     }
 
-    public static class importTable_call extends org.apache.thrift.async.TAsyncMethodCall {
+    public static class listSplits_call extends org.apache.thrift.async.TAsyncMethodCall {
       private ByteBuffer login;
       private String tableName;
-      private String importDir;
-      public importTable_call(ByteBuffer login, String tableName, String importDir, org.apache.thrift.async.AsyncMethodCallback<importTable_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
+      private int maxSplits;
+      public listSplits_call(ByteBuffer login, String tableName, int maxSplits, org.apache.thrift.async.AsyncMethodCallback<listSplits_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
         super(client, protocolFactory, transport, resultHandler, false);
         this.login = login;
         this.tableName = tableName;
-        this.importDir = importDir;
+        this.maxSplits = maxSplits;
       }
 
       public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
-        prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("importTable", org.apache.thrift.protocol.TMessageType.CALL, 0));
-        importTable_args args = new importTable_args();
+        prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("listSplits", org.apache.thrift.protocol.TMessageType.CALL, 0));
+        listSplits_args args = new listSplits_args();
         args.setLogin(login);
         args.setTableName(tableName);
-        args.setImportDir(importDir);
+        args.setMaxSplits(maxSplits);
         args.write(prot);
         prot.writeMessageEnd();
       }
 
-      public void getResult() throws TableExistsException, AccumuloException, AccumuloSecurityException, org.apache.thrift.TException {
+      public List<ByteBuffer> getResult() throws TableNotFoundException, AccumuloException, AccumuloSecurityException, org.apache.thrift.TException {
         if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
           throw new IllegalStateException("Method call not finished!");
         }
         org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
         org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
-        (new Client(prot)).recv_importTable();
+        return (new Client(prot)).recv_listSplits();
       }
     }
 
@@ -5135,9 +5141,9 @@ import org.slf4j.LoggerFactory;
       processMap.put("getIteratorSetting", new getIteratorSetting());
       processMap.put("getMaxRow", new getMaxRow());
       processMap.put("getTableProperties", new getTableProperties());
-      processMap.put("getSplits", new getSplits());
       processMap.put("importDirectory", new importDirectory());
       processMap.put("importTable", new importTable());
+      processMap.put("listSplits", new listSplits());
       processMap.put("listTables", new listTables());
       processMap.put("listIterators", new listIterators());
       processMap.put("listConstraints", new listConstraints());
@@ -5682,30 +5688,6 @@ import org.slf4j.LoggerFactory;
       }
     }
 
-    public static class getSplits<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getSplits_args> {
-      public getSplits() {
-        super("getSplits");
-      }
-
-      public getSplits_args getEmptyArgsInstance() {
-        return new getSplits_args();
-      }
-
-      protected boolean isOneway() {
-        return false;
-      }
-
-      public getSplits_result getResult(I iface, getSplits_args args) throws org.apache.thrift.TException {
-        getSplits_result result = new getSplits_result();
-        try {
-          result.success = iface.getSplits(args.login, args.tableName, args.maxSplits);
-        } catch (TableNotFoundException ouch1) {
-          result.ouch1 = ouch1;
-        }
-        return result;
-      }
-    }
-
     public static class importDirectory<I extends Iface> extends org.apache.thrift.ProcessFunction<I, importDirectory_args> {
       public importDirectory() {
         super("importDirectory");
@@ -5762,6 +5744,34 @@ import org.slf4j.LoggerFactory;
       }
     }
 
+    public static class listSplits<I extends Iface> extends org.apache.thrift.ProcessFunction<I, listSplits_args> {
+      public listSplits() {
+        super("listSplits");
+      }
+
+      public listSplits_args getEmptyArgsInstance() {
+        return new listSplits_args();
+      }
+
+      protected boolean isOneway() {
+        return false;
+      }
+
+      public listSplits_result getResult(I iface, listSplits_args args) throws org.apache.thrift.TException {
+        listSplits_result result = new listSplits_result();
+        try {
+          result.success = iface.listSplits(args.login, args.tableName, args.maxSplits);
+        } catch (TableNotFoundException ouch1) {
+          result.ouch1 = ouch1;
+        } catch (AccumuloException ouch2) {
+          result.ouch2 = ouch2;
+        } catch (AccumuloSecurityException ouch3) {
+          result.ouch3 = ouch3;
+        }
+        return result;
+      }
+    }
+
     public static class listTables<I extends Iface> extends org.apache.thrift.ProcessFunction<I, listTables_args> {
       public listTables() {
         super("listTables");
@@ -29111,28 +29121,34 @@ import org.slf4j.LoggerFactory;
 
   }
 
-  public static class getSplits_args implements org.apache.thrift.TBase<getSplits_args, getSplits_args._Fields>, java.io.Serializable, Cloneable   {
-    private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("getSplits_args");
+  public static class importDirectory_args implements org.apache.thrift.TBase<importDirectory_args, importDirectory_args._Fields>, java.io.Serializable, Cloneable   {
+    private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("importDirectory_args");
 
     private static final org.apache.thrift.protocol.TField LOGIN_FIELD_DESC = new org.apache.thrift.protocol.TField("login", org.apache.thrift.protocol.TType.STRING, (short)1);
     private static final org.apache.thrift.protocol.TField TABLE_NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("tableName", org.apache.thrift.protocol.TType.STRING, (short)2);
-    private static final org.apache.thrift.protocol.TField MAX_SPLITS_FIELD_DESC = new org.apache.thrift.protocol.TField("maxSplits", org.apache.thrift.protocol.TType.I32, (short)3);
+    private static final org.apache.thrift.protocol.TField IMPORT_DIR_FIELD_DESC = new org.apache.thrift.protocol.TField("importDir", org.apache.thrift.protocol.TType.STRING, (short)3);
+    private static final org.apache.thrift.protocol.TField FAILURE_DIR_FIELD_DESC = new org.apache.thrift.protocol.TField("failureDir", org.apache.thrift.protocol.TType.STRING, (short)4);
+    private static final org.apache.thrift.protocol.TField SET_TIME_FIELD_DESC = new org.apache.thrift.protocol.TField("setTime", org.apache.thrift.protocol.TType.BOOL, (short)5);
 
     private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
     static {
-      schemes.put(StandardScheme.class, new getSplits_argsStandardSchemeFactory());
-      schemes.put(TupleScheme.class, new getSplits_argsTupleSchemeFactory());
+      schemes.put(StandardScheme.class, new importDirectory_argsStandardSchemeFactory());
+      schemes.put(TupleScheme.class, new importDirectory_argsTupleSchemeFactory());
     }
 
     public ByteBuffer login; // required
     public String tableName; // required
-    public int maxSplits; // required
+    public String importDir; // required
+    public String failureDir; // required
+    public boolean setTime; // required
 
     /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
     @SuppressWarnings("all") public enum _Fields implements org.apache.thrift.TFieldIdEnum {
       LOGIN((short)1, "login"),
       TABLE_NAME((short)2, "tableName"),
-      MAX_SPLITS((short)3, "maxSplits");
+      IMPORT_DIR((short)3, "importDir"),
+      FAILURE_DIR((short)4, "failureDir"),
+      SET_TIME((short)5, "setTime");
 
       private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
 
@@ -29151,8 +29167,12 @@ import org.slf4j.LoggerFactory;
             return LOGIN;
           case 2: // TABLE_NAME
             return TABLE_NAME;
-          case 3: // MAX_SPLITS
-            return MAX_SPLITS;
+          case 3: // IMPORT_DIR
+            return IMPORT_DIR;
+          case 4: // FAILURE_DIR
+            return FAILURE_DIR;
+          case 5: // SET_TIME
+            return SET_TIME;
           default:
             return null;
         }
@@ -29193,7 +29213,7 @@ import org.slf4j.LoggerFactory;
     }
 
     // isset id assignments
-    private static final int __MAXSPLITS_ISSET_ID = 0;
+    private static final int __SETTIME_ISSET_ID = 0;
     private byte __isset_bitfield = 0;
     public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
     static {
@@ -29202,31 +29222,39 @@ import org.slf4j.LoggerFactory;
           new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING          , true)));
       tmpMap.put(_Fields.TABLE_NAME, new org.apache.thrift.meta_data.FieldMetaData("tableName", org.apache.thrift.TFieldRequirementType.DEFAULT, 
           new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
-      tmpMap.put(_Fields.MAX_SPLITS, new org.apache.thrift.meta_data.FieldMetaData("maxSplits", org.apache.thrift.TFieldRequirementType.DEFAULT, 
-          new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32)));
+      tmpMap.put(_Fields.IMPORT_DIR, new org.apache.thrift.meta_data.FieldMetaData("importDir", org.apache.thrift.TFieldRequirementType.DEFAULT, 
+          new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
+      tmpMap.put(_Fields.FAILURE_DIR, new org.apache.thrift.meta_data.FieldMetaData("failureDir", org.apache.thrift.TFieldRequirementType.DEFAULT, 
+          new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
+      tmpMap.put(_Fields.SET_TIME, new org.apache.thrift.meta_data.FieldMetaData("setTime", org.apache.thrift.TFieldRequirementType.DEFAULT, 
+          new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.BOOL)));
       metaDataMap = Collections.unmodifiableMap(tmpMap);
-      org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(getSplits_args.class, metaDataMap);
+      org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(importDirectory_args.class, metaDataMap);
     }
 
-    public getSplits_args() {
+    public importDirectory_args() {
     }
 
-    public getSplits_args(
+    public importDirectory_args(
       ByteBuffer login,
       String tableName,
-      int maxSplits)
+      String importDir,
+      String failureDir,
+      boolean setTime)
     {
       this();
       this.login = login;
       this.tableName = tableName;
-      this.maxSplits = maxSplits;
-      setMaxSplitsIsSet(true);
+      this.importDir = importDir;
+      this.failureDir = failureDir;
+      this.setTime = setTime;
+      setSetTimeIsSet(true);
     }
 
     /**
      * Performs a deep copy on <i>other</i>.
      */
-    public getSplits_args(getSplits_args other) {
+    public importDirectory_args(importDirectory_args other) {
       __isset_bitfield = other.__isset_bitfield;
       if (other.isSetLogin()) {
         this.login = org.apache.thrift.TBaseHelper.copyBinary(other.login);
@@ -29235,19 +29263,27 @@ import org.slf4j.LoggerFactory;
       if (other.isSetTableName()) {
         this.tableName = other.tableName;
       }
-      this.maxSplits = other.maxSplits;
+      if (other.isSetImportDir()) {
+        this.importDir = other.importDir;
+      }
+      if (other.isSetFailureDir()) {
+        this.failureDir = other.failureDir;
+      }
+      this.setTime = other.setTime;
     }
 
-    public getSplits_args deepCopy() {
-      return new getSplits_args(this);
+    public importDirectory_args deepCopy() {
+      return new importDirectory_args(this);
     }
 
     @Override
     public void clear() {
       this.login = null;
       this.tableName = null;
-      setMaxSplitsIsSet(false);
-      this.maxSplits = 0;
+      this.importDir = null;
+      this.failureDir = null;
+      setSetTimeIsSet(false);
+      this.setTime = false;
     }
 
     public byte[] getLogin() {
@@ -29259,12 +29295,12 @@ import org.slf4j.LoggerFactory;
       return login;
     }
 
-    public getSplits_args setLogin(byte[] login) {
+    public importDirectory_args setLogin(byte[] login) {
       setLogin(login == null ? (ByteBuffer)null : ByteBuffer.wrap(login));
       return this;
     }
 
-    public getSplits_args setLogin(ByteBuffer login) {
+    public importDirectory_args setLogin(ByteBuffer login) {
       this.login = login;
       return this;
     }
@@ -29288,7 +29324,7 @@ import org.slf4j.LoggerFactory;
       return this.tableName;
     }
 
-    public getSplits_args setTableName(String tableName) {
+    public importDirectory_args setTableName(String tableName) {
       this.tableName = tableName;
       return this;
     }
@@ -29308,27 +29344,75 @@ import org.slf4j.LoggerFactory;
       }
     }
 
-    public int getMaxSplits() {
-      return this.maxSplits;
+    public String getImportDir() {
+      return this.importDir;
     }
 
-    public getSplits_args setMaxSplits(int maxSplits) {
-      this.maxSplits = maxSplits;
-      setMaxSplitsIsSet(true);
+    public importDirectory_args setImportDir(String importDir) {
+      this.importDir = importDir;
       return this;
     }
 
-    public void unsetMaxSplits() {
-      __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __MAXSPLITS_ISSET_ID);
+    public void unsetImportDir() {
+      this.importDir = null;
     }
 
-    /** Returns true if field maxSplits is set (has been assigned a value) and false otherwise */
-    public boolean isSetMaxSplits() {
-      return EncodingUtils.testBit(__isset_bitfield, __MAXSPLITS_ISSET_ID);
+    /** Returns true if field importDir is set (has been assigned a value) and false otherwise */
+    public boolean isSetImportDir() {
+      return this.importDir != null;
     }
 
-    public void setMaxSplitsIsSet(boolean value) {
-      __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __MAXSPLITS_ISSET_ID, value);
+    public void setImportDirIsSet(boolean value) {
+      if (!value) {
+        this.importDir = null;
+      }
+    }
+
+    public String getFailureDir() {
+      return this.failureDir;
+    }
+
+    public importDirectory_args setFailureDir(String failureDir) {
+      this.failureDir = failureDir;
+      return this;
+    }
+
+    public void unsetFailureDir() {
+      this.failureDir = null;
+    }
+
+    /** Returns true if field failureDir is set (has been assigned a value) and false otherwise */
+    public boolean isSetFailureDir() {
+      return this.failureDir != null;
+    }
+
+    public void setFailureDirIsSet(boolean value) {
+      if (!value) {
+        this.failureDir = null;
+      }
+    }
+
+    public boolean isSetTime() {
+      return this.setTime;
+    }
+
+    public importDirectory_args setSetTime(boolean setTime) {
+      this.setTime = setTime;
+      setSetTimeIsSet(true);
+      return this;
+    }
+
+    public void unsetSetTime() {
+      __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __SETTIME_ISSET_ID);
+    }
+
+    /** Returns true if field setTime is set (has been assigned a value) and false otherwise */
+    public boolean isSetSetTime() {
+      return EncodingUtils.testBit(__isset_bitfield, __SETTIME_ISSET_ID);
+    }
+
+    public void setSetTimeIsSet(boolean value) {
+      __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __SETTIME_ISSET_ID, value);
     }
 
     public void setFieldValue(_Fields field, Object value) {
@@ -29349,11 +29433,27 @@ import org.slf4j.LoggerFactory;
         }
         break;
 
-      case MAX_SPLITS:
+      case IMPORT_DIR:
         if (value == null) {
-          unsetMaxSplits();
+          unsetImportDir();
         } else {
-          setMaxSplits((Integer)value);
+          setImportDir((String)value);
+        }
+        break;
+
+      case FAILURE_DIR:
+        if (value == null) {
+          unsetFailureDir();
+        } else {
+          setFailureDir((String)value);
+        }
+        break;
+
+      case SET_TIME:
+        if (value == null) {
+          unsetSetTime();
+        } else {
+          setSetTime((Boolean)value);
         }
         break;
 
@@ -29368,8 +29468,14 @@ import org.slf4j.LoggerFactory;
       case TABLE_NAME:
         return getTableName();
 
-      case MAX_SPLITS:
-        return Integer.valueOf(getMaxSplits());
+      case IMPORT_DIR:
+        return getImportDir();
+
+      case FAILURE_DIR:
+        return getFailureDir();
+
+      case SET_TIME:
+        return Boolean.valueOf(isSetTime());
 
       }
       throw new IllegalStateException();
@@ -29386,8 +29492,12 @@ import org.slf4j.LoggerFactory;
         return isSetLogin();
       case TABLE_NAME:
         return isSetTableName();
-      case MAX_SPLITS:
-        return isSetMaxSplits();
+      case IMPORT_DIR:
+        return isSetImportDir();
+      case FAILURE_DIR:
+        return isSetFailureDir();
+      case SET_TIME:
+        return isSetSetTime();
       }
       throw new IllegalStateException();
     }
@@ -29396,12 +29506,12 @@ import org.slf4j.LoggerFactory;
     public boolean equals(Object that) {
       if (that == null)
         return false;
-      if (that instanceof getSplits_args)
-        return this.equals((getSplits_args)that);
+      if (that instanceof importDirectory_args)
+        return this.equals((importDirectory_args)that);
       return false;
     }
 
-    public boolean equals(getSplits_args that) {
+    public boolean equals(importDirectory_args that) {
       if (that == null)
         return false;
 
@@ -29423,12 +29533,30 @@ import org.slf4j.LoggerFactory;
           return false;
       }
 
-      boolean this_present_maxSplits = true;
-      boolean that_present_maxSplits = true;
-      if (this_present_maxSplits || that_present_maxSplits) {
-        if (!(this_present_maxSplits && that_present_maxSplits))
+      boolean this_present_importDir = true && this.isSetImportDir();
+      boolean that_present_importDir = true && that.isSetImportDir();
+      if (this_present_importDir || that_present_importDir) {
+        if (!(this_present_importDir && that_present_importDir))
           return false;
-        if (this.maxSplits != that.maxSplits)
+        if (!this.importDir.equals(that.importDir))
+          return false;
+      }
+
+      boolean this_present_failureDir = true && this.isSetFailureDir();
+      boolean that_present_failureDir = true && that.isSetFailureDir();
+      if (this_present_failureDir || that_present_failureDir) {
+        if (!(this_present_failureDir && that_present_failureDir))
+          return false;
+        if (!this.failureDir.equals(that.failureDir))
+          return false;
+      }
+
+      boolean this_present_setTime = true;
+      boolean that_present_setTime = true;
+      if (this_present_setTime || that_present_setTime) {
+        if (!(this_present_setTime && that_present_setTime))
+          return false;
+        if (this.setTime != that.setTime)
           return false;
       }
 
@@ -29440,13 +29568,13 @@ import org.slf4j.LoggerFactory;
       return 0;
     }
 
-    public int compareTo(getSplits_args other) {
+    public int compareTo(importDirectory_args other) {
       if (!getClass().equals(other.getClass())) {
         return getClass().getName().compareTo(other.getClass().getName());
       }
 
       int lastComparison = 0;
-      getSplits_args typedOther = (getSplits_args)other;
+      importDirectory_args typedOther = (importDirectory_args)other;
 
       lastComparison = Boolean.valueOf(isSetLogin()).compareTo(typedOther.isSetLogin());
       if (lastComparison != 0) {
@@ -29468,12 +29596,32 @@ import org.slf4j.LoggerFactory;
           return lastComparison;
         }
       }
-      lastComparison = Boolean.valueOf(isSetMaxSplits()).compareTo(typedOther.isSetMaxSplits());
+      lastComparison = Boolean.valueOf(isSetImportDir()).compareTo(typedOther.isSetImportDir());
       if (lastComparison != 0) {
         return lastComparison;
       }
-      if (isSetMaxSplits()) {
-        lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.maxSplits, typedOther.maxSplits);
+      if (isSetImportDir()) {
+        lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.importDir, typedOther.importDir);
+        if (lastComparison != 0) {
+          return lastComparison;
+        }
+      }
+      lastComparison = Boolean.valueOf(isSetFailureDir()).compareTo(typedOther.isSetFailureDir());
+      if (lastComparison != 0) {
+        return lastComparison;
+      }
+      if (isSetFailureDir()) {
+        lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.failureDir, typedOther.failureDir);
+        if (lastComparison != 0) {
+          return lastComparison;
+        }
+      }
+      lastComparison = Boolean.valueOf(isSetSetTime()).compareTo(typedOther.isSetSetTime());
+      if (lastComparison != 0) {
+        return lastComparison;
+      }
+      if (isSetSetTime()) {
+        lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.setTime, typedOther.setTime);
         if (lastComparison != 0) {
           return lastComparison;
         }
@@ -29495,7 +29643,7 @@ import org.slf4j.LoggerFactory;
 
     @Override
     public String toString() {
-      StringBuilder sb = new StringBuilder("getSplits_args(");
+      StringBuilder sb = new StringBuilder("importDirectory_args(");
       boolean first = true;
 
       sb.append("login:");
@@ -29514,8 +29662,24 @@ import org.slf4j.LoggerFactory;
       }
       first = false;
       if (!first) sb.append(", ");
-      sb.append("maxSplits:");
-      sb.append(this.maxSplits);
+      sb.append("importDir:");
+      if (this.importDir == null) {
+        sb.append("null");
+      } else {
+        sb.append(this.importDir);
+      }
+      first = false;
+      if (!first) sb.append(", ");
+      sb.append("failureDir:");
+      if (this.failureDir == null) {
+        sb.append("null");
+      } else {
+        sb.append(this.failureDir);
+      }
+      first = false;
+      if (!first) sb.append(", ");
+      sb.append("setTime:");
+      sb.append(this.setTime);
       first = false;
       sb.append(")");
       return sb.toString();
@@ -29544,15 +29708,15 @@ import org.slf4j.LoggerFactory;
       }
     }
 
-    private static class getSplits_argsStandardSchemeFactory implements SchemeFactory {
-      public getSplits_argsStandardScheme getScheme() {
-        return new getSplits_argsStandardScheme();
+    private static class importDirectory_argsStandardSchemeFactory implements SchemeFactory {
+      public importDirectory_argsStandardScheme getScheme() {
+        return new importDirectory_argsStandardScheme();
       }
     }
 
-    private static class getSplits_argsStandardScheme extends StandardScheme<getSplits_args> {
+    private static class importDirectory_argsStandardScheme extends StandardScheme<importDirectory_args> {
 
-      public void read(org.apache.thrift.protocol.TProtocol iprot, getSplits_args struct) throws org.apache.thrift.TException {
+      public void read(org.apache.thrift.protocol.TProtocol iprot, importDirectory_args struct) throws org.apache.thrift.TException {
         org.apache.thrift.protocol.TField schemeField;
         iprot.readStructBegin();
         while (true)
@@ -29578,10 +29742,26 @@ import org.slf4j.LoggerFactory;
                 org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
               }
               break;
-            case 3: // MAX_SPLITS
-              if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
-                struct.maxSplits = iprot.readI32();
-                struct.setMaxSplitsIsSet(true);
+            case 3: // IMPORT_DIR
+              if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
+                struct.importDir = iprot.readString();
+                struct.setImportDirIsSet(true);
+              } else { 
+                org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+              }
+              break;
+            case 4: // FAILURE_DIR
+              if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
+                struct.failureDir = iprot.readString();
+                struct.setFailureDirIsSet(true);
+              } else { 
+                org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+              }
+              break;
+            case 5: // SET_TIME
+              if (schemeField.type == org.apache.thrift.protocol.TType.BOOL) {
+                struct.setTime = iprot.readBool();
+                struct.setSetTimeIsSet(true);
               } else { 
                 org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
               }
@@ -29597,7 +29777,7 @@ import org.slf4j.LoggerFactory;
         struct.validate();
       }
 
-      public void write(org.apache.thrift.protocol.TProtocol oprot, getSplits_args struct) throws org.apache.thrift.TException {
+      public void write(org.apache.thrift.protocol.TProtocol oprot, importDirectory_args struct) throws org.apache.thrift.TException {
         struct.validate();
 
         oprot.writeStructBegin(STRUCT_DESC);
@@ -29611,8 +29791,18 @@ import org.slf4j.LoggerFactory;
           oprot.writeString(struct.tableName);
           oprot.writeFieldEnd();
         }
-        oprot.writeFieldBegin(MAX_SPLITS_FIELD_DESC);
-        oprot.writeI32(struct.maxSplits);
+        if (struct.importDir != null) {
+          oprot.writeFieldBegin(IMPORT_DIR_FIELD_DESC);
+          oprot.writeString(struct.importDir);
+          oprot.writeFieldEnd();
+        }
+        if (struct.failureDir != null) {
+          oprot.writeFieldBegin(FAILURE_DIR_FIELD_DESC);
+          oprot.writeString(struct.failureDir);
+          oprot.writeFieldEnd();
+        }
+        oprot.writeFieldBegin(SET_TIME_FIELD_DESC);
+        oprot.writeBool(struct.setTime);
         oprot.writeFieldEnd();
         oprot.writeFieldStop();
         oprot.writeStructEnd();
@@ -29620,16 +29810,16 @@ import org.slf4j.LoggerFactory;
 
     }
 
-    private static class getSplits_argsTupleSchemeFactory implements SchemeFactory {
-      public getSplits_argsTupleScheme getScheme() {
-        return new getSplits_argsTupleScheme();
+    private static class importDirectory_argsTupleSchemeFactory implements SchemeFactory {
+      public importDirectory_argsTupleScheme getScheme() {
+        return new importDirectory_argsTupleScheme();
       }
     }
 
-    private static class getSplits_argsTupleScheme extends TupleScheme<getSplits_args> {
+    private static class importDirectory_argsTupleScheme extends TupleScheme<importDirectory_args> {
 
       @Override
-      public void write(org.apache.thrift.protocol.TProtocol prot, getSplits_args struct) throws org.apache.thrift.TException {
+      public void write(org.apache.thrift.protocol.TProtocol prot, importDirectory_args struct) throws org.apache.thrift.TException {
         TTupleProtocol oprot = (TTupleProtocol) prot;
         BitSet optionals = new BitSet();
         if (struct.isSetLogin()) {
@@ -29638,25 +29828,37 @@ import org.slf4j.LoggerFactory;
         if (struct.isSetTableName()) {
           optionals.set(1);
         }
-        if (struct.isSetMaxSplits()) {
+        if (struct.isSetImportDir()) {
           optionals.set(2);
         }
-        oprot.writeBitSet(optionals, 3);
+        if (struct.isSetFailureDir()) {
+          optionals.set(3);
+        }
+        if (struct.isSetSetTime()) {
+          optionals.set(4);
+        }
+        oprot.writeBitSet(optionals, 5);
         if (struct.isSetLogin()) {
           oprot.writeBinary(struct.login);
         }
         if (struct.isSetTableName()) {
           oprot.writeString(struct.tableName);
         }
-        if (struct.isSetMaxSplits()) {
-          oprot.writeI32(struct.maxSplits);
+        if (struct.isSetImportDir()) {
+          oprot.writeString(struct.importDir);
+        }
+        if (struct.isSetFailureDir()) {
+          oprot.writeString(struct.failureDir);
+        }
+        if (struct.isSetSetTime()) {
+          oprot.writeBool(struct.setTime);
         }
       }
 
       @Override
-      public void read(org.apache.thrift.protocol.TProtocol prot, getSplits_args struct) throws org.apache.thrift.TException {
+      public void read(org.apache.thrift.protocol.TProtocol prot, importDirectory_args struct) throws org.apache.thrift.TException {
         TTupleProtocol iprot = (TTupleProtocol) prot;
-        BitSet incoming = iprot.readBitSet(3);
+        BitSet incoming = iprot.readBitSet(5);
         if (incoming.get(0)) {
           struct.login = iprot.readBinary();
           struct.setLoginIsSet(true);
@@ -29666,33 +29868,44 @@ import org.slf4j.LoggerFactory;
           struct.setTableNameIsSet(true);
         }
         if (incoming.get(2)) {
-          struct.maxSplits = iprot.readI32();
-          struct.setMaxSplitsIsSet(true);
+          struct.importDir = iprot.readString();
+          struct.setImportDirIsSet(true);
+        }
+        if (incoming.get(3)) {
+          struct.failureDir = iprot.readString();
+          struct.setFailureDirIsSet(true);
+        }
+        if (incoming.get(4)) {
+          struct.setTime = iprot.readBool();
+          struct.setSetTimeIsSet(true);
         }
       }
     }
 
   }
 
-  public static class getSplits_result implements org.apache.thrift.TBase<getSplits_result, getSplits_result._Fields>, java.io.Serializable, Cloneable   {
-    private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("getSplits_result");
+  public static class importDirectory_result implements org.apache.thrift.TBase<importDirectory_result, importDirectory_result._Fields>, java.io.Serializable, Cloneable   {
+    private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("importDirectory_result");
 
-    private static final org.apache.thrift.protocol.TField SUCCESS_FIELD_DESC = new org.apache.thrift.protocol.TField("success", org.apache.thrift.protocol.TType.LIST, (short)0);
     private static final org.apache.thrift.protocol.TField OUCH1_FIELD_DESC = new org.apache.thrift.protocol.TField("ouch1", org.apache.thrift.protocol.TType.STRUCT, (short)1);
+    private static final org.apache.thrift.protocol.TField OUCH3_FIELD_DESC = new org.apache.thrift.protocol.TField("ouch3", org.apache.thrift.protocol.TType.STRUCT, (short)2);
+    private static final org.apache.thrift.protocol.TField OUCH4_FIELD_DESC = new org.apache.thrift.protocol.TField("ouch4", org.apache.thrift.protocol.TType.STRUCT, (short)3);
 
     private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
     static {
-      schemes.put(StandardScheme.class, new getSplits_resultStandardSchemeFactory());
-      schemes.put(TupleScheme.class, new getSplits_resultTupleSchemeFactory());
+      schemes.put(StandardScheme.class, new importDirectory_resultStandardSchemeFactory());
+      schemes.put(TupleScheme.class, new importDirectory_resultTupleSchemeFactory());
     }
 
-    public List<ByteBuffer> success; // required
     public TableNotFoundException ouch1; // required
+    public AccumuloException ouch3; // required
+    public AccumuloSecurityException ouch4; // required
 
     /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
     @SuppressWarnings("all") public enum _Fields implements org.apache.thrift.TFieldIdEnum {
-      SUCCESS((short)0, "success"),
-      OUCH1((short)1, "ouch1");
+      OUCH1((short)1, "ouch1"),
+      OUCH3((short)2, "ouch3"),
+      OUCH4((short)3, "ouch4");
 
       private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
 
@@ -29707,10 +29920,12 @@ import org.slf4j.LoggerFactory;
        */
       public static _Fields findByThriftId(int fieldId) {
         switch(fieldId) {
-          case 0: // SUCCESS
-            return SUCCESS;
           case 1: // OUCH1
             return OUCH1;
+          case 2: // OUCH3
+            return OUCH3;
+          case 3: // OUCH4
+            return OUCH4;
           default:
             return null;
         }
@@ -29754,133 +29969,151 @@ import org.slf4j.LoggerFactory;
     public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
     static {
       Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
-      tmpMap.put(_Fields.SUCCESS, new org.apache.thrift.meta_data.FieldMetaData("success", org.apache.thrift.TFieldRequirementType.DEFAULT, 
-          new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST, 
-              new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING              , true))));
       tmpMap.put(_Fields.OUCH1, new org.apache.thrift.meta_data.FieldMetaData("ouch1", org.apache.thrift.TFieldRequirementType.DEFAULT, 
           new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT)));
+      tmpMap.put(_Fields.OUCH3, new org.apache.thrift.meta_data.FieldMetaData("ouch3", org.apache.thrift.TFieldRequirementType.DEFAULT, 
+          new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT)));
+      tmpMap.put(_Fields.OUCH4, new org.apache.thrift.meta_data.FieldMetaData("ouch4", org.apache.thrift.TFieldRequirementType.DEFAULT, 
+          new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT)));
       metaDataMap = Collections.unmodifiableMap(tmpMap);
-      org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(getSplits_result.class, metaDataMap);
+      org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(importDirectory_result.class, metaDataMap);
     }
 
-    public getSplits_result() {
+    public importDirectory_result() {
     }
 
-    public getSplits_result(
-      List<ByteBuffer> success,
-      TableNotFoundException ouch1)
+    public importDirectory_result(
+      TableNotFoundException ouch1,
+      AccumuloException ouch3,
+      AccumuloSecurityException ouch4)
     {
       this();
-      this.success = success;
       this.ouch1 = ouch1;
+      this.ouch3 = ouch3;
+      this.ouch4 = ouch4;
     }
 
     /**
      * Performs a deep copy on <i>other</i>.
      */
-    public getSplits_result(getSplits_result other) {
-      if (other.isSetSuccess()) {
-        List<ByteBuffer> __this__success = new ArrayList<ByteBuffer>();
-        for (ByteBuffer other_element : other.success) {
-          ByteBuffer temp_binary_element = org.apache.thrift.TBaseHelper.copyBinary(other_element);
-;
-          __this__success.add(temp_binary_element);
-        }
-        this.success = __this__success;
-      }
+    public importDirectory_result(importDirectory_result other) {
       if (other.isSetOuch1()) {
         this.ouch1 = new TableNotFoundException(other.ouch1);
       }
+      if (other.isSetOuch3()) {
+        this.ouch3 = new AccumuloException(other.ouch3);
+      }
+      if (other.isSetOuch4()) {
+        this.ouch4 = new AccumuloSecurityException(other.ouch4);
+      }
     }
 
-    public getSplits_result deepCopy() {
-      return new getSplits_result(this);
+    public importDirectory_result deepCopy() {
+      return new importDirectory_result(this);
     }
 
     @Override
     public void clear() {
-      this.success = null;
       this.ouch1 = null;
+      this.ouch3 = null;
+      this.ouch4 = null;
     }
 
-    public int getSuccessSize() {
-      return (this.success == null) ? 0 : this.success.size();
+    public TableNotFoundException getOuch1() {
+      return this.ouch1;
     }
 
-    public java.util.Iterator<ByteBuffer> getSuccessIterator() {
-      return (this.success == null) ? null : this.success.iterator();
+    public importDirectory_result setOuch1(TableNotFoundException ouch1) {
+      this.ouch1 = ouch1;
+      return this;
     }
 
-    public void addToSuccess(ByteBuffer elem) {
-      if (this.success == null) {
-        this.success = new ArrayList<ByteBuffer>();
+    public void unsetOuch1() {
+      this.ouch1 = null;
+    }
+
+    /** Returns true if field ouch1 is set (has been assigned a value) and false otherwise */
+    public boolean isSetOuch1() {
+      return this.ouch1 != null;
+    }
+
+    public void setOuch1IsSet(boolean value) {
+      if (!value) {
+        this.ouch1 = null;
       }
-      this.success.add(elem);
     }
 
-    public List<ByteBuffer> getSuccess() {
-      return this.success;
+    public AccumuloException getOuch3() {
+      return this.ouch3;
     }
 
-    public getSplits_result setSuccess(List<ByteBuffer> success) {
-      this.success = success;
+    public importDirectory_result setOuch3(AccumuloException ouch3) {
+      this.ouch3 = ouch3;
       return this;
     }
 
-    public void unsetSuccess() {
-      this.success = null;
+    public void unsetOuch3() {
+      this.ouch3 = null;
     }
 
-    /** Returns true if field success is set (has been assigned a value) and false otherwise */
-    public boolean isSetSuccess() {
-      return this.success != null;
+    /** Returns true if field ouch3 is set (has been assigned a value) and false otherwise */
+    public boolean isSetOuch3() {
+      return this.ouch3 != null;
     }
 
-    public void setSuccessIsSet(boolean value) {
+    public void setOuch3IsSet(boolean value) {
       if (!value) {
-        this.success = null;
+        this.ouch3 = null;
       }
     }
 
-    public TableNotFoundException getOuch1() {
-      return this.ouch1;
+    public AccumuloSecurityException getOuch4() {
+      return this.ouch4;
     }
 
-    public getSplits_result setOuch1(TableNotFoundException ouch1) {
-      this.ouch1 = ouch1;
+    public importDirectory_result setOuch4(AccumuloSecurityException ouch4) {
+      this.ouch4 = ouch4;
       return this;
     }
 
-    public void unsetOuch1() {
-      this.ouch1 = null;
+    public void unsetOuch4() {
+      this.ouch4 = null;
     }
 
-    /** Returns true if field ouch1 is set (has been assigned a value) and false otherwise */
-    public boolean isSetOuch1() {
-      return this.ouch1 != null;
+    /** Returns true if field ouch4 is set (has been assigned a value) and false otherwise */
+    public boolean isSetOuch4() {
+      return this.ouch4 != null;
     }
 
-    public void setOuch1IsSet(boolean value) {
+    public void setOuch4IsSet(boolean value) {
       if (!value) {
-        this.ouch1 = null;
+        this.ouch4 = null;
       }
     }
 
     public void setFieldValue(_Fields field, Object value) {
       switch (field) {
-      case SUCCESS:
+      case OUCH1:
         if (value == null) {
-          unsetSuccess();
+          unsetOuch1();
         } else {
-          setSuccess((List<ByteBuffer>)value);
+          setOuch1((TableNotFoundException)value);
         }
         break;
 
-      case OUCH1:
+      case OUCH3:
         if (value == null) {
-          unsetOuch1();
+          unsetOuch3();
         } else {
-          setOuch1((TableNotFoundException)value);
+          setOuch3((AccumuloException)value);
+        }
+        break;
+
+      case OUCH4:
+        if (value == null) {
+          unsetOuch4();
+        } else {
+          setOuch4((AccumuloSecurityException)value);
         }
         break;
 
@@ -29889,12 +30122,15 @@ import org.slf4j.LoggerFactory;
 
     public Object getFieldValue(_Fields field) {
       switch (field) {
-      case SUCCESS:
-        return getSuccess();
-
       case OUCH1:
         return getOuch1();
 
+      case OUCH3:
+        return getOuch3();
+
+      case OUCH4:
+        return getOuch4();
+
       }
       throw new IllegalStateException();
     }
@@ -29906,10 +30142,12 @@ import org.slf4j.LoggerFactory;
       }
 
       switch (field) {
-      case SUCCESS:
-        return isSetSuccess();
       case OUCH1:
         return isSetOuch1();
+      case OUCH3:
+        return isSetOuch3();
+      case OUCH4:
+        return isSetOuch4();
       }
       throw new IllegalStateException();
     }
@@ -29918,24 +30156,15 @@ import org.slf4j.LoggerFactory;
     public boolean equals(Object that) {
       if (that == null)
         return false;
-      if (that instanceof getSplits_result)
-        return this.equals((getSplits_result)that);
+      if (that instanceof importDirectory_result)
+        return this.equals((importDirectory_result)that);
       return false;
     }
 
-    public boolean equals(getSplits_result that) {
+    public boolean equals(importDirectory_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_ouch1 = true && this.isSetOuch1();
       boolean that_present_ouch1 = true && that.isSetOuch1();
       if (this_present_ouch1 || that_present_ouch1) {
@@ -29945,6 +30174,24 @@ import org.slf4j.LoggerFactory;
           return false;
       }
 
+      boolean this_present_ouch3 = true && this.isSetOuch3();
+      boolean that_present_ouch3 = true && that.isSetOuch3();
+      if (this_present_ouch3 || that_present_ouch3) {
+        if (!(this_present_ouch3 && that_present_ouch3))
+          return false;
+        if (!this.ouch3.equals(that.ouch3))
+          return false;
+      }
+
+      boolean this_present_ouch4 = true && this.isSetOuch4();
+      boolean that_present_ouch4 = true && that.isSetOuch4();
+      if (this_present_ouch4 || that_present_ouch4) {
+        if (!(this_present_ouch4 && that_present_ouch4))
+          return false;
+        if (!this.ouch4.equals(that.ouch4))
+          return false;
+      }
+
       return true;
     }
 
@@ -29953,30 +30200,40 @@ import org.slf4j.LoggerFactory;
       return 0;
     }
 
-    public int compareTo(getSplits_result other) {
+    public int compareTo(importDirectory_result other) {
       if (!getClass().equals(other.getClass())) {
         return getClass().getName().compareTo(other.getClass().getName());
       }
 
       int lastComparison = 0;
-      getSplits_result typedOther = (getSplits_result)other;
+      importDirectory_result typedOther = (importDirectory_result)other;
 
-      lastComparison = Boolean.valueOf(isSetSuccess()).compareTo(typedOther.isSetSuccess());
+      lastComparison = Boolean.valueOf(isSetOuch1()).compareTo(typedOther.isSetOuch1());
       if (lastComparison != 0) {
         return lastComparison;
       }
-      if (isSetSuccess()) {
-        lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.success, typedOther.success);
+      if (isSetOuch1()) {
+        lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.ouch1, typedOther.ouch1);
         if (lastComparison != 0) {
           return lastComparison;
         }
       }
-      lastComparison = Boolean.valueOf(isSetOuch1()).compareTo(typedOther.isSetOuch1());
+      lastComparison = Boolean.valueOf(isSetOuch3()).compareTo(typedOther.isSetOuch3());
       if (lastComparison != 0) {
         return lastComparison;
       }
-      if (isSetOuch1()) {
-        lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.ouch1, typedOther.ouch1);
+      if (isSetOuch3()) {
+        lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.ouch3, typedOther.ouch3);
+        if (lastComparison != 0) {
+          return lastComparison;
+        }
+      }
+      lastComparison = Boolean.valueOf(isSetOuch4()).compareTo(typedOther.isSetOuch4());
+      if (lastComparison != 0) {
+        return lastComparison;
+      }
+      if (isSetOuch4()) {
+        lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.ouch4, typedOther.ouch4);
         if (lastComparison != 0) {
           return lastComparison;
         }
@@ -29998,22 +30255,30 @@ import org.slf4j.LoggerFactory;
 
     @Override
     public String toString() {
-      StringBuilder sb = new StringBuilder("getSplits_result(");
+      StringBuilder sb = new StringBuilder("importDirectory_result(");
       boolean first = true;
 
-      sb.append("success:");
-      if (this.success == null) {
+      sb.append("ouch1:");
+      if (this.ouch1 == null) {
         sb.append("null");
       } else {
-        sb.append(this.success);
+        sb.append(this.ouch1);
       }
       first = false;
       if (!first) sb.append(", ");
-      sb.append("ouch1:");
-      if (this.ouch1 == null) {
+      sb.append("ouch3:");
+      if (this.ouch3 == null) {
         sb.append("null");
       } else {
-        sb.append(this.ouch1);
+        sb.append(this.ouch3);
+      }
+      first = false;
+      if (!first) sb.append(", ");
+      sb.append("ouch4:");
+      if (this.ouch4 == null) {
+        sb.append("null");
+      } else {
+        sb.append(this.ouch4);
       }
       first = false;
       sb.append(")");
@@ -30041,15 +30306,15 @@ import org.slf4j.LoggerFactory;
       }
     }
 
-    private static class getSplits_resultStandardSchemeFactory implements SchemeFactory {
-      public getSplits_resultStandardScheme getScheme() {
-        return new getSplits_resultStandardScheme();
+    private static class importDirectory_resultStandardSchemeFactory implements SchemeFactory {
+      public importDirectory_resultStandardScheme getScheme() {
+        return new importDirectory_resultStandardScheme();
       }
     }
 
-    private static class getSplits_resultStandardScheme extends StandardScheme<getSplits_result> {
+    private static class importDirectory_resultStandardScheme extends StandardScheme<importDirectory_result> {
 
-      public void read(org.apache.thrift.protocol.TProtocol iprot, getSplits_result struct) throws org.apache.thrift.TException {
+      public void read(org.apache.thrift.protocol.TProtocol iprot, importDirectory_result struct) throws org.apache.thrift.TException {
         org.apache.thrift.protocol.TField schemeField;
         iprot.readStructBegin();
         while (true)
@@ -30059,24 +30324,6 @@ import org.slf4j.LoggerFactory;
             break;
           }
           switch (schemeField.id) {
-            case 0: // SUCCESS
-              if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
-                {
-                  org.apache.thrift.protocol.TList _list210 = iprot.readListBegin();
-                  struct.success = new ArrayList<ByteBuffer>(_list210.size);
-                  for (int _i211 = 0; _i211 < _list210.size; ++_i211)
-                  {
-                    ByteBuffer _elem212; // required
-                    _elem212 = iprot.readBinary();
-                    struct.success.add(_elem212);
-                  }
-                  iprot.readListEnd();
-                }
-                struct.setSuccessIsSet(true);
-              } else { 
-                org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
-              }
-              break;
             case 1: // OUCH1
               if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
                 struct.ouch1 = new TableNotFoundException();
@@ -30086,6 +30333,24 @@ import org.slf4j.LoggerFactory;
                 org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
               }
               break;
+            case 2: // OUCH3
+              if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
+                struct.ouch3 = new AccumuloException();
+                struct.ouch3.read(iprot);
+                struct.setOuch3IsSet(true);
+              } else { 
+                org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+              }
+              break;
+            case 3: // OUCH4
+              if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
+                struct.ouch4 = new AccumuloSecurityException();
+                struct.ouch4.read(iprot);
+                struct.setOuch4IsSet(true);
+              } else { 
+                org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+              }
+              break;
             default:
               org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
           }
@@ -30097,121 +30362,110 @@ import org.slf4j.LoggerFactory;
         struct.validate();
       }
 
-      public void write(org.apache.thrift.protocol.TProtocol oprot, getSplits_result struct) throws org.apache.thrift.TException {
+      public void write(org.apache.thrift.protocol.TProtocol oprot, importDirectory_result struct) throws org.apache.thrift.TException {
         struct.validate();
 
         oprot.writeStructBegin(STRUCT_DESC);
-        if (struct.success != null) {
-          oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
-          {
-            oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.success.size()));
-            for (ByteBuffer _iter213 : struct.success)
-            {
-              oprot.writeBinary(_iter213);
-            }
-            oprot.writeListEnd();
-          }
-          oprot.writeFieldEnd();
-        }
         if (struct.ouch1 != null) {
           oprot.writeFieldBegin(OUCH1_FIELD_DESC);
           struct.ouch1.write(oprot);
           oprot.writeFieldEnd();
         }
+        if (struct.ouch3 != null) {
+          oprot.writeFieldBegin(OUCH3_FIELD_DESC);
+          struct.ouch3.write(oprot);
+          oprot.writeFieldEnd();
+        }
+        if (struct.ouch4 != null) {
+          oprot.writeFieldBegin(OUCH4_FIELD_DESC);
+          struct.ouch4.write(oprot);
+          oprot.writeFieldEnd();
+        }
         oprot.writeFieldStop();
         oprot.writeStructEnd();
       }
 
     }
 
-    private static class getSplits_resultTupleSchemeFactory implements SchemeFactory {
-      public getSplits_resultTupleScheme getScheme() {
-        return new getSplits_resultTupleScheme();
+    private static class importDirectory_resultTupleSchemeFactory implements SchemeFactory {
+      public importDirectory_resultTupleScheme getScheme() {
+        return new importDirectory_resultTupleScheme();
       }
     }
 
-    private static class getSplits_resultTupleScheme extends TupleScheme<getSplits_result> {
+    private static class importDirectory_resultTupleScheme extends TupleScheme<importDirectory_result> {
 
       @Override
-      public void write(org.apache.thrift.protocol.TProtocol prot, getSplits_result struct) throws org.apache.thrift.TException {
+      public void write(org.apache.thrift.protocol.TProtocol prot, importDirectory_result struct) throws org.apache.thrift.TException {
         TTupleProtocol oprot = (TTupleProtocol) prot;
         BitSet optionals = new BitSet();
-        if (struct.isSetSuccess()) {
+        if (struct.isSetOuch1()) {
           optionals.set(0);
         }
-        if (struct.isSetOuch1()) {
+        if (struct.isSetOuch3()) {
           optionals.set(1);
         }
-        oprot.writeBitSet(optionals, 2);
-        if (struct.isSetSuccess()) {
-          {
-            oprot.writeI32(struct.success.size());
-            for (ByteBuffer _iter214 : struct.success)
-            {
-              oprot.writeBinary(_iter214);
-            }
-          }
+        if (struct.isSetOuch4()) {
+          optionals.set(2);
         }
+        oprot.writeBitSet(optionals, 3);
         if (struct.isSetOuch1()) {
           struct.ouch1.write(oprot);
         }
+        if (struct.isSetOuch3()) {
+          struct.ouch3.write(oprot);
+        }
+        if (struct.isSetOuch4()) {
+          struct.ouch4.write(oprot);
+        }
       }
 
       @Override
-      public void read(org.apache.thrift.protocol.TProtocol prot, getSplits_result struct) throws org.apache.thrift.TException {
+      public void read(org.apache.thrift.protocol.TProtocol prot, importDirectory_result struct) throws org.apache.thrift.TException {
         TTupleProtocol iprot = (TTupleProtocol) prot;
-        BitSet incoming = iprot.readBitSet(2);
+        BitSet incoming = iprot.readBitSet(3);
         if (incoming.get(0)) {
-          {
-            org.apache.thrift.protocol.TList _list215 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
-            struct.success = new ArrayList<ByteBuffer>(_list215.size);
-            for (int _i216 = 0; _i216 < _list215.size; ++_i216)
-            {
-              ByteBuffer _elem217; // required
-              _elem217 = iprot.readBinary();
-              struct.success.add(_elem217);
-            }
-          }
-          struct.setSuccessIsSet(true);
-        }
-        if (incoming.get(1)) {
           struct.ouch1 = new TableNotFoundException();
           struct.ouch1.read(iprot);
           struct.setOuch1IsSet(true);
         }
+        if (incoming.get(1)) {
+          struct.ouch3 = new AccumuloException();
+          struct.ouch3.read(iprot);
+          struct.setOuch3IsSet(true);
+        }
+        if (incoming.get(2)) {
+          struct.ouch4 = new AccumuloSecurityException();
+          struct.ouch4.read(iprot);
+          struct.setOuch4IsSet(true);
+        }
       }
     }
 
   }
 
-  public static class importDirectory_args implements org.apache.thrift.TBase<importDirectory_args, importDirectory_args._Fields>, java.io.Serializable, Cloneable   {
-    private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("importDirectory_args");
+  public static class importTable_args implements org.apache.thrift.TBase<importTable_args, importTable_args._Fields>, java.io.Serializable, Cloneable   {
+    private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("importTable_args");
 
     private static final org.apache.thrift.protocol.TField LOGIN_FIELD_DESC = new org.apache.thrift.protocol.TField("login", org.apache.thrift.protocol.TType.STRING, (short)1);
     private static final org.apache.thrift.protocol.TField TABLE_NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("tableName", org.apache.thrift.protocol.TType.STRING, (short)2);
     private static final org.apache.thrift.protocol.TField IMPORT_DIR_FIELD_DESC = new org.apache.thrift.protocol.TField("importDir", org.apache.thrift.protocol.TType.STRING, (short)3);
-    private static final org.apache.thrift.protocol.TField FAILURE_DIR_FIELD_DESC = new org.apache.thrift.protocol.TField("failureDir", org.apache.thrift.protocol.TType.STRING, (short)4);
-    private static final org.apache.thrift.protocol.TField SET_TIME_FIELD_DESC = new org.apache.thrift.protocol.TField("setTime", org.apache.thrift.protocol.TType.BOOL, (short)5);
 
     private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
     static {
-      schemes.put(StandardScheme.class, new importDirectory_argsStandardSchemeFactory());
-      schemes.put(TupleScheme.class, new importDirectory_argsTupleSchemeFactory());
+      schemes.put(StandardScheme.class, new importTable_argsStandardSchemeFactory());
+      schemes.put(TupleScheme.class, new importTable_argsTupleSchemeFactory());
     }
 
     public ByteBuffer login; // required
     public String tableName; // required
     public String importDir; // required
-    public String failureDir; // required
-    public boolean setTime; // required
 
     /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
     @SuppressWarnings("all") public enum _Fields implements org.apache.thrift.TFieldIdEnum {
       LOGIN((short)1, "login"),
       TABLE_NAME((short)2, "tableName"),
-      IMPORT_DIR((short)3, "importDir"),
-      FAILURE_DIR((short)4, "failureDir"),
-      SET_TIME((short)5, "setTime");
+      IMPORT_DIR((short)3, "importDir");
 
       private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
 
@@ -30232,10 +30486,6 @@ import org.slf4j.LoggerFactory;
             return TABLE_NAME;
           case 3: // IMPORT_DIR
             return IMPORT_DIR;
-          case 4: // FAILURE_DIR
-            return FAILURE_DIR;
-          case 5: // SET_TIME
-            return SET_TIME;
           default:
             return null;
         }
@@ -30276,8 +30526,6 @@ import org.slf4j.LoggerFactory;
     }
 
     // isset id assignments
-    private static final int __SETTIME_ISSET_ID = 0;
-    private byte __isset_bitfield = 0;
     public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
     static {
       Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
@@ -30287,38 +30535,28 @@ import org.slf4j.LoggerFactory;
           new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
       tmpMap.put(_Fields.IMPORT_DIR, new org.apache.thrift.meta_data.FieldMetaData("importDir", org.apache.thrift.TFieldRequirementType.DEFAULT, 
           new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
-      tmpMap.put(_Fields.FAILURE_DIR, new org.apache.thrift.meta_data.FieldMetaData("failureDir", org.apache.thrift.TFieldRequirementType.DEFAULT, 
-          new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
-      tmpMap.put(_Fields.SET_TIME, new org.apache.thrift.meta_data.FieldMetaData("setTime", org.apache.thrift.TFieldRequirementType.DEFAULT, 
-          new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.BOOL)));
       metaDataMap = Collections.unmodifiableMap(tmpMap);
-      org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(importDirectory_args.class, metaDataMap);
+      org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(importTable_args.class, metaDataMap);
     }
 
-    public importDirectory_args() {
+    public importTable_args() {
     }
 
-    public importDirectory_args(
+    public importTable_args(
       ByteBuffer login,
       String tableName,
-      String importDir,
-      String failureDir,
-      boolean setTime)
+      String importDir)
     {
       this();
       this.login = login;
       this.tableName = tableName;
       this.importDir = importDir;
-      this.failureDir = failureDir;
-      this.setTime = setTime;
-      setSetTimeIsSet(true);
     }
 
     /**
      * Performs a deep copy on <i>other</i>.
      */
-    public importDirectory_args(importDirectory_args other) {
-      __isset_bitfield = other.__isset_bitfield;
+    public importTable_args(importTable_args other) {
       if (other.isSetLogin()) {
         this.login = org.apache.thrift.TBaseHelper.copyBinary(other.login);
 ;
@@ -30329,14 +30567,10 @@ import org.slf4j.LoggerFactory;
       if (other.isSetImportDir()) {
         this.importDir = other.importDir;
       }
-      if (other.isSetFailureDir()) {
-        this.failureDir = other.failureDir;
-      }
-      this.setTime = other.setTime;
     }
 
-    public importDirectory_args deepCopy() {
-      return new importDirectory_args(this);
+    public importTable_args deepCopy() {
+      return new importTable_args(this);
     }
 
     @Override
@@ -30344,9 +30578,6 @@ import org.slf4j.LoggerFactory;
       this.login = null;
       this.tableName = null;
       this.importDir = null;
-      this.failureDir = null;
-      setSetTimeIsSet(false);
-      this.setTime = false;
     }
 
     public byte[] getLogin() {
@@ -30358,12 +30589,12 @@ import org.slf4j.LoggerFactory;
       return login;
     }
 
-    public importDirectory_args setLogin(byte[] login) {
+    public importTable_args setLogin(byte[] login) {
       setLogin(login == null ? (ByteBuffer)null : ByteBuffer.wrap(login));
       return this;
     }
 
-    public importDirectory_args setLogin(ByteBuffer login) {
+    public importTable_args setLogin(ByteBuffer login) {
       this.login = login;
       return this;
     }
@@ -30387,7 +30618,7 @@ import org.slf4j.LoggerFactory;
       return this.tableName;
     }
 
-    public importDirectory_args setTableName(String tableName) {
+    public importTable_args setTableName(String tableName) {
       this.tableName = tableName;
       return this;
     }
@@ -30411,7 +30642,7 @@ import org.slf4j.LoggerFactory;
       return this.importDir;
     }
 
-    public importDirectory_args setImportDir(String importDir) {
+    public importTable_args setImportDir(String importDir) {
       this.importDir = importDir;
       return this;
     }
@@ -30431,53 +30662,6 @@ import org.slf4j.LoggerFactory;
       }
     }
 
-    public String getFailureDir() {
-      return this.failureDir;
-    }
-
-    public importDirectory_args setFailureDir(String failureDir) {
-      this.failureDir = failureDir;
-      return this;
-    }
-
-    public void unsetFailureDir() {
-      this.failureDir = null;
-    }
-
-    /** Returns true if field failureDir is set (has been assigned a value) and false otherwise */
-    public boolean isSetFailureDir() {
-      return this.failureDir != null;
-    }
-
-    public void setFailureDirIsSet(boolean value) {
-      if (!value) {
-        this.failureDir = null;
-      }
-    }
-
-    public boolean isSetTime() {
-      return this.setTime;
-    }
-
-    public importDirectory_args setSetTime(boolean setTime) {
-      this.setTime = setTime;
-      setSetTimeIsSet(true);
-      return this;
-    }
-
-    public void unsetSetTime() {
-      __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __SETTIME_ISSET_ID);
-    }
-
-    /** Returns true if field setTime is set (has been assigned a value) and false otherwise */
-    public boolean isSetSetTime() {
-      return EncodingUtils.testBit(__isset_bitfield, __SETTIME_ISSET_ID);
-    }
-
-    public void setSetTimeIsSet(boolean value) {
-      __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __SETTIME_ISSET_ID, value);
-    }
-
     public void setFieldValue(_Fields field, Object value) {
       switch (field) {
       case LOGIN:
@@ -30504,22 +30688,6 @@ import org.slf4j.LoggerFactory;
         }
         break;
 
-      case FAILURE_DIR:
-        if (value == null) {
-          unsetFailureDir();
-        } else {
-          setFailureDir((String)value);
-        }
-        break;
-
-      case SET_TIME:
-        if (value == null) {
-          unsetSetTime();
-        } else {
-          setSetTime((Boolean)value);
-        }
-        break;
-
       }
     }
 
@@ -30534,12 +30702,6 @@ import org.slf4j.LoggerFactory;
       case IMPORT_DIR:
         return getImportDir();
 
-      case FAILURE_DIR:
-        return getFailureDir();
-
-      case SET_TIME:
-        return Boolean.valueOf(isSetTime());
-
       }
       throw new IllegalStateException();
     }
@@ -30557,10 +30719,6 @@ import org.slf4j.LoggerFactory;
         return isSetTableName();
       case IMPORT_DIR:
         return isSetImportDir();
-      case FAILURE_DIR:
-        return isSetFailureDir();
-      case SET_TIME:
-        return isSetSetTime();
       }
       throw new IllegalStateException();
     }
@@ -30569,12 +30727,12 @@ import org.slf4j.LoggerFactory;
     public boolean equals(Object that) {
       if (that == null)
         return false;
-      if (that instanceof importDirectory_args)
-        return this.equals((importDirectory_args)that);
+      if (that instanceof importTable_args)
+        return this.equals((importTable_args)that);
       return false;
     }
 
-    public boolean equals(importDirectory_args that) {
+    public boolean equals(importTable_args that) {
       if (that == null)
         return false;
 
@@ -30605,24 +30763,6 @@ import org.slf4j.LoggerFactory;
           return false;
       }
 
-      boolean this_present_failureDir = true && this.isSetFailureDir();
-      boolean that_present_failureDir = true && that.isSetFailureDir();
-      if (this_present_failureDir || that_present_failureDir) {
-        if (!(this_present_failureDir && that_present_failureDir))
-          return false;
-        if (!this.failureDir.equals(that.failureDir))
-          return false;
-      }
-
-      boolean this_present_setTime = true;
-      boolean that_present_setTime = true;
-      if (this_present_setTime || that_present_setTime) {
-        if (!(this_present_setTime && that_present_setTime))
-          return false;
-        if (this.setTime != that.setTime)
-          return false;
-      }
-
       return true;
     }
 
@@ -30631,13 +30771,13 @@ import org.slf4j.LoggerFactory;
       return 0;
     }
 
-    public int compareTo(importDirectory_args other) {
+    public int compareTo(importTable_args other) {
       if (!getClass().equals(other.getClass())) {
         return getClass().getName().compareTo(other.getClass().getName());
       }
 
       int lastComparison = 0;
-      importDirectory_args typedOther = (importDirectory_args)other;
+      importTable_args typedOther = (importTable_args)other;
 
       lastComparison = Boolean.valueOf(isSetLogin()).compareTo(typedOther.isSetLogin());
       if (lastComparison != 0) {
@@ -30669,26 +30809,6 @@ import org.slf4j.LoggerFactory;
           return lastComparison;
         }
       }
-      lastComparison = Boolean.valueOf(isSetFailureDir()).compareTo(typedOther.isSetFailureDir());
-      if (lastComparison != 0) {
-        return lastComparison;
-      }
-      if (isSetFailureDir()) {
-        lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.failureDir, typedOther.failureDir);
-        if (lastComparison != 0) {
-          return lastComparison;
-        }
-      }
-      lastComparison = Boolean.valueOf(isSetSetTime()).compareTo(typedOther.isSetSetTime());
-      if (lastComparison != 0) {
-        return lastComparison;
-      }
-      if (isSetSetTime()) {
-        lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.setTime, typedOther.setTime);
-        if (lastComparison != 0) {
-          return lastComparison;
-        }
-      }
       return 0;
     }
 
@@ -30706,7 +30826,7 @@ import org.slf4j.LoggerFactory;
 
     @Override
     public String toString() {
-      StringBuilder sb = new StringBuilder("importDirectory_args(");
+      StringBuilder sb = new StringBuilder("importTable_args(");
       boolean first = true;
 
       sb.append("login:");
@@ -30732,18 +30852,6 @@ import org.slf4j.LoggerFactory;
         sb.append(this.importDir);
       }
       first = false;
-      if (!first) sb.append(", ");
-      sb.append("failureDir:");
-      if (this.failureDir == null) {
-        sb.append("null");
-      } else {
-        sb.append(this.failureDir);
-      }
-      first = false;
-      if (!first) sb.append(", ");
-      sb.append("setTime:");
-      sb.append(this.setTime);
-      first = false;
       sb.append(")");
       return sb.toString();
     }
@@ -30763,23 +30871,21 @@ import org.slf4j.LoggerFactory;
 
     private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
       try {
-        // it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor.
-        __isset_bitfield = 0;
         read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
       } catch (org.apache.thrift.TException te) {
         throw new java.io.IOException(te);
       }
     }
 
-    private static class importDirectory_argsStandardSchemeFactory implements SchemeFactory {
-      public importDirectory_argsStandardScheme getScheme() {
-        return new importDirectory_argsStandardScheme();
+    private static class importTable_argsStandardSchemeFactory implements SchemeFactory {
+      public importTable_argsStandardScheme getScheme() {
+        return new importTable_argsStandardScheme();
       }
     }
 
-    private static class importDirectory_argsStandardScheme extends StandardScheme<importDirectory_args> {
+    private static class importTable_argsStandardScheme extends StandardScheme<importTable_args> {
 
-      public void read(org.apache.thrift.protocol.TProtocol iprot, importDirectory_args struct) throws org.apache.thrift.TException {
+      public void read(org.apache.thrift.protocol.TProtocol iprot, importTable_args struct) throws org.apache.thrift.TException {
         org.apache.thrift.protocol.TField schemeField;
         iprot.readStructBegin();
         while (true)
@@ -30813,22 +30919,6 @@ import org.slf4j.LoggerFactory;
                 org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
               }
               break;
-            case 4: // FAILURE_DIR
-              if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
-                struct.failureDir = iprot.readString();
-                struct.setFailureDirIsSet(true);
-              } else { 
-                org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
-              }
-              break;
-            case 5: // SET_TIME
-              if (schemeField.type == org.apache.thrift.protocol.TType.BOOL) {
-                struct.setTime = iprot.readBool();
-                struct.setSetTimeIsSet(true);
-              } else { 
-                org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
-              }
-              break;
             default:
               org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
           }
@@ -30840,7 +30930,7 @@ import org.slf4j.LoggerFactory;
         struct.validate();
       }
 
-      public void write(org.apache.thrift.protocol.TProtocol oprot, importDirectory_args struct) throws org.apache.thrift.TException {
+      public void write(org.apache.thrift.protocol.TProtocol oprot, importTable_args struct) throws org.apache.thrift.TException {
         struct.validate();
 
         oprot.writeStructBegin(STRUCT_DESC);
@@ -30859,30 +30949,22 @@ import org.slf4j.LoggerFactory;
           oprot.writeString(struct.importDir);
           oprot.writeFieldEnd();
         }
-        if (struct.failureDir != null) {
-          oprot.writeFieldBegin(FAILURE_DIR_FIELD_DESC);
-          oprot.writeString(struct.failureDir);
-          oprot.writeFieldEnd();
-        }
-        oprot.writeFieldBegin(SET_TIME_FIELD_DESC);
-        oprot.writeBool(struct.setTime);
-        oprot.writeFieldEnd();
         oprot.writeFieldStop();
         oprot.writeStructEnd();
       }
 
     }
 
-    private static class importDirectory_argsTupleSchemeFactory implements SchemeFactory {
-      public importDirectory_argsTupleScheme getScheme() {
-        return new importDirectory_argsTupleScheme();
+    private static class importTable_argsTupleSchemeFactory implements SchemeFactory {
+      public importTable_argsTupleScheme getScheme() {
+        return new importTable_argsTupleScheme();
       }
     }
 
-    private static class importDirectory_argsTupleScheme extends TupleScheme<importDirectory_args> {
+    private static class importTable_argsTupleScheme extends TupleScheme<importTable_args> {
 
       @Override
-      public void write(org.apache.thrift.protocol.TProtocol prot, importDirectory_args struct) throws org.apache.thrift.TException {
+      public void write(org.apache.thrift.protocol.TProtocol prot, importTable_args struct) throws org.apache.thrift.TException {
         TTupleProtocol oprot = (TTupleProtocol) prot;
         BitSet optionals = new BitSet();
         if (struct.isSetLogin()) {
@@ -30894,13 +30976,7 @@ import org.slf4j.LoggerFactory;
         if (struct.isSetImportDir()) {
           optionals.set(2);
         }
-        if (struct.isSetFailureDir()) {
-          optionals.set(3);
-        }
-        if (struct.isSetSetTime()) {
-          optionals.set(4);
-        }
-        oprot.writeBitSet(optionals, 5);
+        oprot.writeBitSet(optionals, 3);
         if (struct.isSetLogin()) {
           oprot.writeBinary(struct.login);
         }
@@ -30910,18 +30986,12 @@ import org.slf4j.LoggerFactory;
         if (struct.isSetImportDir()) {
           oprot.writeString(struct.importDir);
         }
-        if (struct.isSetFailureDir()) {
-          oprot.writeString(struct.failureDir);
-        }
-        if (struct.isSetSetTime()) {
-          oprot.writeBool(struct.setTime);
-        }
       }
 
       @Override
-      public void read(org.apache.thrift.protocol.TProtocol prot, importDirectory_args struct) throws org.apache.thrift.TException {
+      public void read(org.apache.thrift.protocol.TProtocol prot, importTable_args struct) throws org.apache.thrift.TException {
         TTupleProtocol iprot = (TTupleProtocol) prot;
-        BitSet incoming = iprot.readBitSet(5);
+        BitSet incoming = iprot.readBitSet(3);
         if (incoming.get(0)) {
           struct.login = iprot.readBinary();
           struct.setLoginIsSet(true);

[... 1474 lines stripped ...]


Mime
View raw message