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 2012/07/13 22:34:49 UTC
svn commit: r1361382 [11/16] - in /accumulo/branches/ACCUMULO-259: ./ bin/
conf/examples/1GB/native-standalone/ conf/examples/1GB/standalone/
conf/examples/2GB/native-standalone/ conf/examples/2GB/standalone/
conf/examples/3GB/native-standalone/ conf/e...
Modified: accumulo/branches/ACCUMULO-259/core/src/main/java/org/apache/accumulo/core/tabletserver/thrift/TabletClientService.java
URL: http://svn.apache.org/viewvc/accumulo/branches/ACCUMULO-259/core/src/main/java/org/apache/accumulo/core/tabletserver/thrift/TabletClientService.java?rev=1361382&r1=1361381&r2=1361382&view=diff
==============================================================================
--- accumulo/branches/ACCUMULO-259/core/src/main/java/org/apache/accumulo/core/tabletserver/thrift/TabletClientService.java (original)
+++ accumulo/branches/ACCUMULO-259/core/src/main/java/org/apache/accumulo/core/tabletserver/thrift/TabletClientService.java Fri Jul 13 20:34:44 2012
@@ -1,10 +1,17 @@
/**
- * Autogenerated by Thrift
+ * Autogenerated by Thrift Compiler (0.8.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ * @generated
*/
package org.apache.accumulo.core.tabletserver.thrift;
+import org.apache.thrift.scheme.IScheme;
+import org.apache.thrift.scheme.SchemeFactory;
+import org.apache.thrift.scheme.StandardScheme;
+
+import org.apache.thrift.scheme.TupleScheme;
+import org.apache.thrift.protocol.TTupleProtocol;
import java.util.List;
import java.util.ArrayList;
import java.util.Map;
@@ -130,7 +137,7 @@ import org.slf4j.LoggerFactory;
}
- public static class Client extends org.apache.accumulo.core.client.impl.thrift.ClientService.Client implements org.apache.thrift.TServiceClient, Iface {
+ public static class Client extends org.apache.accumulo.core.client.impl.thrift.ClientService.Client implements Iface {
public static class Factory implements org.apache.thrift.TServiceClientFactory<Client> {
public Factory() {}
public Client getClient(org.apache.thrift.protocol.TProtocol prot) {
@@ -143,11 +150,10 @@ import org.slf4j.LoggerFactory;
public Client(org.apache.thrift.protocol.TProtocol prot)
{
- this(prot, prot);
+ super(prot, prot);
}
- public Client(org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot)
- {
+ public Client(org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) {
super(iprot, oprot);
}
@@ -159,7 +165,6 @@ import org.slf4j.LoggerFactory;
public void send_startScan(org.apache.accumulo.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, List<org.apache.accumulo.core.data.thrift.TColumn> columns, int batchSize, List<org.apache.accumulo.core.data.thrift.IterInfo> ssiList, Map<String,Map<String,String>> ssio, List<ByteBuffer> authorizations, boolean waitForWrites, boolean isolated) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("startScan", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_));
startScan_args args = new startScan_args();
args.setTinfo(tinfo);
args.setCredentials(credentials);
@@ -172,25 +177,13 @@ import org.slf4j.LoggerFactory;
args.setAuthorizations(authorizations);
args.setWaitForWrites(waitForWrites);
args.setIsolated(isolated);
- args.write(oprot_);
- oprot_.writeMessageEnd();
- oprot_.getTransport().flush();
+ sendBase("startScan", args);
}
public org.apache.accumulo.core.data.thrift.InitialScan recv_startScan() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, NotServingTabletException, TooManyFilesException, org.apache.thrift.TException
{
- org.apache.thrift.protocol.TMessage msg = iprot_.readMessageBegin();
- if (msg.type == org.apache.thrift.protocol.TMessageType.EXCEPTION) {
- org.apache.thrift.TApplicationException x = org.apache.thrift.TApplicationException.read(iprot_);
- iprot_.readMessageEnd();
- throw x;
- }
- if (msg.seqid != seqid_) {
- throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.BAD_SEQUENCE_ID, "startScan failed: out of sequence response");
- }
startScan_result result = new startScan_result();
- result.read(iprot_);
- iprot_.readMessageEnd();
+ receiveBase(result, "startScan");
if (result.isSetSuccess()) {
return result.success;
}
@@ -214,29 +207,16 @@ import org.slf4j.LoggerFactory;
public void send_continueScan(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, long scanID) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("continueScan", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_));
continueScan_args args = new continueScan_args();
args.setTinfo(tinfo);
args.setScanID(scanID);
- args.write(oprot_);
- oprot_.writeMessageEnd();
- oprot_.getTransport().flush();
+ sendBase("continueScan", args);
}
public org.apache.accumulo.core.data.thrift.ScanResult recv_continueScan() throws NoSuchScanIDException, NotServingTabletException, TooManyFilesException, org.apache.thrift.TException
{
- org.apache.thrift.protocol.TMessage msg = iprot_.readMessageBegin();
- if (msg.type == org.apache.thrift.protocol.TMessageType.EXCEPTION) {
- org.apache.thrift.TApplicationException x = org.apache.thrift.TApplicationException.read(iprot_);
- iprot_.readMessageEnd();
- throw x;
- }
- if (msg.seqid != seqid_) {
- throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.BAD_SEQUENCE_ID, "continueScan failed: out of sequence response");
- }
continueScan_result result = new continueScan_result();
- result.read(iprot_);
- iprot_.readMessageEnd();
+ receiveBase(result, "continueScan");
if (result.isSetSuccess()) {
return result.success;
}
@@ -259,13 +239,10 @@ import org.slf4j.LoggerFactory;
public void send_closeScan(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, long scanID) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("closeScan", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_));
closeScan_args args = new closeScan_args();
args.setTinfo(tinfo);
args.setScanID(scanID);
- args.write(oprot_);
- oprot_.writeMessageEnd();
- oprot_.getTransport().flush();
+ sendBase("closeScan", args);
}
public org.apache.accumulo.core.data.thrift.InitialMultiScan startMultiScan(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, Map<org.apache.accumulo.core.data.thrift.TKeyExtent,List<org.apache.accumulo.core.data.thrift.TRange>> batch, List<org.apache.accumulo.core.data.thrift.TColumn> columns, List<org.apache.accumulo.core.data.thrift.IterInfo> ssiList, Map<String,Map<String,String>> ssio, List<ByteBuffer> authorizations, boolean waitForWrites) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, org.apache.thrift.TException
@@ -276,7 +253,6 @@ import org.slf4j.LoggerFactory;
public void send_startMultiScan(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, Map<org.apache.accumulo.core.data.thrift.TKeyExtent,List<org.apache.accumulo.core.data.thrift.TRange>> batch, List<org.apache.accumulo.core.data.thrift.TColumn> columns, List<org.apache.accumulo.core.data.thrift.IterInfo> ssiList, Map<String,Map<String,String>> ssio, List<ByteBuffer> authorizations, boolean waitForWrites) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("startMultiScan", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_));
startMultiScan_args args = new startMultiScan_args();
args.setTinfo(tinfo);
args.setCredentials(credentials);
@@ -286,25 +262,13 @@ import org.slf4j.LoggerFactory;
args.setSsio(ssio);
args.setAuthorizations(authorizations);
args.setWaitForWrites(waitForWrites);
- args.write(oprot_);
- oprot_.writeMessageEnd();
- oprot_.getTransport().flush();
+ sendBase("startMultiScan", args);
}
public org.apache.accumulo.core.data.thrift.InitialMultiScan recv_startMultiScan() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, org.apache.thrift.TException
{
- org.apache.thrift.protocol.TMessage msg = iprot_.readMessageBegin();
- if (msg.type == org.apache.thrift.protocol.TMessageType.EXCEPTION) {
- org.apache.thrift.TApplicationException x = org.apache.thrift.TApplicationException.read(iprot_);
- iprot_.readMessageEnd();
- throw x;
- }
- if (msg.seqid != seqid_) {
- throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.BAD_SEQUENCE_ID, "startMultiScan failed: out of sequence response");
- }
startMultiScan_result result = new startMultiScan_result();
- result.read(iprot_);
- iprot_.readMessageEnd();
+ receiveBase(result, "startMultiScan");
if (result.isSetSuccess()) {
return result.success;
}
@@ -322,29 +286,16 @@ import org.slf4j.LoggerFactory;
public void send_continueMultiScan(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, long scanID) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("continueMultiScan", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_));
continueMultiScan_args args = new continueMultiScan_args();
args.setTinfo(tinfo);
args.setScanID(scanID);
- args.write(oprot_);
- oprot_.writeMessageEnd();
- oprot_.getTransport().flush();
+ sendBase("continueMultiScan", args);
}
public org.apache.accumulo.core.data.thrift.MultiScanResult recv_continueMultiScan() throws NoSuchScanIDException, org.apache.thrift.TException
{
- org.apache.thrift.protocol.TMessage msg = iprot_.readMessageBegin();
- if (msg.type == org.apache.thrift.protocol.TMessageType.EXCEPTION) {
- org.apache.thrift.TApplicationException x = org.apache.thrift.TApplicationException.read(iprot_);
- iprot_.readMessageEnd();
- throw x;
- }
- if (msg.seqid != seqid_) {
- throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.BAD_SEQUENCE_ID, "continueMultiScan failed: out of sequence response");
- }
continueMultiScan_result result = new continueMultiScan_result();
- result.read(iprot_);
- iprot_.readMessageEnd();
+ receiveBase(result, "continueMultiScan");
if (result.isSetSuccess()) {
return result.success;
}
@@ -362,29 +313,16 @@ import org.slf4j.LoggerFactory;
public void send_closeMultiScan(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, long scanID) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("closeMultiScan", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_));
closeMultiScan_args args = new closeMultiScan_args();
args.setTinfo(tinfo);
args.setScanID(scanID);
- args.write(oprot_);
- oprot_.writeMessageEnd();
- oprot_.getTransport().flush();
+ sendBase("closeMultiScan", args);
}
public void recv_closeMultiScan() throws NoSuchScanIDException, org.apache.thrift.TException
{
- org.apache.thrift.protocol.TMessage msg = iprot_.readMessageBegin();
- if (msg.type == org.apache.thrift.protocol.TMessageType.EXCEPTION) {
- org.apache.thrift.TApplicationException x = org.apache.thrift.TApplicationException.read(iprot_);
- iprot_.readMessageEnd();
- throw x;
- }
- if (msg.seqid != seqid_) {
- throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.BAD_SEQUENCE_ID, "closeMultiScan failed: out of sequence response");
- }
closeMultiScan_result result = new closeMultiScan_result();
- result.read(iprot_);
- iprot_.readMessageEnd();
+ receiveBase(result, "closeMultiScan");
if (result.nssi != null) {
throw result.nssi;
}
@@ -399,29 +337,16 @@ import org.slf4j.LoggerFactory;
public void send_startUpdate(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("startUpdate", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_));
startUpdate_args args = new startUpdate_args();
args.setTinfo(tinfo);
args.setCredentials(credentials);
- args.write(oprot_);
- oprot_.writeMessageEnd();
- oprot_.getTransport().flush();
+ sendBase("startUpdate", args);
}
public long recv_startUpdate() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, org.apache.thrift.TException
{
- org.apache.thrift.protocol.TMessage msg = iprot_.readMessageBegin();
- if (msg.type == org.apache.thrift.protocol.TMessageType.EXCEPTION) {
- org.apache.thrift.TApplicationException x = org.apache.thrift.TApplicationException.read(iprot_);
- iprot_.readMessageEnd();
- throw x;
- }
- if (msg.seqid != seqid_) {
- throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.BAD_SEQUENCE_ID, "startUpdate failed: out of sequence response");
- }
startUpdate_result result = new startUpdate_result();
- result.read(iprot_);
- iprot_.readMessageEnd();
+ receiveBase(result, "startUpdate");
if (result.isSetSuccess()) {
return result.success;
}
@@ -438,15 +363,12 @@ import org.slf4j.LoggerFactory;
public void send_applyUpdates(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, long updateID, org.apache.accumulo.core.data.thrift.TKeyExtent keyExtent, List<org.apache.accumulo.core.data.thrift.TMutation> mutations) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("applyUpdates", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_));
applyUpdates_args args = new applyUpdates_args();
args.setTinfo(tinfo);
args.setUpdateID(updateID);
args.setKeyExtent(keyExtent);
args.setMutations(mutations);
- args.write(oprot_);
- oprot_.writeMessageEnd();
- oprot_.getTransport().flush();
+ sendBase("applyUpdates", args);
}
public org.apache.accumulo.core.data.thrift.UpdateErrors closeUpdate(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, long updateID) throws NoSuchScanIDException, org.apache.thrift.TException
@@ -457,29 +379,16 @@ import org.slf4j.LoggerFactory;
public void send_closeUpdate(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, long updateID) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("closeUpdate", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_));
closeUpdate_args args = new closeUpdate_args();
args.setTinfo(tinfo);
args.setUpdateID(updateID);
- args.write(oprot_);
- oprot_.writeMessageEnd();
- oprot_.getTransport().flush();
+ sendBase("closeUpdate", args);
}
public org.apache.accumulo.core.data.thrift.UpdateErrors recv_closeUpdate() throws NoSuchScanIDException, org.apache.thrift.TException
{
- org.apache.thrift.protocol.TMessage msg = iprot_.readMessageBegin();
- if (msg.type == org.apache.thrift.protocol.TMessageType.EXCEPTION) {
- org.apache.thrift.TApplicationException x = org.apache.thrift.TApplicationException.read(iprot_);
- iprot_.readMessageEnd();
- throw x;
- }
- if (msg.seqid != seqid_) {
- throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.BAD_SEQUENCE_ID, "closeUpdate failed: out of sequence response");
- }
closeUpdate_result result = new closeUpdate_result();
- result.read(iprot_);
- iprot_.readMessageEnd();
+ receiveBase(result, "closeUpdate");
if (result.isSetSuccess()) {
return result.success;
}
@@ -497,31 +406,18 @@ import org.slf4j.LoggerFactory;
public void send_update(org.apache.accumulo.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.thrift.TException
{
- oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("update", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_));
update_args args = new update_args();
args.setTinfo(tinfo);
args.setCredentials(credentials);
args.setKeyExtent(keyExtent);
args.setMutation(mutation);
- args.write(oprot_);
- oprot_.writeMessageEnd();
- oprot_.getTransport().flush();
+ sendBase("update", args);
}
public void recv_update() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, NotServingTabletException, ConstraintViolationException, org.apache.thrift.TException
{
- org.apache.thrift.protocol.TMessage msg = iprot_.readMessageBegin();
- if (msg.type == org.apache.thrift.protocol.TMessageType.EXCEPTION) {
- org.apache.thrift.TApplicationException x = org.apache.thrift.TApplicationException.read(iprot_);
- iprot_.readMessageEnd();
- throw x;
- }
- if (msg.seqid != seqid_) {
- throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.BAD_SEQUENCE_ID, "update failed: out of sequence response");
- }
update_result result = new update_result();
- result.read(iprot_);
- iprot_.readMessageEnd();
+ receiveBase(result, "update");
if (result.sec != null) {
throw result.sec;
}
@@ -542,32 +438,19 @@ import org.slf4j.LoggerFactory;
public void send_bulkImport(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, long tid, Map<org.apache.accumulo.core.data.thrift.TKeyExtent,Map<String,org.apache.accumulo.core.data.thrift.MapFileInfo>> files, boolean setTime) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("bulkImport", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_));
bulkImport_args args = new bulkImport_args();
args.setTinfo(tinfo);
args.setCredentials(credentials);
args.setTid(tid);
args.setFiles(files);
args.setSetTime(setTime);
- args.write(oprot_);
- oprot_.writeMessageEnd();
- oprot_.getTransport().flush();
+ sendBase("bulkImport", args);
}
public List<org.apache.accumulo.core.data.thrift.TKeyExtent> recv_bulkImport() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, org.apache.thrift.TException
{
- org.apache.thrift.protocol.TMessage msg = iprot_.readMessageBegin();
- if (msg.type == org.apache.thrift.protocol.TMessageType.EXCEPTION) {
- org.apache.thrift.TApplicationException x = org.apache.thrift.TApplicationException.read(iprot_);
- iprot_.readMessageEnd();
- throw x;
- }
- if (msg.seqid != seqid_) {
- throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.BAD_SEQUENCE_ID, "bulkImport failed: out of sequence response");
- }
bulkImport_result result = new bulkImport_result();
- result.read(iprot_);
- iprot_.readMessageEnd();
+ receiveBase(result, "bulkImport");
if (result.isSetSuccess()) {
return result.success;
}
@@ -585,31 +468,18 @@ import org.slf4j.LoggerFactory;
public void send_splitTablet(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, org.apache.accumulo.core.data.thrift.TKeyExtent extent, ByteBuffer splitPoint) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("splitTablet", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_));
splitTablet_args args = new splitTablet_args();
args.setTinfo(tinfo);
args.setCredentials(credentials);
args.setExtent(extent);
args.setSplitPoint(splitPoint);
- args.write(oprot_);
- oprot_.writeMessageEnd();
- oprot_.getTransport().flush();
+ sendBase("splitTablet", args);
}
public void recv_splitTablet() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, NotServingTabletException, org.apache.thrift.TException
{
- org.apache.thrift.protocol.TMessage msg = iprot_.readMessageBegin();
- if (msg.type == org.apache.thrift.protocol.TMessageType.EXCEPTION) {
- org.apache.thrift.TApplicationException x = org.apache.thrift.TApplicationException.read(iprot_);
- iprot_.readMessageEnd();
- throw x;
- }
- if (msg.seqid != seqid_) {
- throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.BAD_SEQUENCE_ID, "splitTablet failed: out of sequence response");
- }
splitTablet_result result = new splitTablet_result();
- result.read(iprot_);
- iprot_.readMessageEnd();
+ receiveBase(result, "splitTablet");
if (result.sec != null) {
throw result.sec;
}
@@ -626,15 +496,12 @@ import org.slf4j.LoggerFactory;
public void send_loadTablet(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String lock, org.apache.accumulo.core.data.thrift.TKeyExtent extent) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("loadTablet", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_));
loadTablet_args args = new loadTablet_args();
args.setTinfo(tinfo);
args.setCredentials(credentials);
args.setLock(lock);
args.setExtent(extent);
- args.write(oprot_);
- oprot_.writeMessageEnd();
- oprot_.getTransport().flush();
+ sendBase("loadTablet", args);
}
public void unloadTablet(org.apache.accumulo.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 org.apache.thrift.TException
@@ -644,16 +511,13 @@ import org.slf4j.LoggerFactory;
public void send_unloadTablet(org.apache.accumulo.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 org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("unloadTablet", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_));
unloadTablet_args args = new unloadTablet_args();
args.setTinfo(tinfo);
args.setCredentials(credentials);
args.setLock(lock);
args.setExtent(extent);
args.setSave(save);
- args.write(oprot_);
- oprot_.writeMessageEnd();
- oprot_.getTransport().flush();
+ sendBase("unloadTablet", args);
}
public void flush(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String lock, String tableId, ByteBuffer startRow, ByteBuffer endRow) throws org.apache.thrift.TException
@@ -663,7 +527,6 @@ import org.slf4j.LoggerFactory;
public void send_flush(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String lock, String tableId, ByteBuffer startRow, ByteBuffer endRow) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("flush", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_));
flush_args args = new flush_args();
args.setTinfo(tinfo);
args.setCredentials(credentials);
@@ -671,9 +534,7 @@ import org.slf4j.LoggerFactory;
args.setTableId(tableId);
args.setStartRow(startRow);
args.setEndRow(endRow);
- args.write(oprot_);
- oprot_.writeMessageEnd();
- oprot_.getTransport().flush();
+ sendBase("flush", args);
}
public void flushTablet(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String lock, org.apache.accumulo.core.data.thrift.TKeyExtent extent) throws org.apache.thrift.TException
@@ -683,15 +544,12 @@ import org.slf4j.LoggerFactory;
public void send_flushTablet(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String lock, org.apache.accumulo.core.data.thrift.TKeyExtent extent) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("flushTablet", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_));
flushTablet_args args = new flushTablet_args();
args.setTinfo(tinfo);
args.setCredentials(credentials);
args.setLock(lock);
args.setExtent(extent);
- args.write(oprot_);
- oprot_.writeMessageEnd();
- oprot_.getTransport().flush();
+ sendBase("flushTablet", args);
}
public void chop(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String lock, org.apache.accumulo.core.data.thrift.TKeyExtent extent) throws org.apache.thrift.TException
@@ -701,15 +559,12 @@ import org.slf4j.LoggerFactory;
public void send_chop(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String lock, org.apache.accumulo.core.data.thrift.TKeyExtent extent) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("chop", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_));
chop_args args = new chop_args();
args.setTinfo(tinfo);
args.setCredentials(credentials);
args.setLock(lock);
args.setExtent(extent);
- args.write(oprot_);
- oprot_.writeMessageEnd();
- oprot_.getTransport().flush();
+ sendBase("chop", args);
}
public void compact(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String lock, String tableId, ByteBuffer startRow, ByteBuffer endRow) throws org.apache.thrift.TException
@@ -719,7 +574,6 @@ import org.slf4j.LoggerFactory;
public void send_compact(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String lock, String tableId, ByteBuffer startRow, ByteBuffer endRow) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("compact", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_));
compact_args args = new compact_args();
args.setTinfo(tinfo);
args.setCredentials(credentials);
@@ -727,9 +581,7 @@ import org.slf4j.LoggerFactory;
args.setTableId(tableId);
args.setStartRow(startRow);
args.setEndRow(endRow);
- args.write(oprot_);
- oprot_.writeMessageEnd();
- oprot_.getTransport().flush();
+ sendBase("compact", args);
}
public org.apache.accumulo.core.master.thrift.TabletServerStatus getTabletServerStatus(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, org.apache.thrift.TException
@@ -740,29 +592,16 @@ import org.slf4j.LoggerFactory;
public void send_getTabletServerStatus(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getTabletServerStatus", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_));
getTabletServerStatus_args args = new getTabletServerStatus_args();
args.setTinfo(tinfo);
args.setCredentials(credentials);
- args.write(oprot_);
- oprot_.writeMessageEnd();
- oprot_.getTransport().flush();
+ sendBase("getTabletServerStatus", args);
}
public org.apache.accumulo.core.master.thrift.TabletServerStatus recv_getTabletServerStatus() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, org.apache.thrift.TException
{
- org.apache.thrift.protocol.TMessage msg = iprot_.readMessageBegin();
- if (msg.type == org.apache.thrift.protocol.TMessageType.EXCEPTION) {
- org.apache.thrift.TApplicationException x = org.apache.thrift.TApplicationException.read(iprot_);
- iprot_.readMessageEnd();
- throw x;
- }
- if (msg.seqid != seqid_) {
- throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.BAD_SEQUENCE_ID, "getTabletServerStatus failed: out of sequence response");
- }
getTabletServerStatus_result result = new getTabletServerStatus_result();
- result.read(iprot_);
- iprot_.readMessageEnd();
+ receiveBase(result, "getTabletServerStatus");
if (result.isSetSuccess()) {
return result.success;
}
@@ -780,30 +619,17 @@ import org.slf4j.LoggerFactory;
public void send_getTabletStats(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tableId) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getTabletStats", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_));
getTabletStats_args args = new getTabletStats_args();
args.setTinfo(tinfo);
args.setCredentials(credentials);
args.setTableId(tableId);
- args.write(oprot_);
- oprot_.writeMessageEnd();
- oprot_.getTransport().flush();
+ sendBase("getTabletStats", args);
}
public List<TabletStats> recv_getTabletStats() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, org.apache.thrift.TException
{
- org.apache.thrift.protocol.TMessage msg = iprot_.readMessageBegin();
- if (msg.type == org.apache.thrift.protocol.TMessageType.EXCEPTION) {
- org.apache.thrift.TApplicationException x = org.apache.thrift.TApplicationException.read(iprot_);
- iprot_.readMessageEnd();
- throw x;
- }
- if (msg.seqid != seqid_) {
- throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.BAD_SEQUENCE_ID, "getTabletStats failed: out of sequence response");
- }
getTabletStats_result result = new getTabletStats_result();
- result.read(iprot_);
- iprot_.readMessageEnd();
+ receiveBase(result, "getTabletStats");
if (result.isSetSuccess()) {
return result.success;
}
@@ -821,29 +647,16 @@ import org.slf4j.LoggerFactory;
public void send_getHistoricalStats(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getHistoricalStats", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_));
getHistoricalStats_args args = new getHistoricalStats_args();
args.setTinfo(tinfo);
args.setCredentials(credentials);
- args.write(oprot_);
- oprot_.writeMessageEnd();
- oprot_.getTransport().flush();
+ sendBase("getHistoricalStats", args);
}
public TabletStats recv_getHistoricalStats() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, org.apache.thrift.TException
{
- org.apache.thrift.protocol.TMessage msg = iprot_.readMessageBegin();
- if (msg.type == org.apache.thrift.protocol.TMessageType.EXCEPTION) {
- org.apache.thrift.TApplicationException x = org.apache.thrift.TApplicationException.read(iprot_);
- iprot_.readMessageEnd();
- throw x;
- }
- if (msg.seqid != seqid_) {
- throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.BAD_SEQUENCE_ID, "getHistoricalStats failed: out of sequence response");
- }
getHistoricalStats_result result = new getHistoricalStats_result();
- result.read(iprot_);
- iprot_.readMessageEnd();
+ receiveBase(result, "getHistoricalStats");
if (result.isSetSuccess()) {
return result.success;
}
@@ -861,30 +674,17 @@ import org.slf4j.LoggerFactory;
public void send_halt(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String lock) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("halt", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_));
halt_args args = new halt_args();
args.setTinfo(tinfo);
args.setCredentials(credentials);
args.setLock(lock);
- args.write(oprot_);
- oprot_.writeMessageEnd();
- oprot_.getTransport().flush();
+ sendBase("halt", args);
}
public void recv_halt() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, org.apache.thrift.TException
{
- org.apache.thrift.protocol.TMessage msg = iprot_.readMessageBegin();
- if (msg.type == org.apache.thrift.protocol.TMessageType.EXCEPTION) {
- org.apache.thrift.TApplicationException x = org.apache.thrift.TApplicationException.read(iprot_);
- iprot_.readMessageEnd();
- throw x;
- }
- if (msg.seqid != seqid_) {
- throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.BAD_SEQUENCE_ID, "halt failed: out of sequence response");
- }
halt_result result = new halt_result();
- result.read(iprot_);
- iprot_.readMessageEnd();
+ receiveBase(result, "halt");
if (result.sec != null) {
throw result.sec;
}
@@ -898,14 +698,11 @@ import org.slf4j.LoggerFactory;
public void send_fastHalt(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String lock) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("fastHalt", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_));
fastHalt_args args = new fastHalt_args();
args.setTinfo(tinfo);
args.setCredentials(credentials);
args.setLock(lock);
- args.write(oprot_);
- oprot_.writeMessageEnd();
- oprot_.getTransport().flush();
+ sendBase("fastHalt", args);
}
public List<ActiveScan> getActiveScans(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, org.apache.thrift.TException
@@ -916,29 +713,16 @@ import org.slf4j.LoggerFactory;
public void send_getActiveScans(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getActiveScans", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_));
getActiveScans_args args = new getActiveScans_args();
args.setTinfo(tinfo);
args.setCredentials(credentials);
- args.write(oprot_);
- oprot_.writeMessageEnd();
- oprot_.getTransport().flush();
+ sendBase("getActiveScans", args);
}
public List<ActiveScan> recv_getActiveScans() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, org.apache.thrift.TException
{
- org.apache.thrift.protocol.TMessage msg = iprot_.readMessageBegin();
- if (msg.type == org.apache.thrift.protocol.TMessageType.EXCEPTION) {
- org.apache.thrift.TApplicationException x = org.apache.thrift.TApplicationException.read(iprot_);
- iprot_.readMessageEnd();
- throw x;
- }
- if (msg.seqid != seqid_) {
- throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.BAD_SEQUENCE_ID, "getActiveScans failed: out of sequence response");
- }
getActiveScans_result result = new getActiveScans_result();
- result.read(iprot_);
- iprot_.readMessageEnd();
+ receiveBase(result, "getActiveScans");
if (result.isSetSuccess()) {
return result.success;
}
@@ -955,14 +739,11 @@ import org.slf4j.LoggerFactory;
public void send_removeLogs(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, List<String> filenames) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("removeLogs", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_));
removeLogs_args args = new removeLogs_args();
args.setTinfo(tinfo);
args.setCredentials(credentials);
args.setFilenames(filenames);
- args.write(oprot_);
- oprot_.writeMessageEnd();
- oprot_.getTransport().flush();
+ sendBase("removeLogs", args);
}
}
@@ -985,9 +766,9 @@ import org.slf4j.LoggerFactory;
public void startScan(org.apache.accumulo.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, List<org.apache.accumulo.core.data.thrift.TColumn> columns, int batchSize, List<org.apache.accumulo.core.data.thrift.IterInfo> ssiList, Map<String,Map<String,String>> ssio, List<ByteBuffer> authorizations, boolean waitForWrites, boolean isolated, org.apache.thrift.async.AsyncMethodCallback<startScan_call> resultHandler) throws org.apache.thrift.TException {
checkReady();
- startScan_call method_call = new startScan_call(tinfo, credentials, extent, range, columns, batchSize, ssiList, ssio, authorizations, waitForWrites, isolated, resultHandler, this, protocolFactory, transport);
- this.currentMethod = method_call;
- manager.call(method_call);
+ startScan_call method_call = new startScan_call(tinfo, credentials, extent, range, columns, batchSize, ssiList, ssio, authorizations, waitForWrites, isolated, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
}
public static class startScan_call extends org.apache.thrift.async.TAsyncMethodCall {
@@ -1047,9 +828,9 @@ import org.slf4j.LoggerFactory;
public void continueScan(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, long scanID, org.apache.thrift.async.AsyncMethodCallback<continueScan_call> resultHandler) throws org.apache.thrift.TException {
checkReady();
- continueScan_call method_call = new continueScan_call(tinfo, scanID, resultHandler, this, protocolFactory, transport);
- this.currentMethod = method_call;
- manager.call(method_call);
+ continueScan_call method_call = new continueScan_call(tinfo, scanID, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
}
public static class continueScan_call extends org.apache.thrift.async.TAsyncMethodCall {
@@ -1082,9 +863,9 @@ import org.slf4j.LoggerFactory;
public void closeScan(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, long scanID, org.apache.thrift.async.AsyncMethodCallback<closeScan_call> resultHandler) throws org.apache.thrift.TException {
checkReady();
- closeScan_call method_call = new closeScan_call(tinfo, scanID, resultHandler, this, protocolFactory, transport);
- this.currentMethod = method_call;
- manager.call(method_call);
+ closeScan_call method_call = new closeScan_call(tinfo, scanID, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
}
public static class closeScan_call extends org.apache.thrift.async.TAsyncMethodCall {
@@ -1116,9 +897,9 @@ import org.slf4j.LoggerFactory;
public void startMultiScan(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, Map<org.apache.accumulo.core.data.thrift.TKeyExtent,List<org.apache.accumulo.core.data.thrift.TRange>> batch, List<org.apache.accumulo.core.data.thrift.TColumn> columns, List<org.apache.accumulo.core.data.thrift.IterInfo> ssiList, Map<String,Map<String,String>> ssio, List<ByteBuffer> authorizations, boolean waitForWrites, org.apache.thrift.async.AsyncMethodCallback<startMultiScan_call> resultHandler) throws org.apache.thrift.TException {
checkReady();
- startMultiScan_call method_call = new startMultiScan_call(tinfo, credentials, batch, columns, ssiList, ssio, authorizations, waitForWrites, resultHandler, this, protocolFactory, transport);
- this.currentMethod = method_call;
- manager.call(method_call);
+ startMultiScan_call method_call = new startMultiScan_call(tinfo, credentials, batch, columns, ssiList, ssio, authorizations, waitForWrites, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
}
public static class startMultiScan_call extends org.apache.thrift.async.TAsyncMethodCall {
@@ -1169,9 +950,9 @@ import org.slf4j.LoggerFactory;
public void continueMultiScan(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, long scanID, org.apache.thrift.async.AsyncMethodCallback<continueMultiScan_call> resultHandler) throws org.apache.thrift.TException {
checkReady();
- continueMultiScan_call method_call = new continueMultiScan_call(tinfo, scanID, resultHandler, this, protocolFactory, transport);
- this.currentMethod = method_call;
- manager.call(method_call);
+ continueMultiScan_call method_call = new continueMultiScan_call(tinfo, scanID, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
}
public static class continueMultiScan_call extends org.apache.thrift.async.TAsyncMethodCall {
@@ -1204,9 +985,9 @@ import org.slf4j.LoggerFactory;
public void closeMultiScan(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, long scanID, org.apache.thrift.async.AsyncMethodCallback<closeMultiScan_call> resultHandler) throws org.apache.thrift.TException {
checkReady();
- closeMultiScan_call method_call = new closeMultiScan_call(tinfo, scanID, resultHandler, this, protocolFactory, transport);
- this.currentMethod = method_call;
- manager.call(method_call);
+ closeMultiScan_call method_call = new closeMultiScan_call(tinfo, scanID, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
}
public static class closeMultiScan_call extends org.apache.thrift.async.TAsyncMethodCall {
@@ -1239,9 +1020,9 @@ import org.slf4j.LoggerFactory;
public void startUpdate(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, org.apache.thrift.async.AsyncMethodCallback<startUpdate_call> resultHandler) throws org.apache.thrift.TException {
checkReady();
- startUpdate_call method_call = new startUpdate_call(tinfo, credentials, resultHandler, this, protocolFactory, transport);
- this.currentMethod = method_call;
- manager.call(method_call);
+ startUpdate_call method_call = new startUpdate_call(tinfo, credentials, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
}
public static class startUpdate_call extends org.apache.thrift.async.TAsyncMethodCall {
@@ -1274,9 +1055,9 @@ import org.slf4j.LoggerFactory;
public void applyUpdates(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, long updateID, org.apache.accumulo.core.data.thrift.TKeyExtent keyExtent, List<org.apache.accumulo.core.data.thrift.TMutation> mutations, org.apache.thrift.async.AsyncMethodCallback<applyUpdates_call> resultHandler) throws org.apache.thrift.TException {
checkReady();
- applyUpdates_call method_call = new applyUpdates_call(tinfo, updateID, keyExtent, mutations, resultHandler, this, protocolFactory, transport);
- this.currentMethod = method_call;
- manager.call(method_call);
+ applyUpdates_call method_call = new applyUpdates_call(tinfo, updateID, keyExtent, mutations, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
}
public static class applyUpdates_call extends org.apache.thrift.async.TAsyncMethodCall {
@@ -1314,9 +1095,9 @@ import org.slf4j.LoggerFactory;
public void closeUpdate(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, long updateID, org.apache.thrift.async.AsyncMethodCallback<closeUpdate_call> resultHandler) throws org.apache.thrift.TException {
checkReady();
- closeUpdate_call method_call = new closeUpdate_call(tinfo, updateID, resultHandler, this, protocolFactory, transport);
- this.currentMethod = method_call;
- manager.call(method_call);
+ closeUpdate_call method_call = new closeUpdate_call(tinfo, updateID, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
}
public static class closeUpdate_call extends org.apache.thrift.async.TAsyncMethodCall {
@@ -1349,9 +1130,9 @@ import org.slf4j.LoggerFactory;
public void update(org.apache.accumulo.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, org.apache.thrift.async.AsyncMethodCallback<update_call> resultHandler) throws org.apache.thrift.TException {
checkReady();
- update_call method_call = new update_call(tinfo, credentials, keyExtent, mutation, resultHandler, this, protocolFactory, transport);
- this.currentMethod = method_call;
- manager.call(method_call);
+ update_call method_call = new update_call(tinfo, credentials, keyExtent, mutation, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
}
public static class update_call extends org.apache.thrift.async.TAsyncMethodCall {
@@ -1390,9 +1171,9 @@ import org.slf4j.LoggerFactory;
public void bulkImport(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, long tid, Map<org.apache.accumulo.core.data.thrift.TKeyExtent,Map<String,org.apache.accumulo.core.data.thrift.MapFileInfo>> files, boolean setTime, org.apache.thrift.async.AsyncMethodCallback<bulkImport_call> resultHandler) throws org.apache.thrift.TException {
checkReady();
- bulkImport_call method_call = new bulkImport_call(tinfo, credentials, tid, files, setTime, resultHandler, this, protocolFactory, transport);
- this.currentMethod = method_call;
- manager.call(method_call);
+ bulkImport_call method_call = new bulkImport_call(tinfo, credentials, tid, files, setTime, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
}
public static class bulkImport_call extends org.apache.thrift.async.TAsyncMethodCall {
@@ -1434,9 +1215,9 @@ import org.slf4j.LoggerFactory;
public void splitTablet(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, org.apache.accumulo.core.data.thrift.TKeyExtent extent, ByteBuffer splitPoint, org.apache.thrift.async.AsyncMethodCallback<splitTablet_call> resultHandler) throws org.apache.thrift.TException {
checkReady();
- splitTablet_call method_call = new splitTablet_call(tinfo, credentials, extent, splitPoint, resultHandler, this, protocolFactory, transport);
- this.currentMethod = method_call;
- manager.call(method_call);
+ splitTablet_call method_call = new splitTablet_call(tinfo, credentials, extent, splitPoint, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
}
public static class splitTablet_call extends org.apache.thrift.async.TAsyncMethodCall {
@@ -1475,9 +1256,9 @@ import org.slf4j.LoggerFactory;
public void loadTablet(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String lock, org.apache.accumulo.core.data.thrift.TKeyExtent extent, org.apache.thrift.async.AsyncMethodCallback<loadTablet_call> resultHandler) throws org.apache.thrift.TException {
checkReady();
- loadTablet_call method_call = new loadTablet_call(tinfo, credentials, lock, extent, resultHandler, this, protocolFactory, transport);
- this.currentMethod = method_call;
- manager.call(method_call);
+ loadTablet_call method_call = new loadTablet_call(tinfo, credentials, lock, extent, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
}
public static class loadTablet_call extends org.apache.thrift.async.TAsyncMethodCall {
@@ -1515,9 +1296,9 @@ import org.slf4j.LoggerFactory;
public void unloadTablet(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String lock, org.apache.accumulo.core.data.thrift.TKeyExtent extent, boolean save, org.apache.thrift.async.AsyncMethodCallback<unloadTablet_call> resultHandler) throws org.apache.thrift.TException {
checkReady();
- unloadTablet_call method_call = new unloadTablet_call(tinfo, credentials, lock, extent, save, resultHandler, this, protocolFactory, transport);
- this.currentMethod = method_call;
- manager.call(method_call);
+ unloadTablet_call method_call = new unloadTablet_call(tinfo, credentials, lock, extent, save, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
}
public static class unloadTablet_call extends org.apache.thrift.async.TAsyncMethodCall {
@@ -1558,9 +1339,9 @@ import org.slf4j.LoggerFactory;
public void flush(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String lock, String tableId, ByteBuffer startRow, ByteBuffer endRow, org.apache.thrift.async.AsyncMethodCallback<flush_call> resultHandler) throws org.apache.thrift.TException {
checkReady();
- flush_call method_call = new flush_call(tinfo, credentials, lock, tableId, startRow, endRow, resultHandler, this, protocolFactory, transport);
- this.currentMethod = method_call;
- manager.call(method_call);
+ flush_call method_call = new flush_call(tinfo, credentials, lock, tableId, startRow, endRow, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
}
public static class flush_call extends org.apache.thrift.async.TAsyncMethodCall {
@@ -1604,9 +1385,9 @@ import org.slf4j.LoggerFactory;
public void flushTablet(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String lock, org.apache.accumulo.core.data.thrift.TKeyExtent extent, org.apache.thrift.async.AsyncMethodCallback<flushTablet_call> resultHandler) throws org.apache.thrift.TException {
checkReady();
- flushTablet_call method_call = new flushTablet_call(tinfo, credentials, lock, extent, resultHandler, this, protocolFactory, transport);
- this.currentMethod = method_call;
- manager.call(method_call);
+ flushTablet_call method_call = new flushTablet_call(tinfo, credentials, lock, extent, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
}
public static class flushTablet_call extends org.apache.thrift.async.TAsyncMethodCall {
@@ -1644,9 +1425,9 @@ import org.slf4j.LoggerFactory;
public void chop(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String lock, org.apache.accumulo.core.data.thrift.TKeyExtent extent, org.apache.thrift.async.AsyncMethodCallback<chop_call> resultHandler) throws org.apache.thrift.TException {
checkReady();
- chop_call method_call = new chop_call(tinfo, credentials, lock, extent, resultHandler, this, protocolFactory, transport);
- this.currentMethod = method_call;
- manager.call(method_call);
+ chop_call method_call = new chop_call(tinfo, credentials, lock, extent, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
}
public static class chop_call extends org.apache.thrift.async.TAsyncMethodCall {
@@ -1684,9 +1465,9 @@ import org.slf4j.LoggerFactory;
public void compact(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String lock, String tableId, ByteBuffer startRow, ByteBuffer endRow, org.apache.thrift.async.AsyncMethodCallback<compact_call> resultHandler) throws org.apache.thrift.TException {
checkReady();
- compact_call method_call = new compact_call(tinfo, credentials, lock, tableId, startRow, endRow, resultHandler, this, protocolFactory, transport);
- this.currentMethod = method_call;
- manager.call(method_call);
+ compact_call method_call = new compact_call(tinfo, credentials, lock, tableId, startRow, endRow, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
}
public static class compact_call extends org.apache.thrift.async.TAsyncMethodCall {
@@ -1730,9 +1511,9 @@ import org.slf4j.LoggerFactory;
public void getTabletServerStatus(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, org.apache.thrift.async.AsyncMethodCallback<getTabletServerStatus_call> resultHandler) throws org.apache.thrift.TException {
checkReady();
- getTabletServerStatus_call method_call = new getTabletServerStatus_call(tinfo, credentials, resultHandler, this, protocolFactory, transport);
- this.currentMethod = method_call;
- manager.call(method_call);
+ getTabletServerStatus_call method_call = new getTabletServerStatus_call(tinfo, credentials, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
}
public static class getTabletServerStatus_call extends org.apache.thrift.async.TAsyncMethodCall {
@@ -1765,9 +1546,9 @@ import org.slf4j.LoggerFactory;
public void getTabletStats(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tableId, org.apache.thrift.async.AsyncMethodCallback<getTabletStats_call> resultHandler) throws org.apache.thrift.TException {
checkReady();
- getTabletStats_call method_call = new getTabletStats_call(tinfo, credentials, tableId, resultHandler, this, protocolFactory, transport);
- this.currentMethod = method_call;
- manager.call(method_call);
+ getTabletStats_call method_call = new getTabletStats_call(tinfo, credentials, tableId, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
}
public static class getTabletStats_call extends org.apache.thrift.async.TAsyncMethodCall {
@@ -1803,9 +1584,9 @@ import org.slf4j.LoggerFactory;
public void getHistoricalStats(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, org.apache.thrift.async.AsyncMethodCallback<getHistoricalStats_call> resultHandler) throws org.apache.thrift.TException {
checkReady();
- getHistoricalStats_call method_call = new getHistoricalStats_call(tinfo, credentials, resultHandler, this, protocolFactory, transport);
- this.currentMethod = method_call;
- manager.call(method_call);
+ getHistoricalStats_call method_call = new getHistoricalStats_call(tinfo, credentials, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
}
public static class getHistoricalStats_call extends org.apache.thrift.async.TAsyncMethodCall {
@@ -1838,9 +1619,9 @@ import org.slf4j.LoggerFactory;
public void halt(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String lock, org.apache.thrift.async.AsyncMethodCallback<halt_call> resultHandler) throws org.apache.thrift.TException {
checkReady();
- halt_call method_call = new halt_call(tinfo, credentials, lock, resultHandler, this, protocolFactory, transport);
- this.currentMethod = method_call;
- manager.call(method_call);
+ halt_call method_call = new halt_call(tinfo, credentials, lock, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
}
public static class halt_call extends org.apache.thrift.async.TAsyncMethodCall {
@@ -1876,9 +1657,9 @@ import org.slf4j.LoggerFactory;
public void fastHalt(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String lock, org.apache.thrift.async.AsyncMethodCallback<fastHalt_call> resultHandler) throws org.apache.thrift.TException {
checkReady();
- fastHalt_call method_call = new fastHalt_call(tinfo, credentials, lock, resultHandler, this, protocolFactory, transport);
- this.currentMethod = method_call;
- manager.call(method_call);
+ fastHalt_call method_call = new fastHalt_call(tinfo, credentials, lock, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
}
public static class fastHalt_call extends org.apache.thrift.async.TAsyncMethodCall {
@@ -1913,9 +1694,9 @@ import org.slf4j.LoggerFactory;
public void getActiveScans(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, org.apache.thrift.async.AsyncMethodCallback<getActiveScans_call> resultHandler) throws org.apache.thrift.TException {
checkReady();
- getActiveScans_call method_call = new getActiveScans_call(tinfo, credentials, resultHandler, this, protocolFactory, transport);
- this.currentMethod = method_call;
- manager.call(method_call);
+ getActiveScans_call method_call = new getActiveScans_call(tinfo, credentials, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
}
public static class getActiveScans_call extends org.apache.thrift.async.TAsyncMethodCall {
@@ -1948,9 +1729,9 @@ import org.slf4j.LoggerFactory;
public void removeLogs(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, List<String> filenames, org.apache.thrift.async.AsyncMethodCallback<removeLogs_call> resultHandler) throws org.apache.thrift.TException {
checkReady();
- removeLogs_call method_call = new removeLogs_call(tinfo, credentials, filenames, resultHandler, this, protocolFactory, transport);
- this.currentMethod = method_call;
- manager.call(method_call);
+ removeLogs_call method_call = new removeLogs_call(tinfo, credentials, filenames, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
}
public static class removeLogs_call extends org.apache.thrift.async.TAsyncMethodCall {
@@ -1985,851 +1766,507 @@ import org.slf4j.LoggerFactory;
}
- public static class Processor extends org.apache.accumulo.core.client.impl.thrift.ClientService.Processor implements org.apache.thrift.TProcessor {
+ public static class Processor<I extends Iface> extends org.apache.accumulo.core.client.impl.thrift.ClientService.Processor implements org.apache.thrift.TProcessor {
private static final Logger LOGGER = LoggerFactory.getLogger(Processor.class.getName());
- public Processor(Iface iface)
- {
- super(iface);
- iface_ = iface;
- processMap_.put("startScan", new startScan());
- processMap_.put("continueScan", new continueScan());
- processMap_.put("closeScan", new closeScan());
- processMap_.put("startMultiScan", new startMultiScan());
- processMap_.put("continueMultiScan", new continueMultiScan());
- processMap_.put("closeMultiScan", new closeMultiScan());
- processMap_.put("startUpdate", new startUpdate());
- processMap_.put("applyUpdates", new applyUpdates());
- processMap_.put("closeUpdate", new closeUpdate());
- processMap_.put("update", new update());
- processMap_.put("bulkImport", new bulkImport());
- processMap_.put("splitTablet", new splitTablet());
- processMap_.put("loadTablet", new loadTablet());
- processMap_.put("unloadTablet", new unloadTablet());
- processMap_.put("flush", new flush());
- processMap_.put("flushTablet", new flushTablet());
- processMap_.put("chop", new chop());
- processMap_.put("compact", new compact());
- processMap_.put("getTabletServerStatus", new getTabletServerStatus());
- processMap_.put("getTabletStats", new getTabletStats());
- processMap_.put("getHistoricalStats", new getHistoricalStats());
- processMap_.put("halt", new halt());
- processMap_.put("fastHalt", new fastHalt());
- processMap_.put("getActiveScans", new getActiveScans());
- processMap_.put("removeLogs", new removeLogs());
- }
-
- private Iface iface_;
-
- public boolean process(org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException
- {
- org.apache.thrift.protocol.TMessage msg = iprot.readMessageBegin();
- ProcessFunction fn = processMap_.get(msg.name);
- if (fn == null) {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, org.apache.thrift.protocol.TType.STRUCT);
- iprot.readMessageEnd();
- org.apache.thrift.TApplicationException x = new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.UNKNOWN_METHOD, "Invalid method name: '"+msg.name+"'");
- oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage(msg.name, org.apache.thrift.protocol.TMessageType.EXCEPTION, msg.seqid));
- x.write(oprot);
- oprot.writeMessageEnd();
- oprot.getTransport().flush();
- return true;
- }
- fn.process(msg.seqid, iprot, oprot);
- return true;
+ public Processor(I iface) {
+ super(iface, getProcessMap(new HashMap<String, org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>>()));
}
- private class startScan implements ProcessFunction {
- public void process(int seqid, org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException
- {
- startScan_args args = new startScan_args();
- try {
- args.read(iprot);
- } catch (org.apache.thrift.protocol.TProtocolException e) {
- iprot.readMessageEnd();
- org.apache.thrift.TApplicationException x = new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.PROTOCOL_ERROR, e.getMessage());
- oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("startScan", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid));
- x.write(oprot);
- oprot.writeMessageEnd();
- oprot.getTransport().flush();
- return;
- }
- iprot.readMessageEnd();
+ protected Processor(I iface, Map<String, org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>> processMap) {
+ super(iface, getProcessMap(processMap));
+ }
+
+ private static <I extends Iface> Map<String, org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>> getProcessMap(Map<String, org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>> processMap) {
+ processMap.put("startScan", new startScan());
+ processMap.put("continueScan", new continueScan());
+ processMap.put("closeScan", new closeScan());
+ processMap.put("startMultiScan", new startMultiScan());
+ processMap.put("continueMultiScan", new continueMultiScan());
+ processMap.put("closeMultiScan", new closeMultiScan());
+ processMap.put("startUpdate", new startUpdate());
+ processMap.put("applyUpdates", new applyUpdates());
+ processMap.put("closeUpdate", new closeUpdate());
+ processMap.put("update", new update());
+ processMap.put("bulkImport", new bulkImport());
+ processMap.put("splitTablet", new splitTablet());
+ processMap.put("loadTablet", new loadTablet());
+ processMap.put("unloadTablet", new unloadTablet());
+ processMap.put("flush", new flush());
+ processMap.put("flushTablet", new flushTablet());
+ processMap.put("chop", new chop());
+ processMap.put("compact", new compact());
+ processMap.put("getTabletServerStatus", new getTabletServerStatus());
+ processMap.put("getTabletStats", new getTabletStats());
+ processMap.put("getHistoricalStats", new getHistoricalStats());
+ processMap.put("halt", new halt());
+ processMap.put("fastHalt", new fastHalt());
+ processMap.put("getActiveScans", new getActiveScans());
+ processMap.put("removeLogs", new removeLogs());
+ return processMap;
+ }
+
+ private static class startScan<I extends Iface> extends org.apache.thrift.ProcessFunction<I, startScan_args> {
+ public startScan() {
+ super("startScan");
+ }
+
+ protected startScan_args getEmptyArgsInstance() {
+ return new startScan_args();
+ }
+
+ protected startScan_result getResult(I iface, startScan_args args) throws org.apache.thrift.TException {
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) {
result.nste = nste;
} catch (TooManyFilesException tmfe) {
result.tmfe = tmfe;
- } catch (Throwable th) {
- LOGGER.error("Internal error processing startScan", th);
- org.apache.thrift.TApplicationException x = new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, "Internal error processing startScan");
- oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("startScan", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid));
- x.write(oprot);
- oprot.writeMessageEnd();
- oprot.getTransport().flush();
- return;
- }
- oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("startScan", org.apache.thrift.protocol.TMessageType.REPLY, seqid));
- result.write(oprot);
- oprot.writeMessageEnd();
- oprot.getTransport().flush();
+ }
+ return result;
}
-
}
- private class continueScan implements ProcessFunction {
- public void process(int seqid, org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException
- {
- continueScan_args args = new continueScan_args();
- try {
- args.read(iprot);
- } catch (org.apache.thrift.protocol.TProtocolException e) {
- iprot.readMessageEnd();
- org.apache.thrift.TApplicationException x = new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.PROTOCOL_ERROR, e.getMessage());
- oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("continueScan", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid));
- x.write(oprot);
- oprot.writeMessageEnd();
- oprot.getTransport().flush();
- return;
- }
- iprot.readMessageEnd();
+ private static class continueScan<I extends Iface> extends org.apache.thrift.ProcessFunction<I, continueScan_args> {
+ public continueScan() {
+ super("continueScan");
+ }
+
+ protected continueScan_args getEmptyArgsInstance() {
+ return new continueScan_args();
+ }
+
+ protected continueScan_result getResult(I iface, continueScan_args args) throws org.apache.thrift.TException {
continueScan_result result = new continueScan_result();
try {
- result.success = iface_.continueScan(args.tinfo, args.scanID);
+ result.success = iface.continueScan(args.tinfo, args.scanID);
} catch (NoSuchScanIDException nssi) {
result.nssi = nssi;
} catch (NotServingTabletException nste) {
result.nste = nste;
} catch (TooManyFilesException tmfe) {
result.tmfe = tmfe;
- } catch (Throwable th) {
- LOGGER.error("Internal error processing continueScan", th);
- org.apache.thrift.TApplicationException x = new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, "Internal error processing continueScan");
- oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("continueScan", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid));
- x.write(oprot);
- oprot.writeMessageEnd();
- oprot.getTransport().flush();
- return;
- }
- oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("continueScan", org.apache.thrift.protocol.TMessageType.REPLY, seqid));
- result.write(oprot);
- oprot.writeMessageEnd();
- oprot.getTransport().flush();
+ }
+ return result;
}
-
}
- private class closeScan implements ProcessFunction {
- public void process(int seqid, org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException
- {
- closeScan_args args = new closeScan_args();
- try {
- args.read(iprot);
- } catch (org.apache.thrift.protocol.TProtocolException e) {
- iprot.readMessageEnd();
- org.apache.thrift.TApplicationException x = new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.PROTOCOL_ERROR, e.getMessage());
- oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("closeScan", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid));
- x.write(oprot);
- oprot.writeMessageEnd();
- oprot.getTransport().flush();
- return;
- }
- iprot.readMessageEnd();
- iface_.closeScan(args.tinfo, args.scanID);
- return;
+ private static class closeScan<I extends Iface> extends org.apache.thrift.ProcessFunction<I, closeScan_args> {
+ public closeScan() {
+ super("closeScan");
+ }
+
+ protected closeScan_args getEmptyArgsInstance() {
+ return new closeScan_args();
+ }
+
+ protected org.apache.thrift.TBase getResult(I iface, closeScan_args args) throws org.apache.thrift.TException {
+ iface.closeScan(args.tinfo, args.scanID);
+ return null;
}
}
- private class startMultiScan implements ProcessFunction {
- public void process(int seqid, org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException
- {
- startMultiScan_args args = new startMultiScan_args();
- try {
- args.read(iprot);
- } catch (org.apache.thrift.protocol.TProtocolException e) {
- iprot.readMessageEnd();
- org.apache.thrift.TApplicationException x = new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.PROTOCOL_ERROR, e.getMessage());
- oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("startMultiScan", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid));
- x.write(oprot);
- oprot.writeMessageEnd();
- oprot.getTransport().flush();
- return;
- }
- iprot.readMessageEnd();
+ private static class startMultiScan<I extends Iface> extends org.apache.thrift.ProcessFunction<I, startMultiScan_args> {
+ public startMultiScan() {
+ super("startMultiScan");
+ }
+
+ protected startMultiScan_args getEmptyArgsInstance() {
+ return new startMultiScan_args();
+ }
+
+ protected startMultiScan_result getResult(I iface, startMultiScan_args args) throws org.apache.thrift.TException {
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) {
- LOGGER.error("Internal error processing startMultiScan", th);
- org.apache.thrift.TApplicationException x = new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, "Internal error processing startMultiScan");
- oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("startMultiScan", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid));
- x.write(oprot);
- oprot.writeMessageEnd();
- oprot.getTransport().flush();
- return;
- }
- oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("startMultiScan", org.apache.thrift.protocol.TMessageType.REPLY, seqid));
- result.write(oprot);
- oprot.writeMessageEnd();
- oprot.getTransport().flush();
+ }
+ return result;
}
-
}
- private class continueMultiScan implements ProcessFunction {
- public void process(int seqid, org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException
- {
- continueMultiScan_args args = new continueMultiScan_args();
- try {
- args.read(iprot);
- } catch (org.apache.thrift.protocol.TProtocolException e) {
- iprot.readMessageEnd();
- org.apache.thrift.TApplicationException x = new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.PROTOCOL_ERROR, e.getMessage());
- oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("continueMultiScan", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid));
- x.write(oprot);
- oprot.writeMessageEnd();
- oprot.getTransport().flush();
- return;
- }
- iprot.readMessageEnd();
+ private static class continueMultiScan<I extends Iface> extends org.apache.thrift.ProcessFunction<I, continueMultiScan_args> {
+ public continueMultiScan() {
+ super("continueMultiScan");
+ }
+
+ protected continueMultiScan_args getEmptyArgsInstance() {
+ return new continueMultiScan_args();
+ }
+
+ protected continueMultiScan_result getResult(I iface, continueMultiScan_args args) throws org.apache.thrift.TException {
continueMultiScan_result result = new continueMultiScan_result();
try {
- result.success = iface_.continueMultiScan(args.tinfo, args.scanID);
+ result.success = iface.continueMultiScan(args.tinfo, args.scanID);
} catch (NoSuchScanIDException nssi) {
result.nssi = nssi;
- } catch (Throwable th) {
- LOGGER.error("Internal error processing continueMultiScan", th);
- org.apache.thrift.TApplicationException x = new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, "Internal error processing continueMultiScan");
- oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("continueMultiScan", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid));
- x.write(oprot);
- oprot.writeMessageEnd();
- oprot.getTransport().flush();
- return;
- }
- oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("continueMultiScan", org.apache.thrift.protocol.TMessageType.REPLY, seqid));
- result.write(oprot);
- oprot.writeMessageEnd();
- oprot.getTransport().flush();
+ }
+ return result;
}
-
}
- private class closeMultiScan implements ProcessFunction {
- public void process(int seqid, org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException
- {
- closeMultiScan_args args = new closeMultiScan_args();
- try {
- args.read(iprot);
- } catch (org.apache.thrift.protocol.TProtocolException e) {
- iprot.readMessageEnd();
- org.apache.thrift.TApplicationException x = new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.PROTOCOL_ERROR, e.getMessage());
- oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("closeMultiScan", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid));
- x.write(oprot);
- oprot.writeMessageEnd();
- oprot.getTransport().flush();
- return;
- }
- iprot.readMessageEnd();
+ private static class closeMultiScan<I extends Iface> extends org.apache.thrift.ProcessFunction<I, closeMultiScan_args> {
+ public closeMultiScan() {
+ super("closeMultiScan");
+ }
+
+ protected closeMultiScan_args getEmptyArgsInstance() {
+ return new closeMultiScan_args();
+ }
+
+ protected closeMultiScan_result getResult(I iface, closeMultiScan_args args) throws org.apache.thrift.TException {
closeMultiScan_result result = new closeMultiScan_result();
try {
- iface_.closeMultiScan(args.tinfo, args.scanID);
+ iface.closeMultiScan(args.tinfo, args.scanID);
} catch (NoSuchScanIDException nssi) {
result.nssi = nssi;
- } catch (Throwable th) {
- LOGGER.error("Internal error processing closeMultiScan", th);
- org.apache.thrift.TApplicationException x = new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, "Internal error processing closeMultiScan");
- oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("closeMultiScan", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid));
- x.write(oprot);
- oprot.writeMessageEnd();
- oprot.getTransport().flush();
- return;
- }
- oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("closeMultiScan", org.apache.thrift.protocol.TMessageType.REPLY, seqid));
- result.write(oprot);
- oprot.writeMessageEnd();
- oprot.getTransport().flush();
+ }
+ return result;
}
-
}
- private class startUpdate implements ProcessFunction {
- public void process(int seqid, org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException
- {
- startUpdate_args args = new startUpdate_args();
- try {
- args.read(iprot);
- } catch (org.apache.thrift.protocol.TProtocolException e) {
- iprot.readMessageEnd();
- org.apache.thrift.TApplicationException x = new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.PROTOCOL_ERROR, e.getMessage());
- oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("startUpdate", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid));
- x.write(oprot);
- oprot.writeMessageEnd();
- oprot.getTransport().flush();
- return;
- }
- iprot.readMessageEnd();
+ private static class startUpdate<I extends Iface> extends org.apache.thrift.ProcessFunction<I, startUpdate_args> {
+ public startUpdate() {
+ super("startUpdate");
+ }
+
+ protected startUpdate_args getEmptyArgsInstance() {
+ return new startUpdate_args();
+ }
+
+ protected startUpdate_result getResult(I iface, startUpdate_args args) throws org.apache.thrift.TException {
startUpdate_result result = new startUpdate_result();
try {
- result.success = iface_.startUpdate(args.tinfo, args.credentials);
+ result.success = iface.startUpdate(args.tinfo, args.credentials);
result.setSuccessIsSet(true);
} catch (org.apache.accumulo.core.security.thrift.ThriftSecurityException sec) {
result.sec = sec;
- } catch (Throwable th) {
- LOGGER.error("Internal error processing startUpdate", th);
- org.apache.thrift.TApplicationException x = new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, "Internal error processing startUpdate");
- oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("startUpdate", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid));
- x.write(oprot);
- oprot.writeMessageEnd();
- oprot.getTransport().flush();
- return;
- }
- oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("startUpdate", org.apache.thrift.protocol.TMessageType.REPLY, seqid));
- result.write(oprot);
- oprot.writeMessageEnd();
- oprot.getTransport().flush();
+ }
+ return result;
}
-
}
- private class applyUpdates implements ProcessFunction {
- public void process(int seqid, org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException
- {
- applyUpdates_args args = new applyUpdates_args();
- try {
- args.read(iprot);
- } catch (org.apache.thrift.protocol.TProtocolException e) {
- iprot.readMessageEnd();
- org.apache.thrift.TApplicationException x = new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.PROTOCOL_ERROR, e.getMessage());
- oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("applyUpdates", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid));
- x.write(oprot);
- oprot.writeMessageEnd();
- oprot.getTransport().flush();
- return;
- }
- iprot.readMessageEnd();
- iface_.applyUpdates(args.tinfo, args.updateID, args.keyExtent, args.mutations);
- return;
+ private static class applyUpdates<I extends Iface> extends org.apache.thrift.ProcessFunction<I, applyUpdates_args> {
+ public applyUpdates() {
+ super("applyUpdates");
+ }
+
+ protected applyUpdates_args getEmptyArgsInstance() {
+ return new applyUpdates_args();
+ }
+
+ protected org.apache.thrift.TBase getResult(I iface, applyUpdates_args args) throws org.apache.thrift.TException {
+ iface.applyUpdates(args.tinfo, args.updateID, args.keyExtent, args.mutations);
+ return null;
}
}
- private class closeUpdate implements ProcessFunction {
- public void process(int seqid, org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException
- {
- closeUpdate_args args = new closeUpdate_args();
- try {
- args.read(iprot);
- } catch (org.apache.thrift.protocol.TProtocolException e) {
- iprot.readMessageEnd();
- org.apache.thrift.TApplicationException x = new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.PROTOCOL_ERROR, e.getMessage());
- oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("closeUpdate", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid));
- x.write(oprot);
- oprot.writeMessageEnd();
- oprot.getTransport().flush();
- return;
- }
- iprot.readMessageEnd();
+ private static class closeUpdate<I extends Iface> extends org.apache.thrift.ProcessFunction<I, closeUpdate_args> {
+ public closeUpdate() {
+ super("closeUpdate");
+ }
+
+ protected closeUpdate_args getEmptyArgsInstance() {
+ return new closeUpdate_args();
+ }
+
+ protected closeUpdate_result getResult(I iface, closeUpdate_args args) throws org.apache.thrift.TException {
closeUpdate_result result = new closeUpdate_result();
try {
- result.success = iface_.closeUpdate(args.tinfo, args.updateID);
+ result.success = iface.closeUpdate(args.tinfo, args.updateID);
} catch (NoSuchScanIDException nssi) {
result.nssi = nssi;
- } catch (Throwable th) {
- LOGGER.error("Internal error processing closeUpdate", th);
- org.apache.thrift.TApplicationException x = new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, "Internal error processing closeUpdate");
- oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("closeUpdate", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid));
- x.write(oprot);
- oprot.writeMessageEnd();
- oprot.getTransport().flush();
- return;
- }
- oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("closeUpdate", org.apache.thrift.protocol.TMessageType.REPLY, seqid));
- result.write(oprot);
- oprot.writeMessageEnd();
- oprot.getTransport().flush();
+ }
+ return result;
}
-
}
- private class update implements ProcessFunction {
- public void process(int seqid, org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException
- {
- update_args args = new update_args();
- try {
- args.read(iprot);
- } catch (org.apache.thrift.protocol.TProtocolException e) {
- iprot.readMessageEnd();
- org.apache.thrift.TApplicationException x = new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.PROTOCOL_ERROR, e.getMessage());
- oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("update", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid));
- x.write(oprot);
- oprot.writeMessageEnd();
- oprot.getTransport().flush();
- return;
- }
- iprot.readMessageEnd();
+ private static class update<I extends Iface> extends org.apache.thrift.ProcessFunction<I, update_args> {
+ public update() {
+ super("update");
+ }
+
+ protected update_args getEmptyArgsInstance() {
+ return new update_args();
+ }
+
[... 11863 lines stripped ...]