You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by kt...@apache.org on 2013/03/15 02:16:52 UTC
svn commit: r1456739 [2/3] - in /accumulo/trunk: ./ assemble/ core/
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/mai...
Modified: accumulo/trunk/proxy/src/main/java/org/apache/accumulo/proxy/thrift/AccumuloProxy.java
URL: http://svn.apache.org/viewvc/accumulo/trunk/proxy/src/main/java/org/apache/accumulo/proxy/thrift/AccumuloProxy.java?rev=1456739&r1=1456738&r2=1456739&view=diff
==============================================================================
--- accumulo/trunk/proxy/src/main/java/org/apache/accumulo/proxy/thrift/AccumuloProxy.java (original)
+++ accumulo/trunk/proxy/src/main/java/org/apache/accumulo/proxy/thrift/AccumuloProxy.java Fri Mar 15 01:16:51 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 ...]