Return-Path: X-Original-To: apmail-accumulo-commits-archive@www.apache.org Delivered-To: apmail-accumulo-commits-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id D1BD510362 for ; Wed, 24 Jul 2013 19:49:21 +0000 (UTC) Received: (qmail 40252 invoked by uid 500); 24 Jul 2013 19:49:21 -0000 Delivered-To: apmail-accumulo-commits-archive@accumulo.apache.org Received: (qmail 40095 invoked by uid 500); 24 Jul 2013 19:49:21 -0000 Mailing-List: contact commits-help@accumulo.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@accumulo.apache.org Delivered-To: mailing list commits@accumulo.apache.org Received: (qmail 39932 invoked by uid 99); 24 Jul 2013 19:49:21 -0000 Received: from tyr.zones.apache.org (HELO tyr.zones.apache.org) (140.211.11.114) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 24 Jul 2013 19:49:21 +0000 Received: by tyr.zones.apache.org (Postfix, from userid 65534) id 0823F8B3D03; Wed, 24 Jul 2013 19:49:20 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: kturner@apache.org To: commits@accumulo.apache.org Date: Wed, 24 Jul 2013 19:49:22 -0000 Message-Id: <451961fb27954839853ab692c17b7fad@git.apache.org> In-Reply-To: References: X-Mailer: ASF-Git Admin Mailer Subject: [3/6] ACCUMULO-1000 added conditional mutations to Accumulo http://git-wip-us.apache.org/repos/asf/accumulo/blob/9dc24448/core/src/main/java/org/apache/accumulo/core/tabletserver/thrift/TabletClientService.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/accumulo/core/tabletserver/thrift/TabletClientService.java b/core/src/main/java/org/apache/accumulo/core/tabletserver/thrift/TabletClientService.java index 9144eb0..19fbb98 100644 --- a/core/src/main/java/org/apache/accumulo/core/tabletserver/thrift/TabletClientService.java +++ b/core/src/main/java/org/apache/accumulo/core/tabletserver/thrift/TabletClientService.java @@ -1,19 +1,3 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ /** * Autogenerated by Thrift Compiler (0.9.0) * @@ -46,7 +30,7 @@ import java.util.Arrays; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -@SuppressWarnings("all") public class TabletClientService { +public class TabletClientService { public interface Iface extends org.apache.accumulo.core.client.impl.thrift.ClientService.Iface { @@ -70,6 +54,14 @@ import org.slf4j.LoggerFactory; public void update(org.apache.accumulo.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, org.apache.accumulo.core.data.thrift.TKeyExtent keyExtent, org.apache.accumulo.core.data.thrift.TMutation mutation) throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, NotServingTabletException, ConstraintViolationException, org.apache.thrift.TException; + public org.apache.accumulo.core.data.thrift.TConditionalSession startConditionalUpdate(org.apache.accumulo.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, List authorizations, String tableID) throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.thrift.TException; + + public List conditionalUpdate(org.apache.accumulo.trace.thrift.TInfo tinfo, long sessID, Map> mutations, List symbols) throws NoSuchScanIDException, org.apache.thrift.TException; + + public void invalidateConditionalUpdate(org.apache.accumulo.trace.thrift.TInfo tinfo, long sessID) throws org.apache.thrift.TException; + + public void closeConditionalUpdate(org.apache.accumulo.trace.thrift.TInfo tinfo, long sessID) throws org.apache.thrift.TException; + public List bulkImport(org.apache.accumulo.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, long tid, Map> files, boolean setTime) throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.thrift.TException; public void splitTablet(org.apache.accumulo.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, org.apache.accumulo.core.data.thrift.TKeyExtent extent, ByteBuffer splitPoint) throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, NotServingTabletException, org.apache.thrift.TException; @@ -126,6 +118,14 @@ import org.slf4j.LoggerFactory; public void update(org.apache.accumulo.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, org.apache.accumulo.core.data.thrift.TKeyExtent keyExtent, org.apache.accumulo.core.data.thrift.TMutation mutation, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void startConditionalUpdate(org.apache.accumulo.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, List authorizations, String tableID, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void conditionalUpdate(org.apache.accumulo.trace.thrift.TInfo tinfo, long sessID, Map> mutations, List symbols, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void invalidateConditionalUpdate(org.apache.accumulo.trace.thrift.TInfo tinfo, long sessID, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void closeConditionalUpdate(org.apache.accumulo.trace.thrift.TInfo tinfo, long sessID, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void bulkImport(org.apache.accumulo.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, long tid, Map> files, boolean setTime, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; public void splitTablet(org.apache.accumulo.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, org.apache.accumulo.core.data.thrift.TKeyExtent extent, ByteBuffer splitPoint, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; @@ -453,6 +453,98 @@ import org.slf4j.LoggerFactory; return; } + public org.apache.accumulo.core.data.thrift.TConditionalSession startConditionalUpdate(org.apache.accumulo.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, List authorizations, String tableID) throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.thrift.TException + { + send_startConditionalUpdate(tinfo, credentials, authorizations, tableID); + return recv_startConditionalUpdate(); + } + + public void send_startConditionalUpdate(org.apache.accumulo.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, List authorizations, String tableID) throws org.apache.thrift.TException + { + startConditionalUpdate_args args = new startConditionalUpdate_args(); + args.setTinfo(tinfo); + args.setCredentials(credentials); + args.setAuthorizations(authorizations); + args.setTableID(tableID); + sendBase("startConditionalUpdate", args); + } + + public org.apache.accumulo.core.data.thrift.TConditionalSession recv_startConditionalUpdate() throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.thrift.TException + { + startConditionalUpdate_result result = new startConditionalUpdate_result(); + receiveBase(result, "startConditionalUpdate"); + if (result.isSetSuccess()) { + return result.success; + } + if (result.sec != null) { + throw result.sec; + } + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "startConditionalUpdate failed: unknown result"); + } + + public List conditionalUpdate(org.apache.accumulo.trace.thrift.TInfo tinfo, long sessID, Map> mutations, List symbols) throws NoSuchScanIDException, org.apache.thrift.TException + { + send_conditionalUpdate(tinfo, sessID, mutations, symbols); + return recv_conditionalUpdate(); + } + + public void send_conditionalUpdate(org.apache.accumulo.trace.thrift.TInfo tinfo, long sessID, Map> mutations, List symbols) throws org.apache.thrift.TException + { + conditionalUpdate_args args = new conditionalUpdate_args(); + args.setTinfo(tinfo); + args.setSessID(sessID); + args.setMutations(mutations); + args.setSymbols(symbols); + sendBase("conditionalUpdate", args); + } + + public List recv_conditionalUpdate() throws NoSuchScanIDException, org.apache.thrift.TException + { + conditionalUpdate_result result = new conditionalUpdate_result(); + receiveBase(result, "conditionalUpdate"); + if (result.isSetSuccess()) { + return result.success; + } + if (result.nssi != null) { + throw result.nssi; + } + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "conditionalUpdate failed: unknown result"); + } + + public void invalidateConditionalUpdate(org.apache.accumulo.trace.thrift.TInfo tinfo, long sessID) throws org.apache.thrift.TException + { + send_invalidateConditionalUpdate(tinfo, sessID); + recv_invalidateConditionalUpdate(); + } + + public void send_invalidateConditionalUpdate(org.apache.accumulo.trace.thrift.TInfo tinfo, long sessID) throws org.apache.thrift.TException + { + invalidateConditionalUpdate_args args = new invalidateConditionalUpdate_args(); + args.setTinfo(tinfo); + args.setSessID(sessID); + sendBase("invalidateConditionalUpdate", args); + } + + public void recv_invalidateConditionalUpdate() throws org.apache.thrift.TException + { + invalidateConditionalUpdate_result result = new invalidateConditionalUpdate_result(); + receiveBase(result, "invalidateConditionalUpdate"); + return; + } + + public void closeConditionalUpdate(org.apache.accumulo.trace.thrift.TInfo tinfo, long sessID) throws org.apache.thrift.TException + { + send_closeConditionalUpdate(tinfo, sessID); + } + + public void send_closeConditionalUpdate(org.apache.accumulo.trace.thrift.TInfo tinfo, long sessID) throws org.apache.thrift.TException + { + closeConditionalUpdate_args args = new closeConditionalUpdate_args(); + args.setTinfo(tinfo); + args.setSessID(sessID); + sendBase("closeConditionalUpdate", args); + } + public List bulkImport(org.apache.accumulo.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, long tid, Map> files, boolean setTime) throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.thrift.TException { send_bulkImport(tinfo, credentials, tid, files, setTime); @@ -1219,6 +1311,157 @@ import org.slf4j.LoggerFactory; } } + public void startConditionalUpdate(org.apache.accumulo.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, List authorizations, String tableID, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + startConditionalUpdate_call method_call = new startConditionalUpdate_call(tinfo, credentials, authorizations, tableID, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class startConditionalUpdate_call extends org.apache.thrift.async.TAsyncMethodCall { + private org.apache.accumulo.trace.thrift.TInfo tinfo; + private org.apache.accumulo.core.security.thrift.TCredentials credentials; + private List authorizations; + private String tableID; + public startConditionalUpdate_call(org.apache.accumulo.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, List authorizations, String tableID, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { + super(client, protocolFactory, transport, resultHandler, false); + this.tinfo = tinfo; + this.credentials = credentials; + this.authorizations = authorizations; + this.tableID = tableID; + } + + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("startConditionalUpdate", org.apache.thrift.protocol.TMessageType.CALL, 0)); + startConditionalUpdate_args args = new startConditionalUpdate_args(); + args.setTinfo(tinfo); + args.setCredentials(credentials); + args.setAuthorizations(authorizations); + args.setTableID(tableID); + args.write(prot); + prot.writeMessageEnd(); + } + + public org.apache.accumulo.core.data.thrift.TConditionalSession getResult() throws org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException, org.apache.thrift.TException { + if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { + throw new IllegalStateException("Method call not finished!"); + } + org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); + org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport); + return (new Client(prot)).recv_startConditionalUpdate(); + } + } + + public void conditionalUpdate(org.apache.accumulo.trace.thrift.TInfo tinfo, long sessID, Map> mutations, List symbols, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + conditionalUpdate_call method_call = new conditionalUpdate_call(tinfo, sessID, mutations, symbols, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class conditionalUpdate_call extends org.apache.thrift.async.TAsyncMethodCall { + private org.apache.accumulo.trace.thrift.TInfo tinfo; + private long sessID; + private Map> mutations; + private List symbols; + public conditionalUpdate_call(org.apache.accumulo.trace.thrift.TInfo tinfo, long sessID, Map> mutations, List symbols, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { + super(client, protocolFactory, transport, resultHandler, false); + this.tinfo = tinfo; + this.sessID = sessID; + this.mutations = mutations; + this.symbols = symbols; + } + + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("conditionalUpdate", org.apache.thrift.protocol.TMessageType.CALL, 0)); + conditionalUpdate_args args = new conditionalUpdate_args(); + args.setTinfo(tinfo); + args.setSessID(sessID); + args.setMutations(mutations); + args.setSymbols(symbols); + args.write(prot); + prot.writeMessageEnd(); + } + + public List getResult() throws NoSuchScanIDException, org.apache.thrift.TException { + if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { + throw new IllegalStateException("Method call not finished!"); + } + org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); + org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport); + return (new Client(prot)).recv_conditionalUpdate(); + } + } + + public void invalidateConditionalUpdate(org.apache.accumulo.trace.thrift.TInfo tinfo, long sessID, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + invalidateConditionalUpdate_call method_call = new invalidateConditionalUpdate_call(tinfo, sessID, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class invalidateConditionalUpdate_call extends org.apache.thrift.async.TAsyncMethodCall { + private org.apache.accumulo.trace.thrift.TInfo tinfo; + private long sessID; + public invalidateConditionalUpdate_call(org.apache.accumulo.trace.thrift.TInfo tinfo, long sessID, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { + super(client, protocolFactory, transport, resultHandler, false); + this.tinfo = tinfo; + this.sessID = sessID; + } + + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("invalidateConditionalUpdate", org.apache.thrift.protocol.TMessageType.CALL, 0)); + invalidateConditionalUpdate_args args = new invalidateConditionalUpdate_args(); + args.setTinfo(tinfo); + args.setSessID(sessID); + args.write(prot); + prot.writeMessageEnd(); + } + + public void getResult() throws org.apache.thrift.TException { + if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { + throw new IllegalStateException("Method call not finished!"); + } + org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); + org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport); + (new Client(prot)).recv_invalidateConditionalUpdate(); + } + } + + public void closeConditionalUpdate(org.apache.accumulo.trace.thrift.TInfo tinfo, long sessID, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + closeConditionalUpdate_call method_call = new closeConditionalUpdate_call(tinfo, sessID, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class closeConditionalUpdate_call extends org.apache.thrift.async.TAsyncMethodCall { + private org.apache.accumulo.trace.thrift.TInfo tinfo; + private long sessID; + public closeConditionalUpdate_call(org.apache.accumulo.trace.thrift.TInfo tinfo, long sessID, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { + super(client, protocolFactory, transport, resultHandler, true); + this.tinfo = tinfo; + this.sessID = sessID; + } + + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("closeConditionalUpdate", org.apache.thrift.protocol.TMessageType.CALL, 0)); + closeConditionalUpdate_args args = new closeConditionalUpdate_args(); + args.setTinfo(tinfo); + args.setSessID(sessID); + args.write(prot); + prot.writeMessageEnd(); + } + + public void getResult() throws org.apache.thrift.TException { + if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { + throw new IllegalStateException("Method call not finished!"); + } + org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); + org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport); + } + } + public void bulkImport(org.apache.accumulo.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, long tid, Map> files, boolean setTime, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { checkReady(); bulkImport_call method_call = new bulkImport_call(tinfo, credentials, tid, files, setTime, resultHandler, this, ___protocolFactory, ___transport); @@ -1872,6 +2115,10 @@ import org.slf4j.LoggerFactory; processMap.put("applyUpdates", new applyUpdates()); processMap.put("closeUpdate", new closeUpdate()); processMap.put("update", new update()); + processMap.put("startConditionalUpdate", new startConditionalUpdate()); + processMap.put("conditionalUpdate", new conditionalUpdate()); + processMap.put("invalidateConditionalUpdate", new invalidateConditionalUpdate()); + processMap.put("closeConditionalUpdate", new closeConditionalUpdate()); processMap.put("bulkImport", new bulkImport()); processMap.put("splitTablet", new splitTablet()); processMap.put("loadTablet", new loadTablet()); @@ -2134,6 +2381,93 @@ import org.slf4j.LoggerFactory; } } + public static class startConditionalUpdate extends org.apache.thrift.ProcessFunction { + public startConditionalUpdate() { + super("startConditionalUpdate"); + } + + public startConditionalUpdate_args getEmptyArgsInstance() { + return new startConditionalUpdate_args(); + } + + protected boolean isOneway() { + return false; + } + + public startConditionalUpdate_result getResult(I iface, startConditionalUpdate_args args) throws org.apache.thrift.TException { + startConditionalUpdate_result result = new startConditionalUpdate_result(); + try { + result.success = iface.startConditionalUpdate(args.tinfo, args.credentials, args.authorizations, args.tableID); + } catch (org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException sec) { + result.sec = sec; + } + return result; + } + } + + public static class conditionalUpdate extends org.apache.thrift.ProcessFunction { + public conditionalUpdate() { + super("conditionalUpdate"); + } + + public conditionalUpdate_args getEmptyArgsInstance() { + return new conditionalUpdate_args(); + } + + protected boolean isOneway() { + return false; + } + + public conditionalUpdate_result getResult(I iface, conditionalUpdate_args args) throws org.apache.thrift.TException { + conditionalUpdate_result result = new conditionalUpdate_result(); + try { + result.success = iface.conditionalUpdate(args.tinfo, args.sessID, args.mutations, args.symbols); + } catch (NoSuchScanIDException nssi) { + result.nssi = nssi; + } + return result; + } + } + + public static class invalidateConditionalUpdate extends org.apache.thrift.ProcessFunction { + public invalidateConditionalUpdate() { + super("invalidateConditionalUpdate"); + } + + public invalidateConditionalUpdate_args getEmptyArgsInstance() { + return new invalidateConditionalUpdate_args(); + } + + protected boolean isOneway() { + return false; + } + + public invalidateConditionalUpdate_result getResult(I iface, invalidateConditionalUpdate_args args) throws org.apache.thrift.TException { + invalidateConditionalUpdate_result result = new invalidateConditionalUpdate_result(); + iface.invalidateConditionalUpdate(args.tinfo, args.sessID); + return result; + } + } + + public static class closeConditionalUpdate extends org.apache.thrift.ProcessFunction { + public closeConditionalUpdate() { + super("closeConditionalUpdate"); + } + + public closeConditionalUpdate_args getEmptyArgsInstance() { + return new closeConditionalUpdate_args(); + } + + protected boolean isOneway() { + return true; + } + + public org.apache.thrift.TBase getResult(I iface, closeConditionalUpdate_args args) throws org.apache.thrift.TException { + iface.closeConditionalUpdate(args.tinfo, args.sessID); + return null; + } + } + public static class bulkImport extends org.apache.thrift.ProcessFunction { public bulkImport() { super("bulkImport"); @@ -2516,7 +2850,7 @@ import org.slf4j.LoggerFactory; public boolean isolated; // required /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ - @SuppressWarnings("all") public enum _Fields implements org.apache.thrift.TFieldIdEnum { + public enum _Fields implements org.apache.thrift.TFieldIdEnum { TINFO((short)11, "tinfo"), CREDENTIALS((short)1, "credentials"), EXTENT((short)2, "extent"), @@ -3685,7 +4019,7 @@ import org.slf4j.LoggerFactory; struct.columns = new ArrayList(_list106.size); for (int _i107 = 0; _i107 < _list106.size; ++_i107) { - org.apache.accumulo.core.data.thrift.TColumn _elem108; // optional + org.apache.accumulo.core.data.thrift.TColumn _elem108; // required _elem108 = new org.apache.accumulo.core.data.thrift.TColumn(); _elem108.read(iprot); struct.columns.add(_elem108); @@ -3712,7 +4046,7 @@ import org.slf4j.LoggerFactory; struct.ssiList = new ArrayList(_list109.size); for (int _i110 = 0; _i110 < _list109.size; ++_i110) { - org.apache.accumulo.core.data.thrift.IterInfo _elem111; // optional + org.apache.accumulo.core.data.thrift.IterInfo _elem111; // required _elem111 = new org.apache.accumulo.core.data.thrift.IterInfo(); _elem111.read(iprot); struct.ssiList.add(_elem111); @@ -3763,7 +4097,7 @@ import org.slf4j.LoggerFactory; struct.authorizations = new ArrayList(_list120.size); for (int _i121 = 0; _i121 < _list120.size; ++_i121) { - ByteBuffer _elem122; // optional + ByteBuffer _elem122; // required _elem122 = iprot.readBinary(); struct.authorizations.add(_elem122); } @@ -4040,7 +4374,7 @@ import org.slf4j.LoggerFactory; struct.columns = new ArrayList(_list133.size); for (int _i134 = 0; _i134 < _list133.size; ++_i134) { - org.apache.accumulo.core.data.thrift.TColumn _elem135; // optional + org.apache.accumulo.core.data.thrift.TColumn _elem135; // required _elem135 = new org.apache.accumulo.core.data.thrift.TColumn(); _elem135.read(iprot); struct.columns.add(_elem135); @@ -4058,7 +4392,7 @@ import org.slf4j.LoggerFactory; struct.ssiList = new ArrayList(_list136.size); for (int _i137 = 0; _i137 < _list136.size; ++_i137) { - org.apache.accumulo.core.data.thrift.IterInfo _elem138; // optional + org.apache.accumulo.core.data.thrift.IterInfo _elem138; // required _elem138 = new org.apache.accumulo.core.data.thrift.IterInfo(); _elem138.read(iprot); struct.ssiList.add(_elem138); @@ -4098,7 +4432,7 @@ import org.slf4j.LoggerFactory; struct.authorizations = new ArrayList(_list147.size); for (int _i148 = 0; _i148 < _list147.size; ++_i148) { - ByteBuffer _elem149; // optional + ByteBuffer _elem149; // required _elem149 = iprot.readBinary(); struct.authorizations.add(_elem149); } @@ -4138,7 +4472,7 @@ import org.slf4j.LoggerFactory; public TooManyFilesException tmfe; // required /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ - @SuppressWarnings("all") public enum _Fields implements org.apache.thrift.TFieldIdEnum { + public enum _Fields implements org.apache.thrift.TFieldIdEnum { SUCCESS((short)0, "success"), SEC((short)1, "sec"), NSTE((short)2, "nste"), @@ -4799,7 +5133,7 @@ import org.slf4j.LoggerFactory; public long scanID; // required /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ - @SuppressWarnings("all") public enum _Fields implements org.apache.thrift.TFieldIdEnum { + public enum _Fields implements org.apache.thrift.TFieldIdEnum { TINFO((short)2, "tinfo"), SCAN_ID((short)1, "scanID"); @@ -5260,7 +5594,7 @@ import org.slf4j.LoggerFactory; public TooManyFilesException tmfe; // required /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ - @SuppressWarnings("all") public enum _Fields implements org.apache.thrift.TFieldIdEnum { + public enum _Fields implements org.apache.thrift.TFieldIdEnum { SUCCESS((short)0, "success"), NSSI((short)1, "nssi"), NSTE((short)2, "nste"), @@ -5921,7 +6255,7 @@ import org.slf4j.LoggerFactory; public long scanID; // required /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ - @SuppressWarnings("all") public enum _Fields implements org.apache.thrift.TFieldIdEnum { + public enum _Fields implements org.apache.thrift.TFieldIdEnum { TINFO((short)2, "tinfo"), SCAN_ID((short)1, "scanID"); @@ -6390,7 +6724,7 @@ import org.slf4j.LoggerFactory; public boolean waitForWrites; // required /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ - @SuppressWarnings("all") public enum _Fields implements org.apache.thrift.TFieldIdEnum { + public enum _Fields implements org.apache.thrift.TFieldIdEnum { TINFO((short)8, "tinfo"), CREDENTIALS((short)1, "credentials"), BATCH((short)2, "batch"), @@ -7338,7 +7672,7 @@ import org.slf4j.LoggerFactory; _val153 = new ArrayList(_list154.size); for (int _i155 = 0; _i155 < _list154.size; ++_i155) { - org.apache.accumulo.core.data.thrift.TRange _elem156; // optional + org.apache.accumulo.core.data.thrift.TRange _elem156; // required _elem156 = new org.apache.accumulo.core.data.thrift.TRange(); _elem156.read(iprot); _val153.add(_elem156); @@ -7361,7 +7695,7 @@ import org.slf4j.LoggerFactory; struct.columns = new ArrayList(_list157.size); for (int _i158 = 0; _i158 < _list157.size; ++_i158) { - org.apache.accumulo.core.data.thrift.TColumn _elem159; // optional + org.apache.accumulo.core.data.thrift.TColumn _elem159; // required _elem159 = new org.apache.accumulo.core.data.thrift.TColumn(); _elem159.read(iprot); struct.columns.add(_elem159); @@ -7380,7 +7714,7 @@ import org.slf4j.LoggerFactory; struct.ssiList = new ArrayList(_list160.size); for (int _i161 = 0; _i161 < _list160.size; ++_i161) { - org.apache.accumulo.core.data.thrift.IterInfo _elem162; // optional + org.apache.accumulo.core.data.thrift.IterInfo _elem162; // required _elem162 = new org.apache.accumulo.core.data.thrift.IterInfo(); _elem162.read(iprot); struct.ssiList.add(_elem162); @@ -7431,7 +7765,7 @@ import org.slf4j.LoggerFactory; struct.authorizations = new ArrayList(_list171.size); for (int _i172 = 0; _i172 < _list171.size; ++_i172) { - ByteBuffer _elem173; // optional + ByteBuffer _elem173; // required _elem173 = iprot.readBinary(); struct.authorizations.add(_elem173); } @@ -7698,7 +8032,7 @@ import org.slf4j.LoggerFactory; _val191 = new ArrayList(_list192.size); for (int _i193 = 0; _i193 < _list192.size; ++_i193) { - org.apache.accumulo.core.data.thrift.TRange _elem194; // optional + org.apache.accumulo.core.data.thrift.TRange _elem194; // required _elem194 = new org.apache.accumulo.core.data.thrift.TRange(); _elem194.read(iprot); _val191.add(_elem194); @@ -7715,7 +8049,7 @@ import org.slf4j.LoggerFactory; struct.columns = new ArrayList(_list195.size); for (int _i196 = 0; _i196 < _list195.size; ++_i196) { - org.apache.accumulo.core.data.thrift.TColumn _elem197; // optional + org.apache.accumulo.core.data.thrift.TColumn _elem197; // required _elem197 = new org.apache.accumulo.core.data.thrift.TColumn(); _elem197.read(iprot); struct.columns.add(_elem197); @@ -7729,7 +8063,7 @@ import org.slf4j.LoggerFactory; struct.ssiList = new ArrayList(_list198.size); for (int _i199 = 0; _i199 < _list198.size; ++_i199) { - org.apache.accumulo.core.data.thrift.IterInfo _elem200; // optional + org.apache.accumulo.core.data.thrift.IterInfo _elem200; // required _elem200 = new org.apache.accumulo.core.data.thrift.IterInfo(); _elem200.read(iprot); struct.ssiList.add(_elem200); @@ -7769,7 +8103,7 @@ import org.slf4j.LoggerFactory; struct.authorizations = new ArrayList(_list209.size); for (int _i210 = 0; _i210 < _list209.size; ++_i210) { - ByteBuffer _elem211; // optional + ByteBuffer _elem211; // required _elem211 = iprot.readBinary(); struct.authorizations.add(_elem211); } @@ -7801,7 +8135,7 @@ import org.slf4j.LoggerFactory; public org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException sec; // required /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ - @SuppressWarnings("all") public enum _Fields implements org.apache.thrift.TFieldIdEnum { + public enum _Fields implements org.apache.thrift.TFieldIdEnum { SUCCESS((short)0, "success"), SEC((short)1, "sec"); @@ -8262,7 +8596,7 @@ import org.slf4j.LoggerFactory; public long scanID; // required /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ - @SuppressWarnings("all") public enum _Fields implements org.apache.thrift.TFieldIdEnum { + public enum _Fields implements org.apache.thrift.TFieldIdEnum { TINFO((short)2, "tinfo"), SCAN_ID((short)1, "scanID"); @@ -8719,7 +9053,7 @@ import org.slf4j.LoggerFactory; public NoSuchScanIDException nssi; // required /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ - @SuppressWarnings("all") public enum _Fields implements org.apache.thrift.TFieldIdEnum { + public enum _Fields implements org.apache.thrift.TFieldIdEnum { SUCCESS((short)0, "success"), NSSI((short)1, "nssi"); @@ -9180,7 +9514,7 @@ import org.slf4j.LoggerFactory; public long scanID; // required /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ - @SuppressWarnings("all") public enum _Fields implements org.apache.thrift.TFieldIdEnum { + public enum _Fields implements org.apache.thrift.TFieldIdEnum { TINFO((short)2, "tinfo"), SCAN_ID((short)1, "scanID"); @@ -9635,7 +9969,7 @@ import org.slf4j.LoggerFactory; public NoSuchScanIDException nssi; // required /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ - @SuppressWarnings("all") public enum _Fields implements org.apache.thrift.TFieldIdEnum { + public enum _Fields implements org.apache.thrift.TFieldIdEnum { NSSI((short)1, "nssi"); private static final Map byName = new HashMap(); @@ -9993,7 +10327,7 @@ import org.slf4j.LoggerFactory; public org.apache.accumulo.core.security.thrift.TCredentials credentials; // required /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ - @SuppressWarnings("all") public enum _Fields implements org.apache.thrift.TFieldIdEnum { + public enum _Fields implements org.apache.thrift.TFieldIdEnum { TINFO((short)2, "tinfo"), CREDENTIALS((short)1, "credentials"); @@ -10457,7 +10791,7 @@ import org.slf4j.LoggerFactory; public org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException sec; // required /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ - @SuppressWarnings("all") public enum _Fields implements org.apache.thrift.TFieldIdEnum { + public enum _Fields implements org.apache.thrift.TFieldIdEnum { SUCCESS((short)0, "success"), SEC((short)1, "sec"); @@ -10917,7 +11251,7 @@ import org.slf4j.LoggerFactory; public List mutations; // required /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ - @SuppressWarnings("all") public enum _Fields implements org.apache.thrift.TFieldIdEnum { + public enum _Fields implements org.apache.thrift.TFieldIdEnum { TINFO((short)1, "tinfo"), UPDATE_ID((short)2, "updateID"), KEY_EXTENT((short)3, "keyExtent"), @@ -11473,7 +11807,7 @@ import org.slf4j.LoggerFactory; struct.mutations = new ArrayList(_list212.size); for (int _i213 = 0; _i213 < _list212.size; ++_i213) { - org.apache.accumulo.core.data.thrift.TMutation _elem214; // optional + org.apache.accumulo.core.data.thrift.TMutation _elem214; // required _elem214 = new org.apache.accumulo.core.data.thrift.TMutation(); _elem214.read(iprot); struct.mutations.add(_elem214); @@ -11600,7 +11934,7 @@ import org.slf4j.LoggerFactory; struct.mutations = new ArrayList(_list217.size); for (int _i218 = 0; _i218 < _list217.size; ++_i218) { - org.apache.accumulo.core.data.thrift.TMutation _elem219; // optional + org.apache.accumulo.core.data.thrift.TMutation _elem219; // required _elem219 = new org.apache.accumulo.core.data.thrift.TMutation(); _elem219.read(iprot); struct.mutations.add(_elem219); @@ -11629,7 +11963,7 @@ import org.slf4j.LoggerFactory; public long updateID; // required /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ - @SuppressWarnings("all") public enum _Fields implements org.apache.thrift.TFieldIdEnum { + public enum _Fields implements org.apache.thrift.TFieldIdEnum { TINFO((short)2, "tinfo"), UPDATE_ID((short)1, "updateID"); @@ -12086,7 +12420,7 @@ import org.slf4j.LoggerFactory; public NoSuchScanIDException nssi; // required /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ - @SuppressWarnings("all") public enum _Fields implements org.apache.thrift.TFieldIdEnum { + public enum _Fields implements org.apache.thrift.TFieldIdEnum { SUCCESS((short)0, "success"), NSSI((short)1, "nssi"); @@ -12551,7 +12885,7 @@ import org.slf4j.LoggerFactory; public org.apache.accumulo.core.data.thrift.TMutation mutation; // required /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ - @SuppressWarnings("all") public enum _Fields implements org.apache.thrift.TFieldIdEnum { + public enum _Fields implements org.apache.thrift.TFieldIdEnum { TINFO((short)4, "tinfo"), CREDENTIALS((short)1, "credentials"), KEY_EXTENT((short)2, "keyExtent"), @@ -13223,7 +13557,7 @@ import org.slf4j.LoggerFactory; public ConstraintViolationException cve; // required /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ - @SuppressWarnings("all") public enum _Fields implements org.apache.thrift.TFieldIdEnum { + public enum _Fields implements org.apache.thrift.TFieldIdEnum { SEC((short)1, "sec"), NSTE((short)2, "nste"), CVE((short)3, "cve"); @@ -13765,6 +14099,3649 @@ import org.slf4j.LoggerFactory; } + public static class startConditionalUpdate_args implements org.apache.thrift.TBase, java.io.Serializable, Cloneable { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("startConditionalUpdate_args"); + + private static final org.apache.thrift.protocol.TField TINFO_FIELD_DESC = new org.apache.thrift.protocol.TField("tinfo", org.apache.thrift.protocol.TType.STRUCT, (short)1); + private static final org.apache.thrift.protocol.TField CREDENTIALS_FIELD_DESC = new org.apache.thrift.protocol.TField("credentials", org.apache.thrift.protocol.TType.STRUCT, (short)2); + private static final org.apache.thrift.protocol.TField AUTHORIZATIONS_FIELD_DESC = new org.apache.thrift.protocol.TField("authorizations", org.apache.thrift.protocol.TType.LIST, (short)3); + private static final org.apache.thrift.protocol.TField TABLE_ID_FIELD_DESC = new org.apache.thrift.protocol.TField("tableID", org.apache.thrift.protocol.TType.STRING, (short)4); + + private static final Map, SchemeFactory> schemes = new HashMap, SchemeFactory>(); + static { + schemes.put(StandardScheme.class, new startConditionalUpdate_argsStandardSchemeFactory()); + schemes.put(TupleScheme.class, new startConditionalUpdate_argsTupleSchemeFactory()); + } + + public org.apache.accumulo.trace.thrift.TInfo tinfo; // required + public org.apache.accumulo.core.security.thrift.TCredentials credentials; // required + public List authorizations; // required + public String tableID; // required + + /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ + public enum _Fields implements org.apache.thrift.TFieldIdEnum { + TINFO((short)1, "tinfo"), + CREDENTIALS((short)2, "credentials"), + AUTHORIZATIONS((short)3, "authorizations"), + TABLE_ID((short)4, "tableID"); + + private static final Map byName = new HashMap(); + + static { + for (_Fields field : EnumSet.allOf(_Fields.class)) { + byName.put(field.getFieldName(), field); + } + } + + /** + * Find the _Fields constant that matches fieldId, or null if its not found. + */ + public static _Fields findByThriftId(int fieldId) { + switch(fieldId) { + case 1: // TINFO + return TINFO; + case 2: // CREDENTIALS + return CREDENTIALS; + case 3: // AUTHORIZATIONS + return AUTHORIZATIONS; + case 4: // TABLE_ID + return TABLE_ID; + default: + return null; + } + } + + /** + * Find the _Fields constant that matches fieldId, throwing an exception + * if it is not found. + */ + public static _Fields findByThriftIdOrThrow(int fieldId) { + _Fields fields = findByThriftId(fieldId); + if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!"); + return fields; + } + + /** + * Find the _Fields constant that matches name, or null if its not found. + */ + public static _Fields findByName(String name) { + return byName.get(name); + } + + private final short _thriftId; + private final String _fieldName; + + _Fields(short thriftId, String fieldName) { + _thriftId = thriftId; + _fieldName = fieldName; + } + + public short getThriftFieldId() { + return _thriftId; + } + + public String getFieldName() { + return _fieldName; + } + } + + // isset id assignments + public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap; + static { + Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class); + tmpMap.put(_Fields.TINFO, new org.apache.thrift.meta_data.FieldMetaData("tinfo", org.apache.thrift.TFieldRequirementType.DEFAULT, + new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, org.apache.accumulo.trace.thrift.TInfo.class))); + tmpMap.put(_Fields.CREDENTIALS, new org.apache.thrift.meta_data.FieldMetaData("credentials", org.apache.thrift.TFieldRequirementType.DEFAULT, + new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, org.apache.accumulo.core.security.thrift.TCredentials.class))); + tmpMap.put(_Fields.AUTHORIZATIONS, new org.apache.thrift.meta_data.FieldMetaData("authorizations", org.apache.thrift.TFieldRequirementType.DEFAULT, + new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING , true)))); + tmpMap.put(_Fields.TABLE_ID, new org.apache.thrift.meta_data.FieldMetaData("tableID", org.apache.thrift.TFieldRequirementType.DEFAULT, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); + metaDataMap = Collections.unmodifiableMap(tmpMap); + org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(startConditionalUpdate_args.class, metaDataMap); + } + + public startConditionalUpdate_args() { + } + + public startConditionalUpdate_args( + org.apache.accumulo.trace.thrift.TInfo tinfo, + org.apache.accumulo.core.security.thrift.TCredentials credentials, + List authorizations, + String tableID) + { + this(); + this.tinfo = tinfo; + this.credentials = credentials; + this.authorizations = authorizations; + this.tableID = tableID; + } + + /** + * Performs a deep copy on other. + */ + public startConditionalUpdate_args(startConditionalUpdate_args other) { + if (other.isSetTinfo()) { + this.tinfo = new org.apache.accumulo.trace.thrift.TInfo(other.tinfo); + } + if (other.isSetCredentials()) { + this.credentials = new org.apache.accumulo.core.security.thrift.TCredentials(other.credentials); + } + if (other.isSetAuthorizations()) { + List __this__authorizations = new ArrayList(); + for (ByteBuffer other_element : other.authorizations) { + ByteBuffer temp_binary_element = org.apache.thrift.TBaseHelper.copyBinary(other_element); +; + __this__authorizations.add(temp_binary_element); + } + this.authorizations = __this__authorizations; + } + if (other.isSetTableID()) { + this.tableID = other.tableID; + } + } + + public startConditionalUpdate_args deepCopy() { + return new startConditionalUpdate_args(this); + } + + @Override + public void clear() { + this.tinfo = null; + this.credentials = null; + this.authorizations = null; + this.tableID = null; + } + + public org.apache.accumulo.trace.thrift.TInfo getTinfo() { + return this.tinfo; + } + + public startConditionalUpdate_args setTinfo(org.apache.accumulo.trace.thrift.TInfo tinfo) { + this.tinfo = tinfo; + return this; + } + + public void unsetTinfo() { + this.tinfo = null; + } + + /** Returns true if field tinfo is set (has been assigned 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.TCredentials getCredentials() { + return this.credentials; + } + + public startConditionalUpdate_args setCredentials(org.apache.accumulo.core.security.thrift.TCredentials credentials) { + this.credentials = credentials; + return this; + } + + public void unsetCredentials() { + this.credentials = null; + } + + /** Returns true if field credentials is set (has been assigned a value) and false otherwise */ + public boolean isSetCredentials() { + return this.credentials != null; + } + + public void setCredentialsIsSet(boolean value) { + if (!value) { + this.credentials = null; + } + } + + public int getAuthorizationsSize() { + return (this.authorizations == null) ? 0 : this.authorizations.size(); + } + + public java.util.Iterator getAuthorizationsIterator() { + return (this.authorizations == null) ? null : this.authorizations.iterator(); + } + + public void addToAuthorizations(ByteBuffer elem) { + if (this.authorizations == null) { + this.authorizations = new ArrayList(); + } + this.authorizations.add(elem); + } + + public List getAuthorizations() { + return this.authorizations; + } + + public startConditionalUpdate_args setAuthorizations(List authorizations) { + this.authorizations = authorizations; + return this; + } + + public void unsetAuthorizations() { + this.authorizations = null; + } + + /** Returns true if field authorizations is set (has been assigned a value) and false otherwise */ + public boolean isSetAuthorizations() { + return this.authorizations != null; + } + + public void setAuthorizationsIsSet(boolean value) { + if (!value) { + this.authorizations = null; + } + } + + public String getTableID() { + return this.tableID; + } + + public startConditionalUpdate_args setTableID(String tableID) { + this.tableID = tableID; + return this; + } + + public void unsetTableID() { + this.tableID = null; + } + + /** Returns true if field tableID is set (has been assigned a value) and false otherwise */ + public boolean isSetTableID() { + return this.tableID != null; + } + + public void setTableIDIsSet(boolean value) { + if (!value) { + this.tableID = null; + } + } + + public void setFieldValue(_Fields field, Object value) { + switch (field) { + case TINFO: + if (value == null) { + unsetTinfo(); + } else { + setTinfo((org.apache.accumulo.trace.thrift.TInfo)value); + } + break; + + case CREDENTIALS: + if (value == null) { + unsetCredentials(); + } else { + setCredentials((org.apache.accumulo.core.security.thrift.TCredentials)value); + } + break; + + case AUTHORIZATIONS: + if (value == null) { + unsetAuthorizations(); + } else { + setAuthorizations((List)value); + } + break; + + case TABLE_ID: + if (value == null) { + unsetTableID(); + } else { + setTableID((String)value); + } + break; + + } + } + + public Object getFieldValue(_Fields field) { + switch (field) { + case TINFO: + return getTinfo(); + + case CREDENTIALS: + return getCredentials(); + + case AUTHORIZATIONS: + return getAuthorizations(); + + case TABLE_ID: + return getTableID(); + + } + throw new IllegalStateException(); + } + + /** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */ + public boolean isSet(_Fields field) { + if (field == null) { + throw new IllegalArgumentException(); + } + + switch (field) { + case TINFO: + return isSetTinfo(); + case CREDENTIALS: + return isSetCredentials(); + case AUTHORIZATIONS: + return isSetAuthorizations(); + case TABLE_ID: + return isSetTableID(); + } + throw new IllegalStateException(); + } + + @Override + public boolean equals(Object that) { + if (that == null) + return false; + if (that instanceof startConditionalUpdate_args) + return this.equals((startConditionalUpdate_args)that); + return false; + } + + public boolean equals(startConditionalUpdate_args that) { + if (that == null) + return false; + + boolean this_present_tinfo = true && this.isSetTinfo(); + boolean that_present_tinfo = true && that.isSetTinfo(); + if (this_present_tinfo || that_present_tinfo) { + if (!(this_present_tinfo && that_present_tinfo)) + return false; + if (!this.tinfo.equals(that.tinfo)) + return false; + } + + boolean this_present_credentials = true && this.isSetCredentials(); + boolean that_present_credentials = true && that.isSetCredentials(); + if (this_present_credentials || that_present_credentials) { + if (!(this_present_credentials && that_present_credentials)) + return false; + if (!this.credentials.equals(that.credentials)) + return false; + } + + boolean this_present_authorizations = true && this.isSetAuthorizations(); + boolean that_present_authorizations = true && that.isSetAuthorizations(); + if (this_present_authorizations || that_present_authorizations) { + if (!(this_present_authorizations && that_present_authorizations)) + return false; + if (!this.authorizations.equals(that.authorizations)) + return false; + } + + boolean this_present_tableID = true && this.isSetTableID(); + boolean that_present_tableID = true && that.isSetTableID(); + if (this_present_tableID || that_present_tableID) { + if (!(this_present_tableID && that_present_tableID)) + return false; + if (!this.tableID.equals(that.tableID)) + return false; + } + + return true; + } + + @Override + public int hashCode() { + return 0; + } + + public int compareTo(startConditionalUpdate_args other) { + if (!getClass().equals(other.getClass())) { + return getClass().getName().compareTo(other.getClass().getName()); + } + + int lastComparison = 0; + startConditionalUpdate_args typedOther = (startConditionalUpdate_args)other; + + lastComparison = Boolean.valueOf(isSetTinfo()).compareTo(typedOther.isSetTinfo()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetTinfo()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.tinfo, typedOther.tinfo); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetCredentials()).compareTo(typedOther.isSetCredentials()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetCredentials()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.credentials, typedOther.credentials); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetAuthorizations()).compareTo(typedOther.isSetAuthorizations()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetAuthorizations()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.authorizations, typedOther.authorizations); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetTableID()).compareTo(typedOther.isSetTableID()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetTableID()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.tableID, typedOther.tableID); + if (lastComparison != 0) { + return lastComparison; + } + } + return 0; + } + + public _Fields fieldForId(int fieldId) { + return _Fields.findByThriftId(fieldId); + } + + public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException { + schemes.get(iprot.getScheme()).getScheme().read(iprot, this); + } + + public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException { + schemes.get(oprot.getScheme()).getScheme().write(oprot, this); + } + + @Override + public String toString() { + StringBuilder sb = new StringBuilder("startConditionalUpdate_args("); + boolean first = true; + + sb.append("tinfo:"); + if (this.tinfo == null) { + sb.append("null"); + } else { + sb.append(this.tinfo); + } + first = false; + if (!first) sb.append(", "); + sb.append("credentials:"); + if (this.credentials == null) { + sb.append("null"); + } else { + sb.append(this.credentials); + } + first = false; + if (!first) sb.append(", "); + sb.append("authorizations:"); + if (this.authorizations == null) { + sb.append("null"); + } else { + sb.append(this.authorizations); + } + first = false; + if (!first) sb.append(", "); + sb.append("tableID:"); + if (this.tableID == null) { + sb.append("null"); + } else { + sb.append(this.tableID); + } + first = false; + sb.append(")"); + return sb.toString(); + } + + public void validate() throws org.apache.thrift.TException { + // check for required fields + // check for sub-struct validity + if (tinfo != null) { + tinfo.validate(); + } + if (credentials != null) { + credentials.validate(); + } + } + + private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException { + try { + write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out))); + } catch (org.apache.thrift.TException te) { + throw new java.io.IOException(te); + } + } + + private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException { + try { + read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in))); + } catch (org.apache.thrift.TException te) { + throw new java.io.IOException(te); + } + } + + private static class startConditionalUpdate_argsStandardSchemeFactory implements SchemeFactory { + public startConditionalUpdate_argsStandardScheme getScheme() { + return new startConditionalUpdate_argsStandardScheme(); + } + } + + private static class startConditionalUpdate_argsStandardScheme extends StandardScheme { + + public void read(org.apache.thrift.protocol.TProtocol iprot, startConditionalUpdate_args struct) throws org.apache.thrift.TException { + org.apache.thrift.protocol.TField schemeField; + iprot.readStructBegin(); + while (true) + { + schemeField = iprot.readFieldBegin(); + if (schemeField.type == org.apache.thrift.protocol.TType.STOP) { + break; + } + switch (schemeField.id) { + case 1: // TINFO + if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) { + struct.tinfo = new org.apache.accumulo.trace.thrift.TInfo(); + struct.tinfo.read(iprot); + struct.setTinfoIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 2: // CREDENTIALS + if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) { + struct.credentials = new org.apache.accumulo.core.security.thrift.TCredentials(); + struct.credentials.read(iprot); + struct.setCredentialsIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 3: // AUTHORIZATIONS + if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { + { + org.apache.thrift.protocol.TList _list220 = iprot.readListBegin(); + struct.authorizations = new ArrayList(_list220.size); + for (int _i221 = 0; _i221 < _list220.size; ++_i221) + { + ByteBuffer _elem222; // required + _elem222 = iprot.readBinary(); + struct.authorizations.add(_elem222); + } + iprot.readListEnd(); + } + struct.setAuthorizationsIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 4: // TABLE_ID + if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { + struct.tableID = iprot.readString(); + struct.setTableIDIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + default: + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + iprot.readFieldEnd(); + } + iprot.readStructEnd(); + + // check for required fields of primitive type, which can't be checked in the validate method + struct.validate(); + } + + public void write(org.apache.thrift.protocol.TProtocol oprot, startConditionalUpdate_args struct) throws org.apache.thrift.TException { + struct.validate(); + + oprot.writeStructBegin(STRUCT_DESC); + if (struct.tinfo != null) { + oprot.writeFieldBegin(TINFO_FIELD_DESC); + struct.tinfo.write(oprot); + oprot.writeFieldEnd(); + } + if (struct.credentials != null) { + oprot.writeFieldBegin(CREDENTIALS_FIELD_DESC); + struct.credentials.write(oprot); + oprot.writeFieldEnd(); + } + if (struct.authorizations != null) { + oprot.writeFieldBegin(AUTHORIZATIONS_FIELD_DESC); + { + oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.authorizations.size())); + for (ByteBuffer _iter223 : struct.authorizations) + { + oprot.writeBinary(_iter223); + } + oprot.writeListEnd(); + } + oprot.writeFieldEnd(); + } + if (struct.tableID != null) { + oprot.writeFieldBegin(TABLE_ID_FIELD_DESC); + oprot.writeString(struct.tableID); + oprot.writeFieldEnd(); + } + oprot.writeFieldStop(); + oprot.writeStructEnd(); + } + + } + + private static class startConditionalUpdate_argsTupleSchemeFactory implements SchemeFactory { + public startConditionalUpdate_argsTupleScheme getScheme() { + return new startConditionalUpdate_argsTupleScheme(); + } + } + + private static class startConditionalUpdate_argsTupleScheme extends TupleScheme { + + @Override + public void write(org.apache.thrift.protocol.TProtocol prot, startConditionalUpdate_args struct) throws org.apache.thrift.TException { + TTupleProtocol oprot = (TTupleProtocol) prot; + BitSet optionals = new BitSet(); + if (struct.isSetTinfo()) { + optionals.set(0); + } + if (struct.isSetCredentials()) { + optionals.set(1); + } + if (struct.isSetAuthorizations()) { + optionals.set(2); + } + if (struct.isSetTableID()) { + optionals.set(3); + } + oprot.writeBitSet(optionals, 4); + if (struct.isSetTinfo()) { + struct.tinfo.write(oprot); + } + if (struct.isSetCredentials()) { + struct.credentials.write(oprot); + } + if (struct.isSetAuthorizations()) { + { + oprot.writeI32(struct.authorizations.size()); + for (ByteBuffer _iter224 : struct.authorizations) + { + oprot.writeBinary(_iter224); + } + } + } + if (struct.isSetTableID()) { + oprot.writeString(struct.tableID); + } + } + + @Override + public void read(org.apache.thrift.protocol.TProtocol prot, startConditionalUpdate_args struct) throws org.apache.thrift.TException { + TTupleProtocol iprot = (TTupleProtocol) prot; + BitSet incoming = iprot.readBitSet(4); + if (incoming.get(0)) { + struct.tinfo = new org.apache.accumulo.trace.thrift.TInfo(); + struct.tinfo.read(iprot); + struct.setTinfoIsSet(true); + } + if (incoming.get(1)) { + struct.credentials = new org.apache.accumulo.core.security.thrift.TCredentials(); + struct.credentials.read(iprot); + struct.setCredentialsIsSet(true); + } + if (incoming.get(2)) { + { + org.apache.thrift.protocol.TList _list225 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); + struct.authorizations = new ArrayList(_list225.size); + for (int _i226 = 0; _i226 < _list225.size; ++_i226) + { + ByteBuffer _elem227; // required + _elem227 = iprot.readBinary(); + struct.authorizations.add(_elem227); + } + } + struct.setAuthorizationsIsSet(true); + } + if (incoming.get(3)) { + struct.tableID = iprot.readString(); + struct.setTableIDIsSet(true); + } + } + } + + } + + public static class startConditionalUpdate_result implements org.apache.thrift.TBase, java.io.Serializable, Cloneable { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("startConditionalUpdate_result"); + + private static final org.apache.thrift.protocol.TField SUCCESS_FIELD_DESC = new org.apache.thrift.protocol.TField("success", org.apache.thrift.protocol.TType.STRUCT, (short)0); + private static final org.apache.thrift.protocol.TField SEC_FIELD_DESC = new org.apache.thrift.protocol.TField("sec", org.apache.thrift.protocol.TType.STRUCT, (short)1); + + private static final Map, SchemeFactory> schemes = new HashMap, SchemeFactory>(); + static { + schemes.put(StandardScheme.class, new startConditionalUpdate_resultStandardSchemeFactory()); + schemes.put(TupleScheme.class, new startConditionalUpdate_resultTupleSchemeFactory()); + } + + public org.apache.accumulo.core.data.thrift.TConditionalSession success; // required + public org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException sec; // required + + /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ + public enum _Fields implements org.apache.thrift.TFieldIdEnum { + SUCCESS((short)0, "success"), + SEC((short)1, "sec"); + + private static final Map byName = new HashMap(); + + static { + for (_Fields field : EnumSet.allOf(_Fields.class)) { + byName.put(field.getFieldName(), field); + } + } + + /** + * Find the _Fields constant that matches fieldId, or null if its not found. + */ + public static _Fields findByThriftId(int fieldId) { + switch(fieldId) { + case 0: // SUCCESS + return SUCCESS; + case 1: // SEC + return SEC; + default: + return null; + } + } + + /** + * Find the _Fields constant that matches fieldId, throwing an exception + * if it is not found. + */ + public static _Fields findByThriftIdOrThrow(int fieldId) { + _Fields fields = findByThriftId(fieldId); + if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!"); + return fields; + } + + /** + * Find the _Fields constant that matches name, or null if its not found. + */ + public static _Fields findByName(String name) { + return byName.get(name); + } + + private final short _thriftId; + private final String _fieldName; + + _Fields(short thriftId, String fieldName) { + _thriftId = thriftId; + _fieldName = fieldName; + } + + public short getThriftFieldId() { + return _thriftId; + } + + public String getFieldName() { + return _fieldName; + } + } + + // isset id assignments + public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap; + static { + Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class); + tmpMap.put(_Fields.SUCCESS, new org.apache.thrift.meta_data.FieldMetaData("success", org.apache.thrift.TFieldRequirementType.DEFAULT, + new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, org.apache.accumulo.core.data.thrift.TConditionalSession.class))); + tmpMap.put(_Fields.SEC, new org.apache.thrift.meta_data.FieldMetaData("sec", org.apache.thrift.TFieldRequirementType.DEFAULT, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT))); + metaDataMap = Collections.unmodifiableMap(tmpMap); + org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(startConditionalUpdate_result.class, metaDataMap); + } + + public startConditionalUpdate_result() { + } + + public startConditionalUpdate_result( + org.apache.accumulo.core.data.thrift.TConditionalSession success, + org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException sec) + { + this(); + this.success = success; + this.sec = sec; + } + + /** + * Performs a deep copy on other. + */ + public startConditionalUpdate_result(startConditionalUpdate_result other) { + if (other.isSetSuccess()) { + this.success = new org.apache.accumulo.core.data.thrift.TConditionalSession(other.success); + } + if (other.isSetSec()) { + this.sec = new org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException(other.sec); + } + } + + public startConditionalUpdate_result deepCopy() { + return new startConditionalUpdate_result(this); + } + + @Override + public void clear() { + this.success = null; + this.sec = null; + } + + public org.apache.accumulo.core.data.thrift.TConditionalSession getSuccess() { + return this.success; + } + + public startConditionalUpdate_result setSuccess(org.apache.accumulo.core.data.thrift.TConditionalSession success) { + this.success = success; + return this; + } + + public void unsetSuccess() { + this.success = null; + } + + /** Returns true if field success is set (has been assigned a value) and false otherwise */ + public boolean isSetSuccess() { + return this.success != null; + } + + public void setSuccessIsSet(boolean value) { + if (!value) { + this.success = null; + } + } + + public org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException getSec() { + return this.sec; + } + + public startConditionalUpdate_result setSec(org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException sec) { + this.sec = sec; + return this; + } + + public void unsetSec() { + this.sec = null; + } + + /** Returns true if field sec is set (has been assigned a value) and false otherwise */ + public boolean isSetSec() { + return this.sec != null; + } + + public void setSecIsSet(boolean value) { + if (!value) { + this.sec = null; + } + } + + public void setFieldValue(_Fields field, Object value) { + switch (field) { + case SUCCESS: + if (value == null) { + unsetSuccess(); + } else { + setSuccess((org.apache.accumulo.core.data.thrift.TConditionalSession)value); + } + break; + + case SEC: + if (value == null) { + unsetSec(); + } else { + setSec((org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException)value); + } + break; + + } + } + + public Object getFieldValue(_Fields field) { + switch (field) { + case SUCCESS: + return getSuccess(); + + case SEC: + return getSec(); + + } + throw new IllegalStateException(); + } + + /** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */ + public boolean isSet(_Fields field) { + if (field == null) { + throw new IllegalArgumentException(); + } + + switch (field) { + case SUCCESS: + return isSetSuccess(); + case SEC: + return isSetSec(); + } + throw new IllegalStateException(); + } + + @Override + public boolean equals(Object that) { + if (that == null) + return false; + if (that instanceof startConditionalUpdate_result) + return this.equals((startConditionalUpdate_result)that); + return false; + } + + public boolean equals(startConditionalUpdate_result that) { + if (that == null) + return false; + + boolean this_present_success = true && this.isSetSuccess(); + boolean that_present_success = true && that.isSetSuccess(); + if (this_present_success || that_present_success) { + if (!(this_present_success && that_present_success)) + return false; + if (!this.success.equals(that.success)) + return false; + } + + boolean this_present_sec = true && this.isSetSec(); + boolean that_present_sec = true && that.isSetSec(); + if (this_present_sec || that_present_sec) { + if (!(this_present_sec && that_present_sec)) + return false; + if (!this.sec.equals(that.sec)) + return false; + } + + return true; + } + + @Override + public int hashCode() { + return 0; + } + + public int compareTo(startConditionalUpdate_result other) { + if (!getClass().equals(other.getClass())) { + return getClass().getName().compareTo(other.getClass().getName()); + } + + int lastComparison = 0; + startConditionalUpdate_result typedOther = (startConditionalUpdate_result)other; + + lastComparison = Boolean.valueOf(isSetSuccess()).compareTo(typedOther.isSetSuccess()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetSuccess()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.success, typedOther.success); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetSec()).compareTo(typedOther.isSetSec()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetSec()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.sec, typedOther.sec); + if (lastComparison != 0) { + return lastComparison; + } + } + return 0; + } + + public _Fields fieldForId(int fieldId) { + return _Fields.findByThriftId(fieldId); + } + + public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException { + schemes.get(iprot.getScheme()).getScheme().read(iprot, this); + } + + public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException { + schemes.get(oprot.getScheme()).getScheme().write(oprot, this); + } + + @Override + public String toString() { + StringBuilder sb = new StringBuilder("startConditionalUpdate_result("); + boolean first = true; + + sb.append("success:"); + if (this.success == null) { + sb.append("null"); + } else { + sb.append(this.success); + } + first = false; + if (!first) sb.append(", "); + sb.append("sec:"); + if (this.sec == null) { + sb.append("null"); + } else { + sb.append(this.sec); + } + first = false; + sb.append(")"); + return sb.toString(); + } + + public void validate() throws org.apache.thrift.TException { + // check for required fields + // check for sub-struct validity + if (success != null) { + success.validate(); + } + } + + private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException { + try { + write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out))); + } catch (org.apache.thrift.TException te) { + throw new java.io.IOException(te); + } + } + + private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException { + try { + read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in))); + } catch (org.apache.thrift.TException te) { + throw new java.io.IOException(te); + } + } + + private static class startConditionalUpdate_resultStandardSchemeFactory implements SchemeFactory { + public startConditionalUpdate_resultStandardScheme getScheme() { + return new startConditionalUpdate_resultStandardScheme(); + } + } + + private static class startConditionalUpdate_resultStandardScheme extends StandardScheme { + + public void read(org.apache.thrift.protocol.TProtocol iprot, startConditionalUpdate_result struct) throws org.apache.thrift.TException { + org.apache.thrift.protocol.TField schemeField; + iprot.readStructBegin(); + while (true) + { + schemeField = iprot.readFieldBegin(); + if (schemeField.type == org.apache.thrift.protocol.TType.STOP) { + break; + } + switch (schemeField.id) { + case 0: // SUCCESS + if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) { + struct.success = new org.apache.accumulo.core.data.thrift.TConditionalSession(); + struct.success.read(iprot); + struct.setSuccessIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 1: // SEC + if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) { + struct.sec = new org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException(); + struct.sec.read(iprot); + struct.setSecIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + default: + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + iprot.readFieldEnd(); + } + iprot.readStructEnd(); + + // check for required fields of primitive type, which can't be checked in the validate method + struct.validate(); + } + + public void write(org.apache.thrift.protocol.TProtocol oprot, startConditionalUpdate_result struct) throws org.apache.thrift.TException { + struct.validate(); + + oprot.writeStructBegin(STRUCT_DESC); + if (struct.success != null) { + oprot.writeFieldBegin(SUCCESS_FIELD_DESC); + struct.success.write(oprot); + oprot.writeFieldEnd(); + } + if (struct.sec != null) { + oprot.writeFieldBegin(SEC_FIELD_DESC); + struct.sec.write(oprot); + oprot.writeFieldEnd(); + } + oprot.writeFieldStop(); + oprot.writeStructEnd(); + } + + } + + private static class startConditionalUpdate_resultTupleSchemeFactory implements SchemeFactory { + public startConditionalUpdate_resultTupleScheme getScheme() { + return new startConditionalUpdate_resultTupleScheme(); + } + } + + private static class startConditionalUpdate_resultTupleScheme extends TupleScheme { + + @Override + public void write(org.apache.thrift.protocol.TProtocol prot, startConditionalUpdate_result struct) throws org.apache.thrift.TException { + TTupleProtocol oprot = (TTupleProtocol) prot; + BitSet optionals = new BitSet(); + if (struct.isSetSuccess()) { + optionals.set(0); + } + if (struct.isSetSec()) { + optionals.set(1); + } + oprot.writeBitSet(optionals, 2); + if (struct.isSetSuccess()) { + struct.success.write(oprot); + } + if (struct.isSetSec()) { + struct.sec.write(oprot); + } + } + + @Override + public void read(org.apache.thrift.protocol.TProtocol prot, startConditionalUpdate_result struct) throws org.apache.thrift.TException { + TTupleProtocol iprot = (TTupleProtocol) prot; + BitSet incoming = iprot.readBitSet(2); + if (incoming.get(0)) { + struct.success = new org.apache.accumulo.core.data.thrift.TConditionalSession(); + struct.success.read(iprot); + struct.setSuccessIsSet(true); + } + if (incoming.get(1)) { + struct.sec = new org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException(); + struct.sec.read(iprot); + struct.setSecIsSet(true); + } + } + } + + } + + public static class conditionalUpdate_args implements org.apache.thrift.TBase, java.io.Serializable, Cloneable { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("conditionalUpdate_args"); + + private static final org.apache.thrift.protocol.TField TINFO_FIELD_DESC = new org.apache.thrift.protocol.TField("tinfo", org.apache.thrift.protocol.TType.STRUCT, (short)1); + private static final org.apache.thrift.protocol.TField SESS_ID_FIELD_DESC = new org.apache.thrift.protocol.TField("sessID", org.apache.thrift.protocol.TType.I64, (short)2); + private static final org.apache.thrift.protocol.TField MUTATIONS_FIELD_DESC = new org.apache.thrift.protocol.TField("mutations", org.apache.thrift.protocol.TType.MAP, (short)3); + private static final org.apache.thrift.protocol.TField SYMBOLS_FIELD_DESC = new org.apache.thrift.protocol.TField("symbols", org.apache.thrift.protocol.TType.LIST, (short)4); + + private static final Map, SchemeFactory> schemes = new HashMap, SchemeFactory>(); + static { + schemes.put(StandardScheme.class, new conditionalUpdate_argsStandardSchemeFactory()); + schemes.put(TupleScheme.class, new conditionalUpdate_argsTupleSchemeFactory()); + } + + public org.apache.accumulo.trace.thrift.TInfo tinfo; // required + public long sessID; // required + public Map> mutations; // required + public List symbols; // required + + /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ + public enum _Fields implements org.apache.thrift.TFieldIdEnum { + TINFO((short)1, "tinfo"), + SESS_ID((short)2, "sessID"), + MUTATIONS((short)3, "mutations"), + SYMBOLS((short)4, "symbols"); + + private static final Map byName = new HashMap(); + + static {