You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by vi...@apache.org on 2011/10/27 17:25:17 UTC
svn commit: r1189806 [21/46] - in /incubator/accumulo: branches/1.3/contrib/
branches/1.3/src/core/src/main/java/org/apache/accumulo/core/client/
branches/1.3/src/core/src/main/java/org/apache/accumulo/core/client/admin/
branches/1.3/src/core/src/main/...
Modified: incubator/accumulo/branches/1.3/src/core/src/main/java/org/apache/accumulo/core/tabletserver/thrift/TabletClientService.java
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.3/src/core/src/main/java/org/apache/accumulo/core/tabletserver/thrift/TabletClientService.java?rev=1189806&r1=1189805&r2=1189806&view=diff
==============================================================================
--- incubator/accumulo/branches/1.3/src/core/src/main/java/org/apache/accumulo/core/tabletserver/thrift/TabletClientService.java (original)
+++ incubator/accumulo/branches/1.3/src/core/src/main/java/org/apache/accumulo/core/tabletserver/thrift/TabletClientService.java Thu Oct 27 15:24:51 2011
@@ -5,91 +5,125 @@
*/
package org.apache.accumulo.core.tabletserver.thrift;
-
-
import org.apache.thrift.*;
import org.apache.thrift.meta_data.*;
import org.apache.thrift.protocol.*;
public class TabletClientService {
-
+
public interface Iface extends org.apache.accumulo.core.client.impl.thrift.ClientService.Iface {
-
- public org.apache.accumulo.core.data.thrift.InitialScan startScan(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, org.apache.accumulo.core.data.thrift.TKeyExtent extent, org.apache.accumulo.core.data.thrift.TRange range, java.util.List<org.apache.accumulo.core.data.thrift.TColumn> columns, int batchSize, java.util.List<org.apache.accumulo.core.data.thrift.IterInfo> ssiList, java.util.Map<String,java.util.Map<String,String>> ssio, java.util.List<byte[]> authorizations, boolean waitForWrites, boolean isolated) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, NotServingTabletException, TooManyFilesException, TException;
-
- public org.apache.accumulo.core.data.thrift.ScanResult continueScan(cloudtrace.thrift.TInfo tinfo, long scanID) throws NoSuchScanIDException, NotServingTabletException, TooManyFilesException, TException;
-
+
+ public org.apache.accumulo.core.data.thrift.InitialScan startScan(cloudtrace.thrift.TInfo tinfo,
+ org.apache.accumulo.core.security.thrift.AuthInfo credentials, org.apache.accumulo.core.data.thrift.TKeyExtent extent,
+ org.apache.accumulo.core.data.thrift.TRange range, java.util.List<org.apache.accumulo.core.data.thrift.TColumn> columns, int batchSize,
+ java.util.List<org.apache.accumulo.core.data.thrift.IterInfo> ssiList, java.util.Map<String,java.util.Map<String,String>> ssio,
+ java.util.List<byte[]> authorizations, boolean waitForWrites, boolean isolated)
+ throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, NotServingTabletException, TooManyFilesException, TException;
+
+ public org.apache.accumulo.core.data.thrift.ScanResult continueScan(cloudtrace.thrift.TInfo tinfo, long scanID) throws NoSuchScanIDException,
+ NotServingTabletException, TooManyFilesException, TException;
+
public void closeScan(cloudtrace.thrift.TInfo tinfo, long scanID) throws TException;
-
- public org.apache.accumulo.core.data.thrift.InitialMultiScan startMultiScan(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, java.util.Map<org.apache.accumulo.core.data.thrift.TKeyExtent,java.util.List<org.apache.accumulo.core.data.thrift.TRange>> batch, java.util.List<org.apache.accumulo.core.data.thrift.TColumn> columns, java.util.List<org.apache.accumulo.core.data.thrift.IterInfo> ssiList, java.util.Map<String,java.util.Map<String,String>> ssio, java.util.List<byte[]> authorizations, boolean waitForWrites) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException;
-
- public org.apache.accumulo.core.data.thrift.MultiScanResult continueMultiScan(cloudtrace.thrift.TInfo tinfo, long scanID) throws NoSuchScanIDException, TException;
-
+
+ public org.apache.accumulo.core.data.thrift.InitialMultiScan startMultiScan(cloudtrace.thrift.TInfo tinfo,
+ org.apache.accumulo.core.security.thrift.AuthInfo credentials,
+ java.util.Map<org.apache.accumulo.core.data.thrift.TKeyExtent,java.util.List<org.apache.accumulo.core.data.thrift.TRange>> batch,
+ java.util.List<org.apache.accumulo.core.data.thrift.TColumn> columns, java.util.List<org.apache.accumulo.core.data.thrift.IterInfo> ssiList,
+ java.util.Map<String,java.util.Map<String,String>> ssio, java.util.List<byte[]> authorizations, boolean waitForWrites)
+ throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException;
+
+ public org.apache.accumulo.core.data.thrift.MultiScanResult continueMultiScan(cloudtrace.thrift.TInfo tinfo, long scanID) throws NoSuchScanIDException,
+ TException;
+
public void closeMultiScan(cloudtrace.thrift.TInfo tinfo, long scanID) throws NoSuchScanIDException, TException;
-
- public long startUpdate(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException;
-
+
+ public long startUpdate(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials)
+ throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException;
+
public void setUpdateTablet(cloudtrace.thrift.TInfo tinfo, long updateID, org.apache.accumulo.core.data.thrift.TKeyExtent keyExtent) throws TException;
-
+
public void applyUpdate(cloudtrace.thrift.TInfo tinfo, long updateID, org.apache.accumulo.core.data.thrift.TMutation mutation) throws TException;
-
+
public org.apache.accumulo.core.data.thrift.UpdateErrors closeUpdate(cloudtrace.thrift.TInfo tinfo, long updateID) throws NoSuchScanIDException, TException;
-
- public void update(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, org.apache.accumulo.core.data.thrift.TKeyExtent keyExtent, org.apache.accumulo.core.data.thrift.TMutation mutation) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, NotServingTabletException, ConstraintViolationException, TException;
-
- public java.util.List<org.apache.accumulo.core.data.thrift.TKeyExtent> bulkImport(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, java.util.Map<org.apache.accumulo.core.data.thrift.TKeyExtent,java.util.Map<String,org.apache.accumulo.core.data.thrift.MapFileInfo>> files) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException;
-
- public void splitTablet(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, org.apache.accumulo.core.data.thrift.TKeyExtent extent, byte[] splitPoint) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, NotServingTabletException, TException;
-
- public void loadTablet(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String lock, org.apache.accumulo.core.data.thrift.TKeyExtent extent) throws TException;
-
- public void unloadTablet(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String lock, org.apache.accumulo.core.data.thrift.TKeyExtent extent, boolean save) throws TException;
-
- public void flush(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String lock, java.util.Set<String> tables) throws TException;
-
- public void useLoggers(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, java.util.Set<String> loggers) throws TException;
-
- public org.apache.accumulo.core.master.thrift.TabletServerStatus getTabletServerStatus(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException;
-
- public java.util.List<TabletStats> getTabletStats(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tableId) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException;
-
- public TabletStats getHistoricalStats(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException;
-
- public void halt(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String lock) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException;
-
- public java.util.List<ActiveScan> getActiveScans(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException;
-
+
+ public void update(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials,
+ org.apache.accumulo.core.data.thrift.TKeyExtent keyExtent, org.apache.accumulo.core.data.thrift.TMutation mutation)
+ throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, NotServingTabletException, ConstraintViolationException, TException;
+
+ public java.util.List<org.apache.accumulo.core.data.thrift.TKeyExtent> bulkImport(cloudtrace.thrift.TInfo tinfo,
+ org.apache.accumulo.core.security.thrift.AuthInfo credentials,
+ java.util.Map<org.apache.accumulo.core.data.thrift.TKeyExtent,java.util.Map<String,org.apache.accumulo.core.data.thrift.MapFileInfo>> files)
+ throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException;
+
+ public void splitTablet(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials,
+ org.apache.accumulo.core.data.thrift.TKeyExtent extent, byte[] splitPoint) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException,
+ NotServingTabletException, TException;
+
+ public void loadTablet(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String lock,
+ org.apache.accumulo.core.data.thrift.TKeyExtent extent) throws TException;
+
+ public void unloadTablet(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String lock,
+ org.apache.accumulo.core.data.thrift.TKeyExtent extent, boolean save) throws TException;
+
+ public void flush(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String lock, java.util.Set<String> tables)
+ throws TException;
+
+ public void useLoggers(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, java.util.Set<String> loggers)
+ throws TException;
+
+ public org.apache.accumulo.core.master.thrift.TabletServerStatus getTabletServerStatus(cloudtrace.thrift.TInfo tinfo,
+ org.apache.accumulo.core.security.thrift.AuthInfo credentials) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException;
+
+ public java.util.List<TabletStats> getTabletStats(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials,
+ String tableId) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException;
+
+ public TabletStats getHistoricalStats(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials)
+ throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException;
+
+ public void halt(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String lock)
+ throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException;
+
+ public java.util.List<ActiveScan> getActiveScans(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials)
+ throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException;
+
}
-
+
public static class Client extends org.apache.accumulo.core.client.impl.thrift.ClientService.Client implements TServiceClient, Iface {
public static class Factory implements TServiceClientFactory<Client> {
public Factory() {}
+
public Client getClient(TProtocol prot) {
return new Client(prot);
}
+
public Client getClient(TProtocol iprot, TProtocol oprot) {
return new Client(iprot, oprot);
}
}
-
- public Client(TProtocol prot)
- {
+
+ public Client(TProtocol prot) {
this(prot, prot);
}
-
- public Client(TProtocol iprot, TProtocol oprot)
- {
+
+ public Client(TProtocol iprot, TProtocol oprot) {
super(iprot, oprot);
}
-
- public org.apache.accumulo.core.data.thrift.InitialScan startScan(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, org.apache.accumulo.core.data.thrift.TKeyExtent extent, org.apache.accumulo.core.data.thrift.TRange range, java.util.List<org.apache.accumulo.core.data.thrift.TColumn> columns, int batchSize, java.util.List<org.apache.accumulo.core.data.thrift.IterInfo> ssiList, java.util.Map<String,java.util.Map<String,String>> ssio, java.util.List<byte[]> authorizations, boolean waitForWrites, boolean isolated) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, NotServingTabletException, TooManyFilesException, TException
- {
+
+ public org.apache.accumulo.core.data.thrift.InitialScan startScan(cloudtrace.thrift.TInfo tinfo,
+ org.apache.accumulo.core.security.thrift.AuthInfo credentials, org.apache.accumulo.core.data.thrift.TKeyExtent extent,
+ org.apache.accumulo.core.data.thrift.TRange range, java.util.List<org.apache.accumulo.core.data.thrift.TColumn> columns, int batchSize,
+ java.util.List<org.apache.accumulo.core.data.thrift.IterInfo> ssiList, java.util.Map<String,java.util.Map<String,String>> ssio,
+ java.util.List<byte[]> authorizations, boolean waitForWrites, boolean isolated)
+ throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, NotServingTabletException, TooManyFilesException, TException {
send_startScan(tinfo, credentials, extent, range, columns, batchSize, ssiList, ssio, authorizations, waitForWrites, isolated);
return recv_startScan();
}
-
- public void send_startScan(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, org.apache.accumulo.core.data.thrift.TKeyExtent extent, org.apache.accumulo.core.data.thrift.TRange range, java.util.List<org.apache.accumulo.core.data.thrift.TColumn> columns, int batchSize, java.util.List<org.apache.accumulo.core.data.thrift.IterInfo> ssiList, java.util.Map<String,java.util.Map<String,String>> ssio, java.util.List<byte[]> authorizations, boolean waitForWrites, boolean isolated) throws TException
- {
+
+ public void send_startScan(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials,
+ org.apache.accumulo.core.data.thrift.TKeyExtent extent, org.apache.accumulo.core.data.thrift.TRange range,
+ java.util.List<org.apache.accumulo.core.data.thrift.TColumn> columns, int batchSize,
+ java.util.List<org.apache.accumulo.core.data.thrift.IterInfo> ssiList, java.util.Map<String,java.util.Map<String,String>> ssio,
+ java.util.List<byte[]> authorizations, boolean waitForWrites, boolean isolated) throws TException {
oprot_.writeMessageBegin(new TMessage("startScan", TMessageType.CALL, ++seqid_));
startScan_args args = new startScan_args();
args.setTinfo(tinfo);
@@ -107,9 +141,9 @@ public class TabletClientService {
oprot_.writeMessageEnd();
oprot_.getTransport().flush();
}
-
- public org.apache.accumulo.core.data.thrift.InitialScan recv_startScan() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, NotServingTabletException, TooManyFilesException, TException
- {
+
+ public org.apache.accumulo.core.data.thrift.InitialScan recv_startScan() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException,
+ NotServingTabletException, TooManyFilesException, TException {
TMessage msg = iprot_.readMessageBegin();
if (msg.type == TMessageType.EXCEPTION) {
TApplicationException x = TApplicationException.read(iprot_);
@@ -136,15 +170,14 @@ public class TabletClientService {
}
throw new TApplicationException(TApplicationException.MISSING_RESULT, "startScan failed: unknown result");
}
-
- public org.apache.accumulo.core.data.thrift.ScanResult continueScan(cloudtrace.thrift.TInfo tinfo, long scanID) throws NoSuchScanIDException, NotServingTabletException, TooManyFilesException, TException
- {
+
+ public org.apache.accumulo.core.data.thrift.ScanResult continueScan(cloudtrace.thrift.TInfo tinfo, long scanID) throws NoSuchScanIDException,
+ NotServingTabletException, TooManyFilesException, TException {
send_continueScan(tinfo, scanID);
return recv_continueScan();
}
-
- public void send_continueScan(cloudtrace.thrift.TInfo tinfo, long scanID) throws TException
- {
+
+ public void send_continueScan(cloudtrace.thrift.TInfo tinfo, long scanID) throws TException {
oprot_.writeMessageBegin(new TMessage("continueScan", TMessageType.CALL, ++seqid_));
continueScan_args args = new continueScan_args();
args.setTinfo(tinfo);
@@ -153,9 +186,9 @@ public class TabletClientService {
oprot_.writeMessageEnd();
oprot_.getTransport().flush();
}
-
- public org.apache.accumulo.core.data.thrift.ScanResult recv_continueScan() throws NoSuchScanIDException, NotServingTabletException, TooManyFilesException, TException
- {
+
+ public org.apache.accumulo.core.data.thrift.ScanResult recv_continueScan() throws NoSuchScanIDException, NotServingTabletException, TooManyFilesException,
+ TException {
TMessage msg = iprot_.readMessageBegin();
if (msg.type == TMessageType.EXCEPTION) {
TApplicationException x = TApplicationException.read(iprot_);
@@ -182,14 +215,12 @@ public class TabletClientService {
}
throw new TApplicationException(TApplicationException.MISSING_RESULT, "continueScan failed: unknown result");
}
-
- public void closeScan(cloudtrace.thrift.TInfo tinfo, long scanID) throws TException
- {
+
+ public void closeScan(cloudtrace.thrift.TInfo tinfo, long scanID) throws TException {
send_closeScan(tinfo, scanID);
}
-
- public void send_closeScan(cloudtrace.thrift.TInfo tinfo, long scanID) throws TException
- {
+
+ public void send_closeScan(cloudtrace.thrift.TInfo tinfo, long scanID) throws TException {
oprot_.writeMessageBegin(new TMessage("closeScan", TMessageType.CALL, ++seqid_));
closeScan_args args = new closeScan_args();
args.setTinfo(tinfo);
@@ -198,15 +229,21 @@ public class TabletClientService {
oprot_.writeMessageEnd();
oprot_.getTransport().flush();
}
-
- public org.apache.accumulo.core.data.thrift.InitialMultiScan startMultiScan(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, java.util.Map<org.apache.accumulo.core.data.thrift.TKeyExtent,java.util.List<org.apache.accumulo.core.data.thrift.TRange>> batch, java.util.List<org.apache.accumulo.core.data.thrift.TColumn> columns, java.util.List<org.apache.accumulo.core.data.thrift.IterInfo> ssiList, java.util.Map<String,java.util.Map<String,String>> ssio, java.util.List<byte[]> authorizations, boolean waitForWrites) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException
- {
+
+ public org.apache.accumulo.core.data.thrift.InitialMultiScan startMultiScan(cloudtrace.thrift.TInfo tinfo,
+ org.apache.accumulo.core.security.thrift.AuthInfo credentials,
+ java.util.Map<org.apache.accumulo.core.data.thrift.TKeyExtent,java.util.List<org.apache.accumulo.core.data.thrift.TRange>> batch,
+ java.util.List<org.apache.accumulo.core.data.thrift.TColumn> columns, java.util.List<org.apache.accumulo.core.data.thrift.IterInfo> ssiList,
+ java.util.Map<String,java.util.Map<String,String>> ssio, java.util.List<byte[]> authorizations, boolean waitForWrites)
+ throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException {
send_startMultiScan(tinfo, credentials, batch, columns, ssiList, ssio, authorizations, waitForWrites);
return recv_startMultiScan();
}
-
- public void send_startMultiScan(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, java.util.Map<org.apache.accumulo.core.data.thrift.TKeyExtent,java.util.List<org.apache.accumulo.core.data.thrift.TRange>> batch, java.util.List<org.apache.accumulo.core.data.thrift.TColumn> columns, java.util.List<org.apache.accumulo.core.data.thrift.IterInfo> ssiList, java.util.Map<String,java.util.Map<String,String>> ssio, java.util.List<byte[]> authorizations, boolean waitForWrites) throws TException
- {
+
+ public void send_startMultiScan(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials,
+ java.util.Map<org.apache.accumulo.core.data.thrift.TKeyExtent,java.util.List<org.apache.accumulo.core.data.thrift.TRange>> batch,
+ java.util.List<org.apache.accumulo.core.data.thrift.TColumn> columns, java.util.List<org.apache.accumulo.core.data.thrift.IterInfo> ssiList,
+ java.util.Map<String,java.util.Map<String,String>> ssio, java.util.List<byte[]> authorizations, boolean waitForWrites) throws TException {
oprot_.writeMessageBegin(new TMessage("startMultiScan", TMessageType.CALL, ++seqid_));
startMultiScan_args args = new startMultiScan_args();
args.setTinfo(tinfo);
@@ -221,9 +258,9 @@ public class TabletClientService {
oprot_.writeMessageEnd();
oprot_.getTransport().flush();
}
-
- public org.apache.accumulo.core.data.thrift.InitialMultiScan recv_startMultiScan() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException
- {
+
+ public org.apache.accumulo.core.data.thrift.InitialMultiScan recv_startMultiScan() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException,
+ TException {
TMessage msg = iprot_.readMessageBegin();
if (msg.type == TMessageType.EXCEPTION) {
TApplicationException x = TApplicationException.read(iprot_);
@@ -244,15 +281,14 @@ public class TabletClientService {
}
throw new TApplicationException(TApplicationException.MISSING_RESULT, "startMultiScan failed: unknown result");
}
-
- public org.apache.accumulo.core.data.thrift.MultiScanResult continueMultiScan(cloudtrace.thrift.TInfo tinfo, long scanID) throws NoSuchScanIDException, TException
- {
+
+ public org.apache.accumulo.core.data.thrift.MultiScanResult continueMultiScan(cloudtrace.thrift.TInfo tinfo, long scanID) throws NoSuchScanIDException,
+ TException {
send_continueMultiScan(tinfo, scanID);
return recv_continueMultiScan();
}
-
- public void send_continueMultiScan(cloudtrace.thrift.TInfo tinfo, long scanID) throws TException
- {
+
+ public void send_continueMultiScan(cloudtrace.thrift.TInfo tinfo, long scanID) throws TException {
oprot_.writeMessageBegin(new TMessage("continueMultiScan", TMessageType.CALL, ++seqid_));
continueMultiScan_args args = new continueMultiScan_args();
args.setTinfo(tinfo);
@@ -261,9 +297,8 @@ public class TabletClientService {
oprot_.writeMessageEnd();
oprot_.getTransport().flush();
}
-
- public org.apache.accumulo.core.data.thrift.MultiScanResult recv_continueMultiScan() throws NoSuchScanIDException, TException
- {
+
+ public org.apache.accumulo.core.data.thrift.MultiScanResult recv_continueMultiScan() throws NoSuchScanIDException, TException {
TMessage msg = iprot_.readMessageBegin();
if (msg.type == TMessageType.EXCEPTION) {
TApplicationException x = TApplicationException.read(iprot_);
@@ -284,15 +319,13 @@ public class TabletClientService {
}
throw new TApplicationException(TApplicationException.MISSING_RESULT, "continueMultiScan failed: unknown result");
}
-
- public void closeMultiScan(cloudtrace.thrift.TInfo tinfo, long scanID) throws NoSuchScanIDException, TException
- {
+
+ public void closeMultiScan(cloudtrace.thrift.TInfo tinfo, long scanID) throws NoSuchScanIDException, TException {
send_closeMultiScan(tinfo, scanID);
recv_closeMultiScan();
}
-
- public void send_closeMultiScan(cloudtrace.thrift.TInfo tinfo, long scanID) throws TException
- {
+
+ public void send_closeMultiScan(cloudtrace.thrift.TInfo tinfo, long scanID) throws TException {
oprot_.writeMessageBegin(new TMessage("closeMultiScan", TMessageType.CALL, ++seqid_));
closeMultiScan_args args = new closeMultiScan_args();
args.setTinfo(tinfo);
@@ -301,9 +334,8 @@ public class TabletClientService {
oprot_.writeMessageEnd();
oprot_.getTransport().flush();
}
-
- public void recv_closeMultiScan() throws NoSuchScanIDException, TException
- {
+
+ public void recv_closeMultiScan() throws NoSuchScanIDException, TException {
TMessage msg = iprot_.readMessageBegin();
if (msg.type == TMessageType.EXCEPTION) {
TApplicationException x = TApplicationException.read(iprot_);
@@ -321,15 +353,14 @@ public class TabletClientService {
}
return;
}
-
- public long startUpdate(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException
- {
+
+ public long startUpdate(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials)
+ throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException {
send_startUpdate(tinfo, credentials);
return recv_startUpdate();
}
-
- public void send_startUpdate(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials) throws TException
- {
+
+ public void send_startUpdate(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials) throws TException {
oprot_.writeMessageBegin(new TMessage("startUpdate", TMessageType.CALL, ++seqid_));
startUpdate_args args = new startUpdate_args();
args.setTinfo(tinfo);
@@ -338,9 +369,8 @@ public class TabletClientService {
oprot_.writeMessageEnd();
oprot_.getTransport().flush();
}
-
- public long recv_startUpdate() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException
- {
+
+ public long recv_startUpdate() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException {
TMessage msg = iprot_.readMessageBegin();
if (msg.type == TMessageType.EXCEPTION) {
TApplicationException x = TApplicationException.read(iprot_);
@@ -361,14 +391,12 @@ public class TabletClientService {
}
throw new TApplicationException(TApplicationException.MISSING_RESULT, "startUpdate failed: unknown result");
}
-
- public void setUpdateTablet(cloudtrace.thrift.TInfo tinfo, long updateID, org.apache.accumulo.core.data.thrift.TKeyExtent keyExtent) throws TException
- {
+
+ public void setUpdateTablet(cloudtrace.thrift.TInfo tinfo, long updateID, org.apache.accumulo.core.data.thrift.TKeyExtent keyExtent) throws TException {
send_setUpdateTablet(tinfo, updateID, keyExtent);
}
-
- public void send_setUpdateTablet(cloudtrace.thrift.TInfo tinfo, long updateID, org.apache.accumulo.core.data.thrift.TKeyExtent keyExtent) throws TException
- {
+
+ public void send_setUpdateTablet(cloudtrace.thrift.TInfo tinfo, long updateID, org.apache.accumulo.core.data.thrift.TKeyExtent keyExtent) throws TException {
oprot_.writeMessageBegin(new TMessage("setUpdateTablet", TMessageType.CALL, ++seqid_));
setUpdateTablet_args args = new setUpdateTablet_args();
args.setTinfo(tinfo);
@@ -378,14 +406,12 @@ public class TabletClientService {
oprot_.writeMessageEnd();
oprot_.getTransport().flush();
}
-
- public void applyUpdate(cloudtrace.thrift.TInfo tinfo, long updateID, org.apache.accumulo.core.data.thrift.TMutation mutation) throws TException
- {
+
+ public void applyUpdate(cloudtrace.thrift.TInfo tinfo, long updateID, org.apache.accumulo.core.data.thrift.TMutation mutation) throws TException {
send_applyUpdate(tinfo, updateID, mutation);
}
-
- public void send_applyUpdate(cloudtrace.thrift.TInfo tinfo, long updateID, org.apache.accumulo.core.data.thrift.TMutation mutation) throws TException
- {
+
+ public void send_applyUpdate(cloudtrace.thrift.TInfo tinfo, long updateID, org.apache.accumulo.core.data.thrift.TMutation mutation) throws TException {
oprot_.writeMessageBegin(new TMessage("applyUpdate", TMessageType.CALL, ++seqid_));
applyUpdate_args args = new applyUpdate_args();
args.setTinfo(tinfo);
@@ -395,15 +421,13 @@ public class TabletClientService {
oprot_.writeMessageEnd();
oprot_.getTransport().flush();
}
-
- public org.apache.accumulo.core.data.thrift.UpdateErrors closeUpdate(cloudtrace.thrift.TInfo tinfo, long updateID) throws NoSuchScanIDException, TException
- {
+
+ public org.apache.accumulo.core.data.thrift.UpdateErrors closeUpdate(cloudtrace.thrift.TInfo tinfo, long updateID) throws NoSuchScanIDException, TException {
send_closeUpdate(tinfo, updateID);
return recv_closeUpdate();
}
-
- public void send_closeUpdate(cloudtrace.thrift.TInfo tinfo, long updateID) throws TException
- {
+
+ public void send_closeUpdate(cloudtrace.thrift.TInfo tinfo, long updateID) throws TException {
oprot_.writeMessageBegin(new TMessage("closeUpdate", TMessageType.CALL, ++seqid_));
closeUpdate_args args = new closeUpdate_args();
args.setTinfo(tinfo);
@@ -412,9 +436,8 @@ public class TabletClientService {
oprot_.writeMessageEnd();
oprot_.getTransport().flush();
}
-
- public org.apache.accumulo.core.data.thrift.UpdateErrors recv_closeUpdate() throws NoSuchScanIDException, TException
- {
+
+ public org.apache.accumulo.core.data.thrift.UpdateErrors recv_closeUpdate() throws NoSuchScanIDException, TException {
TMessage msg = iprot_.readMessageBegin();
if (msg.type == TMessageType.EXCEPTION) {
TApplicationException x = TApplicationException.read(iprot_);
@@ -435,15 +458,16 @@ public class TabletClientService {
}
throw new TApplicationException(TApplicationException.MISSING_RESULT, "closeUpdate failed: unknown result");
}
-
- public void update(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, org.apache.accumulo.core.data.thrift.TKeyExtent keyExtent, org.apache.accumulo.core.data.thrift.TMutation mutation) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, NotServingTabletException, ConstraintViolationException, TException
- {
+
+ public void update(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials,
+ org.apache.accumulo.core.data.thrift.TKeyExtent keyExtent, org.apache.accumulo.core.data.thrift.TMutation mutation)
+ throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, NotServingTabletException, ConstraintViolationException, TException {
send_update(tinfo, credentials, keyExtent, mutation);
recv_update();
}
-
- public void send_update(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, org.apache.accumulo.core.data.thrift.TKeyExtent keyExtent, org.apache.accumulo.core.data.thrift.TMutation mutation) throws TException
- {
+
+ public void send_update(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials,
+ org.apache.accumulo.core.data.thrift.TKeyExtent keyExtent, org.apache.accumulo.core.data.thrift.TMutation mutation) throws TException {
oprot_.writeMessageBegin(new TMessage("update", TMessageType.CALL, ++seqid_));
update_args args = new update_args();
args.setTinfo(tinfo);
@@ -454,9 +478,9 @@ public class TabletClientService {
oprot_.writeMessageEnd();
oprot_.getTransport().flush();
}
-
- public void recv_update() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, NotServingTabletException, ConstraintViolationException, TException
- {
+
+ public void recv_update() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, NotServingTabletException, ConstraintViolationException,
+ TException {
TMessage msg = iprot_.readMessageBegin();
if (msg.type == TMessageType.EXCEPTION) {
TApplicationException x = TApplicationException.read(iprot_);
@@ -480,15 +504,18 @@ public class TabletClientService {
}
return;
}
-
- public java.util.List<org.apache.accumulo.core.data.thrift.TKeyExtent> bulkImport(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, java.util.Map<org.apache.accumulo.core.data.thrift.TKeyExtent,java.util.Map<String,org.apache.accumulo.core.data.thrift.MapFileInfo>> files) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException
- {
+
+ public java.util.List<org.apache.accumulo.core.data.thrift.TKeyExtent> bulkImport(cloudtrace.thrift.TInfo tinfo,
+ org.apache.accumulo.core.security.thrift.AuthInfo credentials,
+ java.util.Map<org.apache.accumulo.core.data.thrift.TKeyExtent,java.util.Map<String,org.apache.accumulo.core.data.thrift.MapFileInfo>> files)
+ throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException {
send_bulkImport(tinfo, credentials, files);
return recv_bulkImport();
}
-
- public void send_bulkImport(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, java.util.Map<org.apache.accumulo.core.data.thrift.TKeyExtent,java.util.Map<String,org.apache.accumulo.core.data.thrift.MapFileInfo>> files) throws TException
- {
+
+ public void send_bulkImport(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials,
+ java.util.Map<org.apache.accumulo.core.data.thrift.TKeyExtent,java.util.Map<String,org.apache.accumulo.core.data.thrift.MapFileInfo>> files)
+ throws TException {
oprot_.writeMessageBegin(new TMessage("bulkImport", TMessageType.CALL, ++seqid_));
bulkImport_args args = new bulkImport_args();
args.setTinfo(tinfo);
@@ -498,9 +525,9 @@ public class TabletClientService {
oprot_.writeMessageEnd();
oprot_.getTransport().flush();
}
-
- public java.util.List<org.apache.accumulo.core.data.thrift.TKeyExtent> recv_bulkImport() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException
- {
+
+ public java.util.List<org.apache.accumulo.core.data.thrift.TKeyExtent> recv_bulkImport()
+ throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException {
TMessage msg = iprot_.readMessageBegin();
if (msg.type == TMessageType.EXCEPTION) {
TApplicationException x = TApplicationException.read(iprot_);
@@ -521,15 +548,16 @@ public class TabletClientService {
}
throw new TApplicationException(TApplicationException.MISSING_RESULT, "bulkImport failed: unknown result");
}
-
- public void splitTablet(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, org.apache.accumulo.core.data.thrift.TKeyExtent extent, byte[] splitPoint) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, NotServingTabletException, TException
- {
+
+ public void splitTablet(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials,
+ org.apache.accumulo.core.data.thrift.TKeyExtent extent, byte[] splitPoint) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException,
+ NotServingTabletException, TException {
send_splitTablet(tinfo, credentials, extent, splitPoint);
recv_splitTablet();
}
-
- public void send_splitTablet(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, org.apache.accumulo.core.data.thrift.TKeyExtent extent, byte[] splitPoint) throws TException
- {
+
+ public void send_splitTablet(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials,
+ org.apache.accumulo.core.data.thrift.TKeyExtent extent, byte[] splitPoint) throws TException {
oprot_.writeMessageBegin(new TMessage("splitTablet", TMessageType.CALL, ++seqid_));
splitTablet_args args = new splitTablet_args();
args.setTinfo(tinfo);
@@ -540,9 +568,8 @@ public class TabletClientService {
oprot_.writeMessageEnd();
oprot_.getTransport().flush();
}
-
- public void recv_splitTablet() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, NotServingTabletException, TException
- {
+
+ public void recv_splitTablet() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, NotServingTabletException, TException {
TMessage msg = iprot_.readMessageBegin();
if (msg.type == TMessageType.EXCEPTION) {
TApplicationException x = TApplicationException.read(iprot_);
@@ -563,14 +590,14 @@ public class TabletClientService {
}
return;
}
-
- public void loadTablet(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String lock, org.apache.accumulo.core.data.thrift.TKeyExtent extent) throws TException
- {
+
+ public void loadTablet(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String lock,
+ org.apache.accumulo.core.data.thrift.TKeyExtent extent) throws TException {
send_loadTablet(tinfo, credentials, lock, extent);
}
-
- public void send_loadTablet(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String lock, org.apache.accumulo.core.data.thrift.TKeyExtent extent) throws TException
- {
+
+ public void send_loadTablet(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String lock,
+ org.apache.accumulo.core.data.thrift.TKeyExtent extent) throws TException {
oprot_.writeMessageBegin(new TMessage("loadTablet", TMessageType.CALL, ++seqid_));
loadTablet_args args = new loadTablet_args();
args.setTinfo(tinfo);
@@ -581,14 +608,14 @@ public class TabletClientService {
oprot_.writeMessageEnd();
oprot_.getTransport().flush();
}
-
- public void unloadTablet(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String lock, org.apache.accumulo.core.data.thrift.TKeyExtent extent, boolean save) throws TException
- {
+
+ public void unloadTablet(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String lock,
+ org.apache.accumulo.core.data.thrift.TKeyExtent extent, boolean save) throws TException {
send_unloadTablet(tinfo, credentials, lock, extent, save);
}
-
- public void send_unloadTablet(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String lock, org.apache.accumulo.core.data.thrift.TKeyExtent extent, boolean save) throws TException
- {
+
+ public void send_unloadTablet(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String lock,
+ org.apache.accumulo.core.data.thrift.TKeyExtent extent, boolean save) throws TException {
oprot_.writeMessageBegin(new TMessage("unloadTablet", TMessageType.CALL, ++seqid_));
unloadTablet_args args = new unloadTablet_args();
args.setTinfo(tinfo);
@@ -600,14 +627,14 @@ public class TabletClientService {
oprot_.writeMessageEnd();
oprot_.getTransport().flush();
}
-
- public void flush(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String lock, java.util.Set<String> tables) throws TException
- {
+
+ public void flush(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String lock, java.util.Set<String> tables)
+ throws TException {
send_flush(tinfo, credentials, lock, tables);
}
-
- public void send_flush(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String lock, java.util.Set<String> tables) throws TException
- {
+
+ public void send_flush(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String lock,
+ java.util.Set<String> tables) throws TException {
oprot_.writeMessageBegin(new TMessage("flush", TMessageType.CALL, ++seqid_));
flush_args args = new flush_args();
args.setTinfo(tinfo);
@@ -618,14 +645,14 @@ public class TabletClientService {
oprot_.writeMessageEnd();
oprot_.getTransport().flush();
}
-
- public void useLoggers(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, java.util.Set<String> loggers) throws TException
- {
+
+ public void useLoggers(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, java.util.Set<String> loggers)
+ throws TException {
send_useLoggers(tinfo, credentials, loggers);
}
-
- public void send_useLoggers(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, java.util.Set<String> loggers) throws TException
- {
+
+ public void send_useLoggers(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, java.util.Set<String> loggers)
+ throws TException {
oprot_.writeMessageBegin(new TMessage("useLoggers", TMessageType.CALL, ++seqid_));
useLoggers_args args = new useLoggers_args();
args.setTinfo(tinfo);
@@ -635,15 +662,14 @@ public class TabletClientService {
oprot_.writeMessageEnd();
oprot_.getTransport().flush();
}
-
- public org.apache.accumulo.core.master.thrift.TabletServerStatus getTabletServerStatus(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException
- {
+
+ public org.apache.accumulo.core.master.thrift.TabletServerStatus getTabletServerStatus(cloudtrace.thrift.TInfo tinfo,
+ org.apache.accumulo.core.security.thrift.AuthInfo credentials) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException {
send_getTabletServerStatus(tinfo, credentials);
return recv_getTabletServerStatus();
}
-
- public void send_getTabletServerStatus(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials) throws TException
- {
+
+ public void send_getTabletServerStatus(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials) throws TException {
oprot_.writeMessageBegin(new TMessage("getTabletServerStatus", TMessageType.CALL, ++seqid_));
getTabletServerStatus_args args = new getTabletServerStatus_args();
args.setTinfo(tinfo);
@@ -652,9 +678,9 @@ public class TabletClientService {
oprot_.writeMessageEnd();
oprot_.getTransport().flush();
}
-
- public org.apache.accumulo.core.master.thrift.TabletServerStatus recv_getTabletServerStatus() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException
- {
+
+ public org.apache.accumulo.core.master.thrift.TabletServerStatus recv_getTabletServerStatus()
+ throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException {
TMessage msg = iprot_.readMessageBegin();
if (msg.type == TMessageType.EXCEPTION) {
TApplicationException x = TApplicationException.read(iprot_);
@@ -675,15 +701,15 @@ public class TabletClientService {
}
throw new TApplicationException(TApplicationException.MISSING_RESULT, "getTabletServerStatus failed: unknown result");
}
-
- public java.util.List<TabletStats> getTabletStats(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tableId) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException
- {
+
+ public java.util.List<TabletStats> getTabletStats(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials,
+ String tableId) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException {
send_getTabletStats(tinfo, credentials, tableId);
return recv_getTabletStats();
}
-
- public void send_getTabletStats(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tableId) throws TException
- {
+
+ public void send_getTabletStats(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tableId)
+ throws TException {
oprot_.writeMessageBegin(new TMessage("getTabletStats", TMessageType.CALL, ++seqid_));
getTabletStats_args args = new getTabletStats_args();
args.setTinfo(tinfo);
@@ -693,9 +719,8 @@ public class TabletClientService {
oprot_.writeMessageEnd();
oprot_.getTransport().flush();
}
-
- public java.util.List<TabletStats> recv_getTabletStats() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException
- {
+
+ public java.util.List<TabletStats> recv_getTabletStats() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException {
TMessage msg = iprot_.readMessageBegin();
if (msg.type == TMessageType.EXCEPTION) {
TApplicationException x = TApplicationException.read(iprot_);
@@ -716,15 +741,14 @@ public class TabletClientService {
}
throw new TApplicationException(TApplicationException.MISSING_RESULT, "getTabletStats failed: unknown result");
}
-
- public TabletStats getHistoricalStats(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException
- {
+
+ public TabletStats getHistoricalStats(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials)
+ throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException {
send_getHistoricalStats(tinfo, credentials);
return recv_getHistoricalStats();
}
-
- public void send_getHistoricalStats(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials) throws TException
- {
+
+ public void send_getHistoricalStats(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials) throws TException {
oprot_.writeMessageBegin(new TMessage("getHistoricalStats", TMessageType.CALL, ++seqid_));
getHistoricalStats_args args = new getHistoricalStats_args();
args.setTinfo(tinfo);
@@ -733,9 +757,8 @@ public class TabletClientService {
oprot_.writeMessageEnd();
oprot_.getTransport().flush();
}
-
- public TabletStats recv_getHistoricalStats() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException
- {
+
+ public TabletStats recv_getHistoricalStats() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException {
TMessage msg = iprot_.readMessageBegin();
if (msg.type == TMessageType.EXCEPTION) {
TApplicationException x = TApplicationException.read(iprot_);
@@ -756,15 +779,14 @@ public class TabletClientService {
}
throw new TApplicationException(TApplicationException.MISSING_RESULT, "getHistoricalStats failed: unknown result");
}
-
- public void halt(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String lock) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException
- {
+
+ public void halt(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String lock)
+ throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException {
send_halt(tinfo, credentials, lock);
recv_halt();
}
-
- public void send_halt(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String lock) throws TException
- {
+
+ public void send_halt(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String lock) throws TException {
oprot_.writeMessageBegin(new TMessage("halt", TMessageType.CALL, ++seqid_));
halt_args args = new halt_args();
args.setTinfo(tinfo);
@@ -774,9 +796,8 @@ public class TabletClientService {
oprot_.writeMessageEnd();
oprot_.getTransport().flush();
}
-
- public void recv_halt() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException
- {
+
+ public void recv_halt() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException {
TMessage msg = iprot_.readMessageBegin();
if (msg.type == TMessageType.EXCEPTION) {
TApplicationException x = TApplicationException.read(iprot_);
@@ -794,15 +815,14 @@ public class TabletClientService {
}
return;
}
-
- public java.util.List<ActiveScan> getActiveScans(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException
- {
+
+ public java.util.List<ActiveScan> getActiveScans(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials)
+ throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException {
send_getActiveScans(tinfo, credentials);
return recv_getActiveScans();
}
-
- public void send_getActiveScans(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials) throws TException
- {
+
+ public void send_getActiveScans(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials) throws TException {
oprot_.writeMessageBegin(new TMessage("getActiveScans", TMessageType.CALL, ++seqid_));
getActiveScans_args args = new getActiveScans_args();
args.setTinfo(tinfo);
@@ -811,9 +831,8 @@ public class TabletClientService {
oprot_.writeMessageEnd();
oprot_.getTransport().flush();
}
-
- public java.util.List<ActiveScan> recv_getActiveScans() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException
- {
+
+ public java.util.List<ActiveScan> recv_getActiveScans() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException {
TMessage msg = iprot_.readMessageBegin();
if (msg.type == TMessageType.EXCEPTION) {
TApplicationException x = TApplicationException.read(iprot_);
@@ -834,12 +853,13 @@ public class TabletClientService {
}
throw new TApplicationException(TApplicationException.MISSING_RESULT, "getActiveScans failed: unknown result");
}
-
+
}
+
public static class Processor extends org.apache.accumulo.core.client.impl.thrift.ClientService.Processor implements TProcessor {
private static final org.slf4j.Logger LOGGER = org.slf4j.LoggerFactory.getLogger(Processor.class.getName());
- public Processor(Iface iface)
- {
+
+ public Processor(Iface iface) {
super(iface);
iface_ = iface;
processMap_.put("startScan", new startScan());
@@ -865,17 +885,16 @@ public class TabletClientService {
processMap_.put("halt", new halt());
processMap_.put("getActiveScans", new getActiveScans());
}
-
+
private Iface iface_;
-
- public boolean process(TProtocol iprot, TProtocol oprot) throws TException
- {
+
+ public boolean process(TProtocol iprot, TProtocol oprot) throws TException {
TMessage msg = iprot.readMessageBegin();
ProcessFunction fn = processMap_.get(msg.name);
if (fn == null) {
TProtocolUtil.skip(iprot, TType.STRUCT);
iprot.readMessageEnd();
- TApplicationException x = new TApplicationException(TApplicationException.UNKNOWN_METHOD, "Invalid method name: '"+msg.name+"'");
+ TApplicationException x = new TApplicationException(TApplicationException.UNKNOWN_METHOD, "Invalid method name: '" + msg.name + "'");
oprot.writeMessageBegin(new TMessage(msg.name, TMessageType.EXCEPTION, msg.seqid));
x.write(oprot);
oprot.writeMessageEnd();
@@ -885,10 +904,9 @@ public class TabletClientService {
fn.process(msg.seqid, iprot, oprot);
return true;
}
-
+
private class startScan implements ProcessFunction {
- public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
- {
+ public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException {
startScan_args args = new startScan_args();
try {
args.read(iprot);
@@ -904,7 +922,8 @@ public class TabletClientService {
iprot.readMessageEnd();
startScan_result result = new startScan_result();
try {
- result.success = iface_.startScan(args.tinfo, args.credentials, args.extent, args.range, args.columns, args.batchSize, args.ssiList, args.ssio, args.authorizations, args.waitForWrites, args.isolated);
+ result.success = iface_.startScan(args.tinfo, args.credentials, args.extent, args.range, args.columns, args.batchSize, args.ssiList, args.ssio,
+ args.authorizations, args.waitForWrites, args.isolated);
} catch (org.apache.accumulo.core.security.thrift.ThriftSecurityException sec) {
result.sec = sec;
} catch (NotServingTabletException nste) {
@@ -925,12 +944,11 @@ public class TabletClientService {
oprot.writeMessageEnd();
oprot.getTransport().flush();
}
-
+
}
-
+
private class continueScan implements ProcessFunction {
- public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
- {
+ public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException {
continueScan_args args = new continueScan_args();
try {
args.read(iprot);
@@ -967,12 +985,11 @@ public class TabletClientService {
oprot.writeMessageEnd();
oprot.getTransport().flush();
}
-
+
}
-
+
private class closeScan implements ProcessFunction {
- public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
- {
+ public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException {
closeScan_args args = new closeScan_args();
try {
args.read(iprot);
@@ -990,10 +1007,9 @@ public class TabletClientService {
return;
}
}
-
+
private class startMultiScan implements ProcessFunction {
- public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
- {
+ public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException {
startMultiScan_args args = new startMultiScan_args();
try {
args.read(iprot);
@@ -1009,7 +1025,8 @@ public class TabletClientService {
iprot.readMessageEnd();
startMultiScan_result result = new startMultiScan_result();
try {
- result.success = iface_.startMultiScan(args.tinfo, args.credentials, args.batch, args.columns, args.ssiList, args.ssio, args.authorizations, args.waitForWrites);
+ result.success = iface_.startMultiScan(args.tinfo, args.credentials, args.batch, args.columns, args.ssiList, args.ssio, args.authorizations,
+ args.waitForWrites);
} catch (org.apache.accumulo.core.security.thrift.ThriftSecurityException sec) {
result.sec = sec;
} catch (Throwable th) {
@@ -1026,12 +1043,11 @@ public class TabletClientService {
oprot.writeMessageEnd();
oprot.getTransport().flush();
}
-
+
}
-
+
private class continueMultiScan implements ProcessFunction {
- public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
- {
+ public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException {
continueMultiScan_args args = new continueMultiScan_args();
try {
args.read(iprot);
@@ -1064,12 +1080,11 @@ public class TabletClientService {
oprot.writeMessageEnd();
oprot.getTransport().flush();
}
-
+
}
-
+
private class closeMultiScan implements ProcessFunction {
- public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
- {
+ public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException {
closeMultiScan_args args = new closeMultiScan_args();
try {
args.read(iprot);
@@ -1102,12 +1117,11 @@ public class TabletClientService {
oprot.writeMessageEnd();
oprot.getTransport().flush();
}
-
+
}
-
+
private class startUpdate implements ProcessFunction {
- public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
- {
+ public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException {
startUpdate_args args = new startUpdate_args();
try {
args.read(iprot);
@@ -1141,12 +1155,11 @@ public class TabletClientService {
oprot.writeMessageEnd();
oprot.getTransport().flush();
}
-
+
}
-
+
private class setUpdateTablet implements ProcessFunction {
- public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
- {
+ public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException {
setUpdateTablet_args args = new setUpdateTablet_args();
try {
args.read(iprot);
@@ -1164,10 +1177,9 @@ public class TabletClientService {
return;
}
}
-
+
private class applyUpdate implements ProcessFunction {
- public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
- {
+ public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException {
applyUpdate_args args = new applyUpdate_args();
try {
args.read(iprot);
@@ -1185,10 +1197,9 @@ public class TabletClientService {
return;
}
}
-
+
private class closeUpdate implements ProcessFunction {
- public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
- {
+ public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException {
closeUpdate_args args = new closeUpdate_args();
try {
args.read(iprot);
@@ -1221,12 +1232,11 @@ public class TabletClientService {
oprot.writeMessageEnd();
oprot.getTransport().flush();
}
-
+
}
-
+
private class update implements ProcessFunction {
- public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
- {
+ public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException {
update_args args = new update_args();
try {
args.read(iprot);
@@ -1263,12 +1273,11 @@ public class TabletClientService {
oprot.writeMessageEnd();
oprot.getTransport().flush();
}
-
+
}
-
+
private class bulkImport implements ProcessFunction {
- public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
- {
+ public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException {
bulkImport_args args = new bulkImport_args();
try {
args.read(iprot);
@@ -1301,12 +1310,11 @@ public class TabletClientService {
oprot.writeMessageEnd();
oprot.getTransport().flush();
}
-
+
}
-
+
private class splitTablet implements ProcessFunction {
- public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
- {
+ public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException {
splitTablet_args args = new splitTablet_args();
try {
args.read(iprot);
@@ -1341,12 +1349,11 @@ public class TabletClientService {
oprot.writeMessageEnd();
oprot.getTransport().flush();
}
-
+
}
-
+
private class loadTablet implements ProcessFunction {
- public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
- {
+ public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException {
loadTablet_args args = new loadTablet_args();
try {
args.read(iprot);
@@ -1364,10 +1371,9 @@ public class TabletClientService {
return;
}
}
-
+
private class unloadTablet implements ProcessFunction {
- public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
- {
+ public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException {
unloadTablet_args args = new unloadTablet_args();
try {
args.read(iprot);
@@ -1385,10 +1391,9 @@ public class TabletClientService {
return;
}
}
-
+
private class flush implements ProcessFunction {
- public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
- {
+ public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException {
flush_args args = new flush_args();
try {
args.read(iprot);
@@ -1406,10 +1411,9 @@ public class TabletClientService {
return;
}
}
-
+
private class useLoggers implements ProcessFunction {
- public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
- {
+ public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException {
useLoggers_args args = new useLoggers_args();
try {
args.read(iprot);
@@ -1427,10 +1431,9 @@ public class TabletClientService {
return;
}
}
-
+
private class getTabletServerStatus implements ProcessFunction {
- public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
- {
+ public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException {
getTabletServerStatus_args args = new getTabletServerStatus_args();
try {
args.read(iprot);
@@ -1463,12 +1466,11 @@ public class TabletClientService {
oprot.writeMessageEnd();
oprot.getTransport().flush();
}
-
+
}
-
+
private class getTabletStats implements ProcessFunction {
- public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
- {
+ public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException {
getTabletStats_args args = new getTabletStats_args();
try {
args.read(iprot);
@@ -1501,12 +1503,11 @@ public class TabletClientService {
oprot.writeMessageEnd();
oprot.getTransport().flush();
}
-
+
}
-
+
private class getHistoricalStats implements ProcessFunction {
- public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
- {
+ public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException {
getHistoricalStats_args args = new getHistoricalStats_args();
try {
args.read(iprot);
@@ -1539,12 +1540,11 @@ public class TabletClientService {
oprot.writeMessageEnd();
oprot.getTransport().flush();
}
-
+
}
-
+
private class halt implements ProcessFunction {
- public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
- {
+ public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException {
halt_args args = new halt_args();
try {
args.read(iprot);
@@ -1577,12 +1577,11 @@ public class TabletClientService {
oprot.writeMessageEnd();
oprot.getTransport().flush();
}
-
+
}
-
+
private class getActiveScans implements ProcessFunction {
- public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
- {
+ public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException {
getActiveScans_args args = new getActiveScans_args();
try {
args.read(iprot);
@@ -1615,27 +1614,27 @@ public class TabletClientService {
oprot.writeMessageEnd();
oprot.getTransport().flush();
}
-
+
}
-
+
}
-
+
@SuppressWarnings("serial")
- public static class startScan_args implements TBase<startScan_args, startScan_args._Fields>, java.io.Serializable, Cloneable {
+ public static class startScan_args implements TBase<startScan_args,startScan_args._Fields>, java.io.Serializable, Cloneable {
private static final TStruct STRUCT_DESC = new TStruct("startScan_args");
-
- private static final TField TINFO_FIELD_DESC = new TField("tinfo", TType.STRUCT, (short)11);
- private static final TField CREDENTIALS_FIELD_DESC = new TField("credentials", TType.STRUCT, (short)1);
- private static final TField EXTENT_FIELD_DESC = new TField("extent", TType.STRUCT, (short)2);
- private static final TField RANGE_FIELD_DESC = new TField("range", TType.STRUCT, (short)3);
- private static final TField COLUMNS_FIELD_DESC = new TField("columns", TType.LIST, (short)4);
- private static final TField BATCH_SIZE_FIELD_DESC = new TField("batchSize", TType.I32, (short)5);
- private static final TField SSI_LIST_FIELD_DESC = new TField("ssiList", TType.LIST, (short)6);
- private static final TField SSIO_FIELD_DESC = new TField("ssio", TType.MAP, (short)7);
- private static final TField AUTHORIZATIONS_FIELD_DESC = new TField("authorizations", TType.LIST, (short)8);
- private static final TField WAIT_FOR_WRITES_FIELD_DESC = new TField("waitForWrites", TType.BOOL, (short)9);
- private static final TField ISOLATED_FIELD_DESC = new TField("isolated", TType.BOOL, (short)10);
-
+
+ private static final TField TINFO_FIELD_DESC = new TField("tinfo", TType.STRUCT, (short) 11);
+ private static final TField CREDENTIALS_FIELD_DESC = new TField("credentials", TType.STRUCT, (short) 1);
+ private static final TField EXTENT_FIELD_DESC = new TField("extent", TType.STRUCT, (short) 2);
+ private static final TField RANGE_FIELD_DESC = new TField("range", TType.STRUCT, (short) 3);
+ private static final TField COLUMNS_FIELD_DESC = new TField("columns", TType.LIST, (short) 4);
+ private static final TField BATCH_SIZE_FIELD_DESC = new TField("batchSize", TType.I32, (short) 5);
+ private static final TField SSI_LIST_FIELD_DESC = new TField("ssiList", TType.LIST, (short) 6);
+ private static final TField SSIO_FIELD_DESC = new TField("ssio", TType.MAP, (short) 7);
+ private static final TField AUTHORIZATIONS_FIELD_DESC = new TField("authorizations", TType.LIST, (short) 8);
+ private static final TField WAIT_FOR_WRITES_FIELD_DESC = new TField("waitForWrites", TType.BOOL, (short) 9);
+ private static final TField ISOLATED_FIELD_DESC = new TField("isolated", TType.BOOL, (short) 10);
+
public cloudtrace.thrift.TInfo tinfo;
public org.apache.accumulo.core.security.thrift.AuthInfo credentials;
public org.apache.accumulo.core.data.thrift.TKeyExtent extent;
@@ -1647,34 +1646,34 @@ public class TabletClientService {
public java.util.List<byte[]> authorizations;
public boolean waitForWrites;
public boolean isolated;
-
+
/** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
public enum _Fields implements TFieldIdEnum {
- TINFO((short)11, "tinfo"),
- CREDENTIALS((short)1, "credentials"),
- EXTENT((short)2, "extent"),
- RANGE((short)3, "range"),
- COLUMNS((short)4, "columns"),
- BATCH_SIZE((short)5, "batchSize"),
- SSI_LIST((short)6, "ssiList"),
- SSIO((short)7, "ssio"),
- AUTHORIZATIONS((short)8, "authorizations"),
- WAIT_FOR_WRITES((short)9, "waitForWrites"),
- ISOLATED((short)10, "isolated");
-
- private static final java.util.Map<String, _Fields> byName = new java.util.HashMap<String, _Fields>();
-
+ TINFO((short) 11, "tinfo"),
+ CREDENTIALS((short) 1, "credentials"),
+ EXTENT((short) 2, "extent"),
+ RANGE((short) 3, "range"),
+ COLUMNS((short) 4, "columns"),
+ BATCH_SIZE((short) 5, "batchSize"),
+ SSI_LIST((short) 6, "ssiList"),
+ SSIO((short) 7, "ssio"),
+ AUTHORIZATIONS((short) 8, "authorizations"),
+ WAIT_FOR_WRITES((short) 9, "waitForWrites"),
+ ISOLATED((short) 10, "isolated");
+
+ private static final java.util.Map<String,_Fields> byName = new java.util.HashMap<String,_Fields>();
+
static {
for (_Fields field : java.util.EnumSet.allOf(_Fields.class)) {
byName.put(field.getFieldName(), field);
}
}
-
+
/**
* Find the _Fields constant that matches fieldId, or null if its not found.
*/
public static _Fields findByThriftId(int fieldId) {
- switch(fieldId) {
+ switch (fieldId) {
case 11: // TINFO
return TINFO;
case 1: // CREDENTIALS
@@ -1701,99 +1700,79 @@ public class TabletClientService {
return null;
}
}
-
+
/**
- * Find the _Fields constant that matches fieldId, throwing an exception
- * if it is not found.
+ * Find the _Fields constant that matches fieldId, throwing an exception if it is not found.
*/
public static _Fields findByThriftIdOrThrow(int fieldId) {
_Fields fields = findByThriftId(fieldId);
- if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
+ if (fields == null)
+ throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
return fields;
}
-
+
/**
* Find the _Fields constant that matches name, or null if its not found.
*/
public static _Fields findByName(String name) {
return byName.get(name);
}
-
+
private final short _thriftId;
private final String _fieldName;
-
+
_Fields(short thriftId, String fieldName) {
_thriftId = thriftId;
_fieldName = fieldName;
}
-
+
public short getThriftFieldId() {
return _thriftId;
}
-
+
public String getFieldName() {
return _fieldName;
}
}
-
+
// isset id assignments
private static final int __BATCHSIZE_ISSET_ID = 0;
private static final int __WAITFORWRITES_ISSET_ID = 1;
private static final int __ISOLATED_ISSET_ID = 2;
private java.util.BitSet __isset_bit_vector = new java.util.BitSet(3);
-
- public static final java.util.Map<_Fields, FieldMetaData> metaDataMap;
+
+ public static final java.util.Map<_Fields,FieldMetaData> metaDataMap;
static {
- java.util.Map<_Fields, FieldMetaData> tmpMap = new java.util.EnumMap<_Fields, FieldMetaData>(_Fields.class);
- tmpMap.put(_Fields.TINFO, new FieldMetaData("tinfo", TFieldRequirementType.DEFAULT,
- new StructMetaData(TType.STRUCT, cloudtrace.thrift.TInfo.class)));
- tmpMap.put(_Fields.CREDENTIALS, new FieldMetaData("credentials", TFieldRequirementType.DEFAULT,
- new StructMetaData(TType.STRUCT, org.apache.accumulo.core.security.thrift.AuthInfo.class)));
- tmpMap.put(_Fields.EXTENT, new FieldMetaData("extent", TFieldRequirementType.DEFAULT,
- new StructMetaData(TType.STRUCT, org.apache.accumulo.core.data.thrift.TKeyExtent.class)));
- tmpMap.put(_Fields.RANGE, new FieldMetaData("range", TFieldRequirementType.DEFAULT,
- new StructMetaData(TType.STRUCT, org.apache.accumulo.core.data.thrift.TRange.class)));
- tmpMap.put(_Fields.COLUMNS, new FieldMetaData("columns", TFieldRequirementType.DEFAULT,
- new ListMetaData(TType.LIST,
- new StructMetaData(TType.STRUCT, org.apache.accumulo.core.data.thrift.TColumn.class))));
- tmpMap.put(_Fields.BATCH_SIZE, new FieldMetaData("batchSize", TFieldRequirementType.DEFAULT,
- new FieldValueMetaData(TType.I32)));
- tmpMap.put(_Fields.SSI_LIST, new FieldMetaData("ssiList", TFieldRequirementType.DEFAULT,
- new ListMetaData(TType.LIST,
- new StructMetaData(TType.STRUCT, org.apache.accumulo.core.data.thrift.IterInfo.class))));
- tmpMap.put(_Fields.SSIO, new FieldMetaData("ssio", TFieldRequirementType.DEFAULT,
- new MapMetaData(TType.MAP,
- new FieldValueMetaData(TType.STRING),
- new MapMetaData(TType.MAP,
- new FieldValueMetaData(TType.STRING),
- new FieldValueMetaData(TType.STRING)))));
- tmpMap.put(_Fields.AUTHORIZATIONS, new FieldMetaData("authorizations", TFieldRequirementType.DEFAULT,
- new ListMetaData(TType.LIST,
- new FieldValueMetaData(TType.STRING))));
- tmpMap.put(_Fields.WAIT_FOR_WRITES, new FieldMetaData("waitForWrites", TFieldRequirementType.DEFAULT,
- new FieldValueMetaData(TType.BOOL)));
- tmpMap.put(_Fields.ISOLATED, new FieldMetaData("isolated", TFieldRequirementType.DEFAULT,
- new FieldValueMetaData(TType.BOOL)));
+ java.util.Map<_Fields,FieldMetaData> tmpMap = new java.util.EnumMap<_Fields,FieldMetaData>(_Fields.class);
+ tmpMap.put(_Fields.TINFO, new FieldMetaData("tinfo", TFieldRequirementType.DEFAULT, new StructMetaData(TType.STRUCT, cloudtrace.thrift.TInfo.class)));
+ tmpMap.put(_Fields.CREDENTIALS, new FieldMetaData("credentials", TFieldRequirementType.DEFAULT, new StructMetaData(TType.STRUCT,
+ org.apache.accumulo.core.security.thrift.AuthInfo.class)));
+ tmpMap.put(_Fields.EXTENT, new FieldMetaData("extent", TFieldRequirementType.DEFAULT, new StructMetaData(TType.STRUCT,
+ org.apache.accumulo.core.data.thrift.TKeyExtent.class)));
+ tmpMap.put(_Fields.RANGE, new FieldMetaData("range", TFieldRequirementType.DEFAULT, new StructMetaData(TType.STRUCT,
+ org.apache.accumulo.core.data.thrift.TRange.class)));
+ tmpMap.put(_Fields.COLUMNS, new FieldMetaData("columns", TFieldRequirementType.DEFAULT, new ListMetaData(TType.LIST, new StructMetaData(TType.STRUCT,
+ org.apache.accumulo.core.data.thrift.TColumn.class))));
+ tmpMap.put(_Fields.BATCH_SIZE, new FieldMetaData("batchSize", TFieldRequirementType.DEFAULT, new FieldValueMetaData(TType.I32)));
+ tmpMap.put(_Fields.SSI_LIST, new FieldMetaData("ssiList", TFieldRequirementType.DEFAULT, new ListMetaData(TType.LIST, new StructMetaData(TType.STRUCT,
+ org.apache.accumulo.core.data.thrift.IterInfo.class))));
+ tmpMap.put(_Fields.SSIO, new FieldMetaData("ssio", TFieldRequirementType.DEFAULT, new MapMetaData(TType.MAP, new FieldValueMetaData(TType.STRING),
+ new MapMetaData(TType.MAP, new FieldValueMetaData(TType.STRING), new FieldValueMetaData(TType.STRING)))));
+ tmpMap.put(_Fields.AUTHORIZATIONS, new FieldMetaData("authorizations", TFieldRequirementType.DEFAULT, new ListMetaData(TType.LIST,
+ new FieldValueMetaData(TType.STRING))));
+ tmpMap.put(_Fields.WAIT_FOR_WRITES, new FieldMetaData("waitForWrites", TFieldRequirementType.DEFAULT, new FieldValueMetaData(TType.BOOL)));
+ tmpMap.put(_Fields.ISOLATED, new FieldMetaData("isolated", TFieldRequirementType.DEFAULT, new FieldValueMetaData(TType.BOOL)));
metaDataMap = java.util.Collections.unmodifiableMap(tmpMap);
FieldMetaData.addStructMetaDataMap(startScan_args.class, metaDataMap);
}
-
- public startScan_args() {
- }
-
- public startScan_args(
- cloudtrace.thrift.TInfo tinfo,
- org.apache.accumulo.core.security.thrift.AuthInfo credentials,
- org.apache.accumulo.core.data.thrift.TKeyExtent extent,
- org.apache.accumulo.core.data.thrift.TRange range,
- java.util.List<org.apache.accumulo.core.data.thrift.TColumn> columns,
- int batchSize,
- java.util.List<org.apache.accumulo.core.data.thrift.IterInfo> ssiList,
- java.util.Map<String,java.util.Map<String,String>> ssio,
- java.util.List<byte[]> authorizations,
- boolean waitForWrites,
- boolean isolated)
- {
+
+ public startScan_args() {}
+
+ public startScan_args(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials,
+ org.apache.accumulo.core.data.thrift.TKeyExtent extent, org.apache.accumulo.core.data.thrift.TRange range,
+ java.util.List<org.apache.accumulo.core.data.thrift.TColumn> columns, int batchSize,
+ java.util.List<org.apache.accumulo.core.data.thrift.IterInfo> ssiList, java.util.Map<String,java.util.Map<String,String>> ssio,
+ java.util.List<byte[]> authorizations, boolean waitForWrites, boolean isolated) {
this();
this.tinfo = tinfo;
this.credentials = credentials;
@@ -1810,7 +1789,7 @@ public class TabletClientService {
this.isolated = isolated;
setIsolatedIsSet(true);
}
-
+
/**
* Performs a deep copy on <i>other</i>.
*/
@@ -1846,26 +1825,26 @@ public class TabletClientService {
}
if (other.isSetSsio()) {
java.util.Map<String,java.util.Map<String,String>> __this__ssio = new java.util.HashMap<String,java.util.Map<String,String>>();
- for (java.util.Map.Entry<String, java.util.Map<String,String>> other_element : other.ssio.entrySet()) {
-
+ for (java.util.Map.Entry<String,java.util.Map<String,String>> other_element : other.ssio.entrySet()) {
+
String other_element_key = other_element.getKey();
java.util.Map<String,String> other_element_value = other_element.getValue();
-
+
String __this__ssio_copy_key = other_element_key;
-
+
java.util.Map<String,String> __this__ssio_copy_value = new java.util.HashMap<String,String>();
- for (java.util.Map.Entry<String, String> other_element_value_element : other_element_value.entrySet()) {
-
+ for (java.util.Map.Entry<String,String> other_element_value_element : other_element_value.entrySet()) {
+
String other_element_value_element_key = other_element_value_element.getKey();
String other_element_value_element_value = other_element_value_element.getValue();
-
+
String __this__ssio_copy_value_copy_key = other_element_value_element_key;
-
+
String __this__ssio_copy_value_copy_value = other_element_value_element_value;
-
+
__this__ssio_copy_value.put(__this__ssio_copy_value_copy_key, __this__ssio_copy_value_copy_value);
}
-
+
__this__ssio.put(__this__ssio_copy_key, __this__ssio_copy_value);
}
this.ssio = __this__ssio;
@@ -1882,520 +1861,520 @@ public class TabletClientService {
this.waitForWrites = other.waitForWrites;
this.isolated = other.isolated;
}
-
+
public startScan_args deepCopy() {
return new startScan_args(this);
}
-
+
@Deprecated
public startScan_args clone() {
return new startScan_args(this);
}
-
+
public cloudtrace.thrift.TInfo getTinfo() {
return this.tinfo;
}
-
+
public startScan_args setTinfo(cloudtrace.thrift.TInfo tinfo) {
this.tinfo = tinfo;
return this;
}
-
+
public void unsetTinfo() {
this.tinfo = null;
}
-
+
/** Returns true if field tinfo is set (has been asigned a value) and false otherwise */
public boolean isSetTinfo() {
return this.tinfo != null;
}
-
+
public void setTinfoIsSet(boolean value) {
if (!value) {
this.tinfo = null;
}
}
-
+
public org.apache.accumulo.core.security.thrift.AuthInfo getCredentials() {
return this.credentials;
}
-
+
public startScan_args setCredentials(org.apache.accumulo.core.security.thrift.AuthInfo credentials) {
this.credentials = credentials;
return this;
}
-
+
public void unsetCredentials() {
this.credentials = null;
}
-
+
/** Returns true if field credentials is set (has been asigned a value) and false otherwise */
public boolean isSetCredentials() {
return this.credentials != null;
}
-
+
public void setCredentialsIsSet(boolean value) {
if (!value) {
this.credentials = null;
}
}
-
+
public org.apache.accumulo.core.data.thrift.TKeyExtent getExtent() {
return this.extent;
}
-
+
public startScan_args setExtent(org.apache.accumulo.core.data.thrift.TKeyExtent extent) {
this.extent = extent;
return this;
}
-
+
public void unsetExtent() {
this.extent = null;
}
-
+
/** Returns true if field extent is set (has been asigned a value) and false otherwise */
public boolean isSetExtent() {
return this.extent != null;
}
-
+
public void setExtentIsSet(boolean value) {
if (!value) {
this.extent = null;
}
}
-
+
public org.apache.accumulo.core.data.thrift.TRange getRange() {
return this.range;
}
-
+
public startScan_args setRange(org.apache.accumulo.core.data.thrift.TRange range) {
this.range = range;
return this;
}
-
+
public void unsetRange() {
this.range = null;
}
-
+
/** Returns true if field range is set (has been asigned a value) and false otherwise */
public boolean isSetRange() {
return this.range != null;
}
-
+
public void setRangeIsSet(boolean value) {
if (!value) {
this.range = null;
}
}
-
+
public int getColumnsSize() {
return (this.columns == null) ? 0 : this.columns.size();
}
-
+
public java.util.Iterator<org.apache.accumulo.core.data.thrift.TColumn> getColumnsIterator() {
return (this.columns == null) ? null : this.columns.iterator();
}
-
+
public void addToColumns(org.apache.accumulo.core.data.thrift.TColumn elem) {
if (this.columns == null) {
this.columns = new java.util.ArrayList<org.apache.accumulo.core.data.thrift.TColumn>();
}
this.columns.add(elem);
}
-
+
public java.util.List<org.apache.accumulo.core.data.thrift.TColumn> getColumns() {
return this.columns;
}
-
+
public startScan_args setColumns(java.util.List<org.apache.accumulo.core.data.thrift.TColumn> columns) {
this.columns = columns;
return this;
}
-
+
public void unsetColumns() {
this.columns = null;
}
-
+
/** Returns true if field columns is set (has been asigned a value) and false otherwise */
public boolean isSetColumns() {
return this.columns != null;
}
-
+
public void setColumnsIsSet(boolean value) {
if (!value) {
this.columns = null;
}
}
-
+
public int getBatchSize() {
return this.batchSize;
}
-
+
public startScan_args setBatchSize(int batchSize) {
this.batchSize = batchSize;
setBatchSizeIsSet(true);
return this;
}
-
+
public void unsetBatchSize() {
__isset_bit_vector.clear(__BATCHSIZE_ISSET_ID);
}
-
+
/** Returns true if field batchSize is set (has been asigned a value) and false otherwise */
public boolean isSetBatchSize() {
return __isset_bit_vector.get(__BATCHSIZE_ISSET_ID);
}
-
+
public void setBatchSizeIsSet(boolean value) {
__isset_bit_vector.set(__BATCHSIZE_ISSET_ID, value);
}
-
+
public int getSsiListSize() {
return (this.ssiList == null) ? 0 : this.ssiList.size();
}
-
+
public java.util.Iterator<org.apache.accumulo.core.data.thrift.IterInfo> getSsiListIterator() {
return (this.ssiList == null) ? null : this.ssiList.iterator();
}
-
+
public void addToSsiList(org.apache.accumulo.core.data.thrift.IterInfo elem) {
if (this.ssiList == null) {
this.ssiList = new java.util.ArrayList<org.apache.accumulo.core.data.thrift.IterInfo>();
}
this.ssiList.add(elem);
}
-
+
public java.util.List<org.apache.accumulo.core.data.thrift.IterInfo> getSsiList() {
return this.ssiList;
}
-
+
public startScan_args setSsiList(java.util.List<org.apache.accumulo.core.data.thrift.IterInfo> ssiList) {
this.ssiList = ssiList;
return this;
}
-
+
public void unsetSsiList() {
this.ssiList = null;
}
-
+
/** Returns true if field ssiList is set (has been asigned a value) and false otherwise */
public boolean isSetSsiList() {
return this.ssiList != null;
}
-
+
public void setSsiListIsSet(boolean value) {
if (!value) {
this.ssiList = null;
}
}
-
+
public int getSsioSize() {
return (this.ssio == null) ? 0 : this.ssio.size();
}
-
+
public void putToSsio(String key, java.util.Map<String,String> val) {
if (this.ssio == null) {
this.ssio = new java.util.HashMap<String,java.util.Map<String,String>>();
}
this.ssio.put(key, val);
}
-
+
public java.util.Map<String,java.util.Map<String,String>> getSsio() {
return this.ssio;
}
-
+
public startScan_args setSsio(java.util.Map<String,java.util.Map<String,String>> ssio) {
this.ssio = ssio;
return this;
}
-
+
public void unsetSsio() {
this.ssio = null;
}
-
+
/** Returns true if field ssio is set (has been asigned a value) and false otherwise */
public boolean isSetSsio() {
return this.ssio != null;
}
-
+
public void setSsioIsSet(boolean value) {
if (!value) {
this.ssio = null;
}
}
-
+
public int getAuthorizationsSize() {
return (this.authorizations == null) ? 0 : this.authorizations.size();
}
-
+
public java.util.Iterator<byte[]> getAuthorizationsIterator() {
return (this.authorizations == null) ? null : this.authorizations.iterator();
}
-
+
public void addToAuthorizations(byte[] elem) {
if (this.authorizations == null) {
this.authorizations = new java.util.ArrayList<byte[]>();
}
this.authorizations.add(elem);
}
-
+
public java.util.List<byte[]> getAuthorizations() {
return this.authorizations;
}
-
+
public startScan_args setAuthorizations(java.util.List<byte[]> authorizations) {
this.authorizations = authorizations;
return this;
}
-
+
public void unsetAuthorizations() {
this.authorizations = null;
}
-
+
/** Returns true if field authorizations is set (has been asigned a value) and false otherwise */
public boolean isSetAuthorizations() {
return this.authorizations != null;
}
-
+
public void setAuthorizationsIsSet(boolean value) {
if (!value) {
this.authorizations = null;
}
}
-
+
public boolean isWaitForWrites() {
return this.waitForWrites;
}
-
+
public startScan_args setWaitForWrites(boolean waitForWrites) {
this.waitForWrites = waitForWrites;
setWaitForWritesIsSet(true);
return this;
}
-
+
[... 19851 lines stripped ...]