| /* |
| * 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 |
| * |
| * https://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.17.0) |
| * |
| * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING |
| * @generated |
| */ |
| package org.apache.accumulo.core.compaction.thrift; |
| |
| @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"}) |
| public class CompactorService { |
| |
| public interface Iface { |
| |
| public org.apache.accumulo.core.tabletserver.thrift.TExternalCompactionJob getRunningCompaction(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.securityImpl.thrift.TCredentials credentials) throws org.apache.accumulo.core.clientImpl.thrift.ThriftSecurityException, org.apache.thrift.TException; |
| |
| public java.lang.String getRunningCompactionId(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.securityImpl.thrift.TCredentials credentials) throws org.apache.accumulo.core.clientImpl.thrift.ThriftSecurityException, org.apache.thrift.TException; |
| |
| public java.util.List<org.apache.accumulo.core.tabletserver.thrift.ActiveCompaction> getActiveCompactions(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.securityImpl.thrift.TCredentials credentials) throws org.apache.accumulo.core.clientImpl.thrift.ThriftSecurityException, org.apache.thrift.TException; |
| |
| public void cancel(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.securityImpl.thrift.TCredentials credentials, java.lang.String externalCompactionId) throws org.apache.thrift.TException; |
| |
| } |
| |
| public interface AsyncIface { |
| |
| public void getRunningCompaction(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.securityImpl.thrift.TCredentials credentials, org.apache.thrift.async.AsyncMethodCallback<org.apache.accumulo.core.tabletserver.thrift.TExternalCompactionJob> resultHandler) throws org.apache.thrift.TException; |
| |
| public void getRunningCompactionId(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.securityImpl.thrift.TCredentials credentials, org.apache.thrift.async.AsyncMethodCallback<java.lang.String> resultHandler) throws org.apache.thrift.TException; |
| |
| public void getActiveCompactions(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.securityImpl.thrift.TCredentials credentials, org.apache.thrift.async.AsyncMethodCallback<java.util.List<org.apache.accumulo.core.tabletserver.thrift.ActiveCompaction>> resultHandler) throws org.apache.thrift.TException; |
| |
| public void cancel(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.securityImpl.thrift.TCredentials credentials, java.lang.String externalCompactionId, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.thrift.TException; |
| |
| } |
| |
| public static class Client extends org.apache.thrift.TServiceClient implements Iface { |
| public static class Factory implements org.apache.thrift.TServiceClientFactory<Client> { |
| public Factory() {} |
| @Override |
| public Client getClient(org.apache.thrift.protocol.TProtocol prot) { |
| return new Client(prot); |
| } |
| @Override |
| public Client getClient(org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) { |
| return new Client(iprot, oprot); |
| } |
| } |
| |
| public Client(org.apache.thrift.protocol.TProtocol prot) |
| { |
| super(prot, prot); |
| } |
| |
| public Client(org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) { |
| super(iprot, oprot); |
| } |
| |
| @Override |
| public org.apache.accumulo.core.tabletserver.thrift.TExternalCompactionJob getRunningCompaction(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.securityImpl.thrift.TCredentials credentials) throws org.apache.accumulo.core.clientImpl.thrift.ThriftSecurityException, org.apache.thrift.TException |
| { |
| send_getRunningCompaction(tinfo, credentials); |
| return recv_getRunningCompaction(); |
| } |
| |
| public void send_getRunningCompaction(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.securityImpl.thrift.TCredentials credentials) throws org.apache.thrift.TException |
| { |
| getRunningCompaction_args args = new getRunningCompaction_args(); |
| args.setTinfo(tinfo); |
| args.setCredentials(credentials); |
| sendBase("getRunningCompaction", args); |
| } |
| |
| public org.apache.accumulo.core.tabletserver.thrift.TExternalCompactionJob recv_getRunningCompaction() throws org.apache.accumulo.core.clientImpl.thrift.ThriftSecurityException, org.apache.thrift.TException |
| { |
| getRunningCompaction_result result = new getRunningCompaction_result(); |
| receiveBase(result, "getRunningCompaction"); |
| 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, "getRunningCompaction failed: unknown result"); |
| } |
| |
| @Override |
| public java.lang.String getRunningCompactionId(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.securityImpl.thrift.TCredentials credentials) throws org.apache.accumulo.core.clientImpl.thrift.ThriftSecurityException, org.apache.thrift.TException |
| { |
| send_getRunningCompactionId(tinfo, credentials); |
| return recv_getRunningCompactionId(); |
| } |
| |
| public void send_getRunningCompactionId(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.securityImpl.thrift.TCredentials credentials) throws org.apache.thrift.TException |
| { |
| getRunningCompactionId_args args = new getRunningCompactionId_args(); |
| args.setTinfo(tinfo); |
| args.setCredentials(credentials); |
| sendBase("getRunningCompactionId", args); |
| } |
| |
| public java.lang.String recv_getRunningCompactionId() throws org.apache.accumulo.core.clientImpl.thrift.ThriftSecurityException, org.apache.thrift.TException |
| { |
| getRunningCompactionId_result result = new getRunningCompactionId_result(); |
| receiveBase(result, "getRunningCompactionId"); |
| 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, "getRunningCompactionId failed: unknown result"); |
| } |
| |
| @Override |
| public java.util.List<org.apache.accumulo.core.tabletserver.thrift.ActiveCompaction> getActiveCompactions(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.securityImpl.thrift.TCredentials credentials) throws org.apache.accumulo.core.clientImpl.thrift.ThriftSecurityException, org.apache.thrift.TException |
| { |
| send_getActiveCompactions(tinfo, credentials); |
| return recv_getActiveCompactions(); |
| } |
| |
| public void send_getActiveCompactions(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.securityImpl.thrift.TCredentials credentials) throws org.apache.thrift.TException |
| { |
| getActiveCompactions_args args = new getActiveCompactions_args(); |
| args.setTinfo(tinfo); |
| args.setCredentials(credentials); |
| sendBase("getActiveCompactions", args); |
| } |
| |
| public java.util.List<org.apache.accumulo.core.tabletserver.thrift.ActiveCompaction> recv_getActiveCompactions() throws org.apache.accumulo.core.clientImpl.thrift.ThriftSecurityException, org.apache.thrift.TException |
| { |
| getActiveCompactions_result result = new getActiveCompactions_result(); |
| receiveBase(result, "getActiveCompactions"); |
| 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, "getActiveCompactions failed: unknown result"); |
| } |
| |
| @Override |
| public void cancel(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.securityImpl.thrift.TCredentials credentials, java.lang.String externalCompactionId) throws org.apache.thrift.TException |
| { |
| send_cancel(tinfo, credentials, externalCompactionId); |
| recv_cancel(); |
| } |
| |
| public void send_cancel(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.securityImpl.thrift.TCredentials credentials, java.lang.String externalCompactionId) throws org.apache.thrift.TException |
| { |
| cancel_args args = new cancel_args(); |
| args.setTinfo(tinfo); |
| args.setCredentials(credentials); |
| args.setExternalCompactionId(externalCompactionId); |
| sendBase("cancel", args); |
| } |
| |
| public void recv_cancel() throws org.apache.thrift.TException |
| { |
| cancel_result result = new cancel_result(); |
| receiveBase(result, "cancel"); |
| return; |
| } |
| |
| } |
| public static class AsyncClient extends org.apache.thrift.async.TAsyncClient implements AsyncIface { |
| public static class Factory implements org.apache.thrift.async.TAsyncClientFactory<AsyncClient> { |
| private org.apache.thrift.async.TAsyncClientManager clientManager; |
| private org.apache.thrift.protocol.TProtocolFactory protocolFactory; |
| public Factory(org.apache.thrift.async.TAsyncClientManager clientManager, org.apache.thrift.protocol.TProtocolFactory protocolFactory) { |
| this.clientManager = clientManager; |
| this.protocolFactory = protocolFactory; |
| } |
| @Override |
| public AsyncClient getAsyncClient(org.apache.thrift.transport.TNonblockingTransport transport) { |
| return new AsyncClient(protocolFactory, clientManager, transport); |
| } |
| } |
| |
| public AsyncClient(org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.async.TAsyncClientManager clientManager, org.apache.thrift.transport.TNonblockingTransport transport) { |
| super(protocolFactory, clientManager, transport); |
| } |
| |
| @Override |
| public void getRunningCompaction(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.securityImpl.thrift.TCredentials credentials, org.apache.thrift.async.AsyncMethodCallback<org.apache.accumulo.core.tabletserver.thrift.TExternalCompactionJob> resultHandler) throws org.apache.thrift.TException { |
| checkReady(); |
| getRunningCompaction_call method_call = new getRunningCompaction_call(tinfo, credentials, resultHandler, this, ___protocolFactory, ___transport); |
| this.___currentMethod = method_call; |
| ___manager.call(method_call); |
| } |
| |
| public static class getRunningCompaction_call extends org.apache.thrift.async.TAsyncMethodCall<org.apache.accumulo.core.tabletserver.thrift.TExternalCompactionJob> { |
| private org.apache.accumulo.core.trace.thrift.TInfo tinfo; |
| private org.apache.accumulo.core.securityImpl.thrift.TCredentials credentials; |
| public getRunningCompaction_call(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.securityImpl.thrift.TCredentials credentials, org.apache.thrift.async.AsyncMethodCallback<org.apache.accumulo.core.tabletserver.thrift.TExternalCompactionJob> 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; |
| } |
| |
| @Override |
| public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { |
| prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getRunningCompaction", org.apache.thrift.protocol.TMessageType.CALL, 0)); |
| getRunningCompaction_args args = new getRunningCompaction_args(); |
| args.setTinfo(tinfo); |
| args.setCredentials(credentials); |
| args.write(prot); |
| prot.writeMessageEnd(); |
| } |
| |
| @Override |
| public org.apache.accumulo.core.tabletserver.thrift.TExternalCompactionJob getResult() throws org.apache.accumulo.core.clientImpl.thrift.ThriftSecurityException, org.apache.thrift.TException { |
| if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { |
| throw new java.lang.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_getRunningCompaction(); |
| } |
| } |
| |
| @Override |
| public void getRunningCompactionId(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.securityImpl.thrift.TCredentials credentials, org.apache.thrift.async.AsyncMethodCallback<java.lang.String> resultHandler) throws org.apache.thrift.TException { |
| checkReady(); |
| getRunningCompactionId_call method_call = new getRunningCompactionId_call(tinfo, credentials, resultHandler, this, ___protocolFactory, ___transport); |
| this.___currentMethod = method_call; |
| ___manager.call(method_call); |
| } |
| |
| public static class getRunningCompactionId_call extends org.apache.thrift.async.TAsyncMethodCall<java.lang.String> { |
| private org.apache.accumulo.core.trace.thrift.TInfo tinfo; |
| private org.apache.accumulo.core.securityImpl.thrift.TCredentials credentials; |
| public getRunningCompactionId_call(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.securityImpl.thrift.TCredentials credentials, org.apache.thrift.async.AsyncMethodCallback<java.lang.String> 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; |
| } |
| |
| @Override |
| public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { |
| prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getRunningCompactionId", org.apache.thrift.protocol.TMessageType.CALL, 0)); |
| getRunningCompactionId_args args = new getRunningCompactionId_args(); |
| args.setTinfo(tinfo); |
| args.setCredentials(credentials); |
| args.write(prot); |
| prot.writeMessageEnd(); |
| } |
| |
| @Override |
| public java.lang.String getResult() throws org.apache.accumulo.core.clientImpl.thrift.ThriftSecurityException, org.apache.thrift.TException { |
| if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { |
| throw new java.lang.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_getRunningCompactionId(); |
| } |
| } |
| |
| @Override |
| public void getActiveCompactions(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.securityImpl.thrift.TCredentials credentials, org.apache.thrift.async.AsyncMethodCallback<java.util.List<org.apache.accumulo.core.tabletserver.thrift.ActiveCompaction>> resultHandler) throws org.apache.thrift.TException { |
| checkReady(); |
| getActiveCompactions_call method_call = new getActiveCompactions_call(tinfo, credentials, resultHandler, this, ___protocolFactory, ___transport); |
| this.___currentMethod = method_call; |
| ___manager.call(method_call); |
| } |
| |
| public static class getActiveCompactions_call extends org.apache.thrift.async.TAsyncMethodCall<java.util.List<org.apache.accumulo.core.tabletserver.thrift.ActiveCompaction>> { |
| private org.apache.accumulo.core.trace.thrift.TInfo tinfo; |
| private org.apache.accumulo.core.securityImpl.thrift.TCredentials credentials; |
| public getActiveCompactions_call(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.securityImpl.thrift.TCredentials credentials, org.apache.thrift.async.AsyncMethodCallback<java.util.List<org.apache.accumulo.core.tabletserver.thrift.ActiveCompaction>> 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; |
| } |
| |
| @Override |
| public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { |
| prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getActiveCompactions", org.apache.thrift.protocol.TMessageType.CALL, 0)); |
| getActiveCompactions_args args = new getActiveCompactions_args(); |
| args.setTinfo(tinfo); |
| args.setCredentials(credentials); |
| args.write(prot); |
| prot.writeMessageEnd(); |
| } |
| |
| @Override |
| public java.util.List<org.apache.accumulo.core.tabletserver.thrift.ActiveCompaction> getResult() throws org.apache.accumulo.core.clientImpl.thrift.ThriftSecurityException, org.apache.thrift.TException { |
| if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { |
| throw new java.lang.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_getActiveCompactions(); |
| } |
| } |
| |
| @Override |
| public void cancel(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.securityImpl.thrift.TCredentials credentials, java.lang.String externalCompactionId, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.thrift.TException { |
| checkReady(); |
| cancel_call method_call = new cancel_call(tinfo, credentials, externalCompactionId, resultHandler, this, ___protocolFactory, ___transport); |
| this.___currentMethod = method_call; |
| ___manager.call(method_call); |
| } |
| |
| public static class cancel_call extends org.apache.thrift.async.TAsyncMethodCall<Void> { |
| private org.apache.accumulo.core.trace.thrift.TInfo tinfo; |
| private org.apache.accumulo.core.securityImpl.thrift.TCredentials credentials; |
| private java.lang.String externalCompactionId; |
| public cancel_call(org.apache.accumulo.core.trace.thrift.TInfo tinfo, org.apache.accumulo.core.securityImpl.thrift.TCredentials credentials, java.lang.String externalCompactionId, org.apache.thrift.async.AsyncMethodCallback<Void> 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.externalCompactionId = externalCompactionId; |
| } |
| |
| @Override |
| public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { |
| prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("cancel", org.apache.thrift.protocol.TMessageType.CALL, 0)); |
| cancel_args args = new cancel_args(); |
| args.setTinfo(tinfo); |
| args.setCredentials(credentials); |
| args.setExternalCompactionId(externalCompactionId); |
| args.write(prot); |
| prot.writeMessageEnd(); |
| } |
| |
| @Override |
| public Void getResult() throws org.apache.thrift.TException { |
| if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { |
| throw new java.lang.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_cancel(); |
| return null; |
| } |
| } |
| |
| } |
| |
| public static class Processor<I extends Iface> extends org.apache.thrift.TBaseProcessor<I> implements org.apache.thrift.TProcessor { |
| private static final org.slf4j.Logger _LOGGER = org.slf4j.LoggerFactory.getLogger(Processor.class.getName()); |
| public Processor(I iface) { |
| super(iface, getProcessMap(new java.util.HashMap<java.lang.String, org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>>())); |
| } |
| |
| protected Processor(I iface, java.util.Map<java.lang.String, org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>> processMap) { |
| super(iface, getProcessMap(processMap)); |
| } |
| |
| private static <I extends Iface> java.util.Map<java.lang.String, org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>> getProcessMap(java.util.Map<java.lang.String, org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>> processMap) { |
| processMap.put("getRunningCompaction", new getRunningCompaction()); |
| processMap.put("getRunningCompactionId", new getRunningCompactionId()); |
| processMap.put("getActiveCompactions", new getActiveCompactions()); |
| processMap.put("cancel", new cancel()); |
| return processMap; |
| } |
| |
| public static class getRunningCompaction<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getRunningCompaction_args> { |
| public getRunningCompaction() { |
| super("getRunningCompaction"); |
| } |
| |
| @Override |
| public getRunningCompaction_args getEmptyArgsInstance() { |
| return new getRunningCompaction_args(); |
| } |
| |
| @Override |
| protected boolean isOneway() { |
| return false; |
| } |
| |
| @Override |
| protected boolean rethrowUnhandledExceptions() { |
| return false; |
| } |
| |
| @Override |
| public getRunningCompaction_result getResult(I iface, getRunningCompaction_args args) throws org.apache.thrift.TException { |
| getRunningCompaction_result result = new getRunningCompaction_result(); |
| try { |
| result.success = iface.getRunningCompaction(args.tinfo, args.credentials); |
| } catch (org.apache.accumulo.core.clientImpl.thrift.ThriftSecurityException sec) { |
| result.sec = sec; |
| } |
| return result; |
| } |
| } |
| |
| public static class getRunningCompactionId<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getRunningCompactionId_args> { |
| public getRunningCompactionId() { |
| super("getRunningCompactionId"); |
| } |
| |
| @Override |
| public getRunningCompactionId_args getEmptyArgsInstance() { |
| return new getRunningCompactionId_args(); |
| } |
| |
| @Override |
| protected boolean isOneway() { |
| return false; |
| } |
| |
| @Override |
| protected boolean rethrowUnhandledExceptions() { |
| return false; |
| } |
| |
| @Override |
| public getRunningCompactionId_result getResult(I iface, getRunningCompactionId_args args) throws org.apache.thrift.TException { |
| getRunningCompactionId_result result = new getRunningCompactionId_result(); |
| try { |
| result.success = iface.getRunningCompactionId(args.tinfo, args.credentials); |
| } catch (org.apache.accumulo.core.clientImpl.thrift.ThriftSecurityException sec) { |
| result.sec = sec; |
| } |
| return result; |
| } |
| } |
| |
| public static class getActiveCompactions<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getActiveCompactions_args> { |
| public getActiveCompactions() { |
| super("getActiveCompactions"); |
| } |
| |
| @Override |
| public getActiveCompactions_args getEmptyArgsInstance() { |
| return new getActiveCompactions_args(); |
| } |
| |
| @Override |
| protected boolean isOneway() { |
| return false; |
| } |
| |
| @Override |
| protected boolean rethrowUnhandledExceptions() { |
| return false; |
| } |
| |
| @Override |
| public getActiveCompactions_result getResult(I iface, getActiveCompactions_args args) throws org.apache.thrift.TException { |
| getActiveCompactions_result result = new getActiveCompactions_result(); |
| try { |
| result.success = iface.getActiveCompactions(args.tinfo, args.credentials); |
| } catch (org.apache.accumulo.core.clientImpl.thrift.ThriftSecurityException sec) { |
| result.sec = sec; |
| } |
| return result; |
| } |
| } |
| |
| public static class cancel<I extends Iface> extends org.apache.thrift.ProcessFunction<I, cancel_args> { |
| public cancel() { |
| super("cancel"); |
| } |
| |
| @Override |
| public cancel_args getEmptyArgsInstance() { |
| return new cancel_args(); |
| } |
| |
| @Override |
| protected boolean isOneway() { |
| return false; |
| } |
| |
| @Override |
| protected boolean rethrowUnhandledExceptions() { |
| return false; |
| } |
| |
| @Override |
| public cancel_result getResult(I iface, cancel_args args) throws org.apache.thrift.TException { |
| cancel_result result = new cancel_result(); |
| iface.cancel(args.tinfo, args.credentials, args.externalCompactionId); |
| return result; |
| } |
| } |
| |
| } |
| |
| public static class AsyncProcessor<I extends AsyncIface> extends org.apache.thrift.TBaseAsyncProcessor<I> { |
| private static final org.slf4j.Logger _LOGGER = org.slf4j.LoggerFactory.getLogger(AsyncProcessor.class.getName()); |
| public AsyncProcessor(I iface) { |
| super(iface, getProcessMap(new java.util.HashMap<java.lang.String, org.apache.thrift.AsyncProcessFunction<I, ? extends org.apache.thrift.TBase, ?>>())); |
| } |
| |
| protected AsyncProcessor(I iface, java.util.Map<java.lang.String, org.apache.thrift.AsyncProcessFunction<I, ? extends org.apache.thrift.TBase, ?>> processMap) { |
| super(iface, getProcessMap(processMap)); |
| } |
| |
| private static <I extends AsyncIface> java.util.Map<java.lang.String, org.apache.thrift.AsyncProcessFunction<I, ? extends org.apache.thrift.TBase,?>> getProcessMap(java.util.Map<java.lang.String, org.apache.thrift.AsyncProcessFunction<I, ? extends org.apache.thrift.TBase, ?>> processMap) { |
| processMap.put("getRunningCompaction", new getRunningCompaction()); |
| processMap.put("getRunningCompactionId", new getRunningCompactionId()); |
| processMap.put("getActiveCompactions", new getActiveCompactions()); |
| processMap.put("cancel", new cancel()); |
| return processMap; |
| } |
| |
| public static class getRunningCompaction<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getRunningCompaction_args, org.apache.accumulo.core.tabletserver.thrift.TExternalCompactionJob> { |
| public getRunningCompaction() { |
| super("getRunningCompaction"); |
| } |
| |
| @Override |
| public getRunningCompaction_args getEmptyArgsInstance() { |
| return new getRunningCompaction_args(); |
| } |
| |
| @Override |
| public org.apache.thrift.async.AsyncMethodCallback<org.apache.accumulo.core.tabletserver.thrift.TExternalCompactionJob> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) { |
| final org.apache.thrift.AsyncProcessFunction fcall = this; |
| return new org.apache.thrift.async.AsyncMethodCallback<org.apache.accumulo.core.tabletserver.thrift.TExternalCompactionJob>() { |
| @Override |
| public void onComplete(org.apache.accumulo.core.tabletserver.thrift.TExternalCompactionJob o) { |
| getRunningCompaction_result result = new getRunningCompaction_result(); |
| result.success = o; |
| try { |
| fcall.sendResponse(fb, result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); |
| } catch (org.apache.thrift.transport.TTransportException e) { |
| _LOGGER.error("TTransportException writing to internal frame buffer", e); |
| fb.close(); |
| } catch (java.lang.Exception e) { |
| _LOGGER.error("Exception writing to internal frame buffer", e); |
| onError(e); |
| } |
| } |
| @Override |
| public void onError(java.lang.Exception e) { |
| byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; |
| org.apache.thrift.TSerializable msg; |
| getRunningCompaction_result result = new getRunningCompaction_result(); |
| if (e instanceof org.apache.accumulo.core.clientImpl.thrift.ThriftSecurityException) { |
| result.sec = (org.apache.accumulo.core.clientImpl.thrift.ThriftSecurityException) e; |
| result.setSecIsSet(true); |
| msg = result; |
| } else if (e instanceof org.apache.thrift.transport.TTransportException) { |
| _LOGGER.error("TTransportException inside handler", e); |
| fb.close(); |
| return; |
| } else if (e instanceof org.apache.thrift.TApplicationException) { |
| _LOGGER.error("TApplicationException inside handler", e); |
| msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; |
| msg = (org.apache.thrift.TApplicationException)e; |
| } else { |
| _LOGGER.error("Exception inside handler", e); |
| msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; |
| msg = new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage()); |
| } |
| try { |
| fcall.sendResponse(fb,msg,msgType,seqid); |
| } catch (java.lang.Exception ex) { |
| _LOGGER.error("Exception writing to internal frame buffer", ex); |
| fb.close(); |
| } |
| } |
| }; |
| } |
| |
| @Override |
| protected boolean isOneway() { |
| return false; |
| } |
| |
| @Override |
| public void start(I iface, getRunningCompaction_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.accumulo.core.tabletserver.thrift.TExternalCompactionJob> resultHandler) throws org.apache.thrift.TException { |
| iface.getRunningCompaction(args.tinfo, args.credentials,resultHandler); |
| } |
| } |
| |
| public static class getRunningCompactionId<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getRunningCompactionId_args, java.lang.String> { |
| public getRunningCompactionId() { |
| super("getRunningCompactionId"); |
| } |
| |
| @Override |
| public getRunningCompactionId_args getEmptyArgsInstance() { |
| return new getRunningCompactionId_args(); |
| } |
| |
| @Override |
| public org.apache.thrift.async.AsyncMethodCallback<java.lang.String> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) { |
| final org.apache.thrift.AsyncProcessFunction fcall = this; |
| return new org.apache.thrift.async.AsyncMethodCallback<java.lang.String>() { |
| @Override |
| public void onComplete(java.lang.String o) { |
| getRunningCompactionId_result result = new getRunningCompactionId_result(); |
| result.success = o; |
| try { |
| fcall.sendResponse(fb, result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); |
| } catch (org.apache.thrift.transport.TTransportException e) { |
| _LOGGER.error("TTransportException writing to internal frame buffer", e); |
| fb.close(); |
| } catch (java.lang.Exception e) { |
| _LOGGER.error("Exception writing to internal frame buffer", e); |
| onError(e); |
| } |
| } |
| @Override |
| public void onError(java.lang.Exception e) { |
| byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; |
| org.apache.thrift.TSerializable msg; |
| getRunningCompactionId_result result = new getRunningCompactionId_result(); |
| if (e instanceof org.apache.accumulo.core.clientImpl.thrift.ThriftSecurityException) { |
| result.sec = (org.apache.accumulo.core.clientImpl.thrift.ThriftSecurityException) e; |
| result.setSecIsSet(true); |
| msg = result; |
| } else if (e instanceof org.apache.thrift.transport.TTransportException) { |
| _LOGGER.error("TTransportException inside handler", e); |
| fb.close(); |
| return; |
| } else if (e instanceof org.apache.thrift.TApplicationException) { |
| _LOGGER.error("TApplicationException inside handler", e); |
| msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; |
| msg = (org.apache.thrift.TApplicationException)e; |
| } else { |
| _LOGGER.error("Exception inside handler", e); |
| msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; |
| msg = new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage()); |
| } |
| try { |
| fcall.sendResponse(fb,msg,msgType,seqid); |
| } catch (java.lang.Exception ex) { |
| _LOGGER.error("Exception writing to internal frame buffer", ex); |
| fb.close(); |
| } |
| } |
| }; |
| } |
| |
| @Override |
| protected boolean isOneway() { |
| return false; |
| } |
| |
| @Override |
| public void start(I iface, getRunningCompactionId_args args, org.apache.thrift.async.AsyncMethodCallback<java.lang.String> resultHandler) throws org.apache.thrift.TException { |
| iface.getRunningCompactionId(args.tinfo, args.credentials,resultHandler); |
| } |
| } |
| |
| public static class getActiveCompactions<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getActiveCompactions_args, java.util.List<org.apache.accumulo.core.tabletserver.thrift.ActiveCompaction>> { |
| public getActiveCompactions() { |
| super("getActiveCompactions"); |
| } |
| |
| @Override |
| public getActiveCompactions_args getEmptyArgsInstance() { |
| return new getActiveCompactions_args(); |
| } |
| |
| @Override |
| public org.apache.thrift.async.AsyncMethodCallback<java.util.List<org.apache.accumulo.core.tabletserver.thrift.ActiveCompaction>> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) { |
| final org.apache.thrift.AsyncProcessFunction fcall = this; |
| return new org.apache.thrift.async.AsyncMethodCallback<java.util.List<org.apache.accumulo.core.tabletserver.thrift.ActiveCompaction>>() { |
| @Override |
| public void onComplete(java.util.List<org.apache.accumulo.core.tabletserver.thrift.ActiveCompaction> o) { |
| getActiveCompactions_result result = new getActiveCompactions_result(); |
| result.success = o; |
| try { |
| fcall.sendResponse(fb, result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); |
| } catch (org.apache.thrift.transport.TTransportException e) { |
| _LOGGER.error("TTransportException writing to internal frame buffer", e); |
| fb.close(); |
| } catch (java.lang.Exception e) { |
| _LOGGER.error("Exception writing to internal frame buffer", e); |
| onError(e); |
| } |
| } |
| @Override |
| public void onError(java.lang.Exception e) { |
| byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; |
| org.apache.thrift.TSerializable msg; |
| getActiveCompactions_result result = new getActiveCompactions_result(); |
| if (e instanceof org.apache.accumulo.core.clientImpl.thrift.ThriftSecurityException) { |
| result.sec = (org.apache.accumulo.core.clientImpl.thrift.ThriftSecurityException) e; |
| result.setSecIsSet(true); |
| msg = result; |
| } else if (e instanceof org.apache.thrift.transport.TTransportException) { |
| _LOGGER.error("TTransportException inside handler", e); |
| fb.close(); |
| return; |
| } else if (e instanceof org.apache.thrift.TApplicationException) { |
| _LOGGER.error("TApplicationException inside handler", e); |
| msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; |
| msg = (org.apache.thrift.TApplicationException)e; |
| } else { |
| _LOGGER.error("Exception inside handler", e); |
| msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; |
| msg = new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage()); |
| } |
| try { |
| fcall.sendResponse(fb,msg,msgType,seqid); |
| } catch (java.lang.Exception ex) { |
| _LOGGER.error("Exception writing to internal frame buffer", ex); |
| fb.close(); |
| } |
| } |
| }; |
| } |
| |
| @Override |
| protected boolean isOneway() { |
| return false; |
| } |
| |
| @Override |
| public void start(I iface, getActiveCompactions_args args, org.apache.thrift.async.AsyncMethodCallback<java.util.List<org.apache.accumulo.core.tabletserver.thrift.ActiveCompaction>> resultHandler) throws org.apache.thrift.TException { |
| iface.getActiveCompactions(args.tinfo, args.credentials,resultHandler); |
| } |
| } |
| |
| public static class cancel<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, cancel_args, Void> { |
| public cancel() { |
| super("cancel"); |
| } |
| |
| @Override |
| public cancel_args getEmptyArgsInstance() { |
| return new cancel_args(); |
| } |
| |
| @Override |
| public org.apache.thrift.async.AsyncMethodCallback<Void> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) { |
| final org.apache.thrift.AsyncProcessFunction fcall = this; |
| return new org.apache.thrift.async.AsyncMethodCallback<Void>() { |
| @Override |
| public void onComplete(Void o) { |
| cancel_result result = new cancel_result(); |
| try { |
| fcall.sendResponse(fb, result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); |
| } catch (org.apache.thrift.transport.TTransportException e) { |
| _LOGGER.error("TTransportException writing to internal frame buffer", e); |
| fb.close(); |
| } catch (java.lang.Exception e) { |
| _LOGGER.error("Exception writing to internal frame buffer", e); |
| onError(e); |
| } |
| } |
| @Override |
| public void onError(java.lang.Exception e) { |
| byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; |
| org.apache.thrift.TSerializable msg; |
| cancel_result result = new cancel_result(); |
| if (e instanceof org.apache.thrift.transport.TTransportException) { |
| _LOGGER.error("TTransportException inside handler", e); |
| fb.close(); |
| return; |
| } else if (e instanceof org.apache.thrift.TApplicationException) { |
| _LOGGER.error("TApplicationException inside handler", e); |
| msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; |
| msg = (org.apache.thrift.TApplicationException)e; |
| } else { |
| _LOGGER.error("Exception inside handler", e); |
| msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; |
| msg = new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage()); |
| } |
| try { |
| fcall.sendResponse(fb,msg,msgType,seqid); |
| } catch (java.lang.Exception ex) { |
| _LOGGER.error("Exception writing to internal frame buffer", ex); |
| fb.close(); |
| } |
| } |
| }; |
| } |
| |
| @Override |
| protected boolean isOneway() { |
| return false; |
| } |
| |
| @Override |
| public void start(I iface, cancel_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.thrift.TException { |
| iface.cancel(args.tinfo, args.credentials, args.externalCompactionId,resultHandler); |
| } |
| } |
| |
| } |
| |
| @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"}) |
| public static class getRunningCompaction_args implements org.apache.thrift.TBase<getRunningCompaction_args, getRunningCompaction_args._Fields>, java.io.Serializable, Cloneable, Comparable<getRunningCompaction_args> { |
| private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("getRunningCompaction_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.scheme.SchemeFactory STANDARD_SCHEME_FACTORY = new getRunningCompaction_argsStandardSchemeFactory(); |
| private static final org.apache.thrift.scheme.SchemeFactory TUPLE_SCHEME_FACTORY = new getRunningCompaction_argsTupleSchemeFactory(); |
| |
| public @org.apache.thrift.annotation.Nullable org.apache.accumulo.core.trace.thrift.TInfo tinfo; // required |
| public @org.apache.thrift.annotation.Nullable org.apache.accumulo.core.securityImpl.thrift.TCredentials credentials; // 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"); |
| |
| private static final java.util.Map<java.lang.String, _Fields> byName = new java.util.HashMap<java.lang.String, _Fields>(); |
| |
| static { |
| for (_Fields field : java.util.EnumSet.allOf(_Fields.class)) { |
| byName.put(field.getFieldName(), field); |
| } |
| } |
| |
| /** |
| * Find the _Fields constant that matches fieldId, or null if its not found. |
| */ |
| @org.apache.thrift.annotation.Nullable |
| public static _Fields findByThriftId(int fieldId) { |
| switch(fieldId) { |
| case 1: // TINFO |
| return TINFO; |
| case 2: // CREDENTIALS |
| return CREDENTIALS; |
| 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 java.lang.IllegalArgumentException("Field " + fieldId + " doesn't exist!"); |
| return fields; |
| } |
| |
| /** |
| * Find the _Fields constant that matches name, or null if its not found. |
| */ |
| @org.apache.thrift.annotation.Nullable |
| public static _Fields findByName(java.lang.String name) { |
| return byName.get(name); |
| } |
| |
| private final short _thriftId; |
| private final java.lang.String _fieldName; |
| |
| _Fields(short thriftId, java.lang.String fieldName) { |
| _thriftId = thriftId; |
| _fieldName = fieldName; |
| } |
| |
| @Override |
| public short getThriftFieldId() { |
| return _thriftId; |
| } |
| |
| @Override |
| public java.lang.String getFieldName() { |
| return _fieldName; |
| } |
| } |
| |
| // isset id assignments |
| public static final java.util.Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap; |
| static { |
| java.util.Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new java.util.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.core.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.securityImpl.thrift.TCredentials.class))); |
| metaDataMap = java.util.Collections.unmodifiableMap(tmpMap); |
| org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(getRunningCompaction_args.class, metaDataMap); |
| } |
| |
| public getRunningCompaction_args() { |
| } |
| |
| public getRunningCompaction_args( |
| org.apache.accumulo.core.trace.thrift.TInfo tinfo, |
| org.apache.accumulo.core.securityImpl.thrift.TCredentials credentials) |
| { |
| this(); |
| this.tinfo = tinfo; |
| this.credentials = credentials; |
| } |
| |
| /** |
| * Performs a deep copy on <i>other</i>. |
| */ |
| public getRunningCompaction_args(getRunningCompaction_args other) { |
| if (other.isSetTinfo()) { |
| this.tinfo = new org.apache.accumulo.core.trace.thrift.TInfo(other.tinfo); |
| } |
| if (other.isSetCredentials()) { |
| this.credentials = new org.apache.accumulo.core.securityImpl.thrift.TCredentials(other.credentials); |
| } |
| } |
| |
| @Override |
| public getRunningCompaction_args deepCopy() { |
| return new getRunningCompaction_args(this); |
| } |
| |
| @Override |
| public void clear() { |
| this.tinfo = null; |
| this.credentials = null; |
| } |
| |
| @org.apache.thrift.annotation.Nullable |
| public org.apache.accumulo.core.trace.thrift.TInfo getTinfo() { |
| return this.tinfo; |
| } |
| |
| public getRunningCompaction_args setTinfo(@org.apache.thrift.annotation.Nullable org.apache.accumulo.core.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; |
| } |
| } |
| |
| @org.apache.thrift.annotation.Nullable |
| public org.apache.accumulo.core.securityImpl.thrift.TCredentials getCredentials() { |
| return this.credentials; |
| } |
| |
| public getRunningCompaction_args setCredentials(@org.apache.thrift.annotation.Nullable org.apache.accumulo.core.securityImpl.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; |
| } |
| } |
| |
| @Override |
| public void setFieldValue(_Fields field, @org.apache.thrift.annotation.Nullable java.lang.Object value) { |
| switch (field) { |
| case TINFO: |
| if (value == null) { |
| unsetTinfo(); |
| } else { |
| setTinfo((org.apache.accumulo.core.trace.thrift.TInfo)value); |
| } |
| break; |
| |
| case CREDENTIALS: |
| if (value == null) { |
| unsetCredentials(); |
| } else { |
| setCredentials((org.apache.accumulo.core.securityImpl.thrift.TCredentials)value); |
| } |
| break; |
| |
| } |
| } |
| |
| @org.apache.thrift.annotation.Nullable |
| @Override |
| public java.lang.Object getFieldValue(_Fields field) { |
| switch (field) { |
| case TINFO: |
| return getTinfo(); |
| |
| case CREDENTIALS: |
| return getCredentials(); |
| |
| } |
| throw new java.lang.IllegalStateException(); |
| } |
| |
| /** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */ |
| @Override |
| public boolean isSet(_Fields field) { |
| if (field == null) { |
| throw new java.lang.IllegalArgumentException(); |
| } |
| |
| switch (field) { |
| case TINFO: |
| return isSetTinfo(); |
| case CREDENTIALS: |
| return isSetCredentials(); |
| } |
| throw new java.lang.IllegalStateException(); |
| } |
| |
| @Override |
| public boolean equals(java.lang.Object that) { |
| if (that instanceof getRunningCompaction_args) |
| return this.equals((getRunningCompaction_args)that); |
| return false; |
| } |
| |
| public boolean equals(getRunningCompaction_args that) { |
| if (that == null) |
| return false; |
| if (this == that) |
| return true; |
| |
| 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; |
| } |
| |
| return true; |
| } |
| |
| @Override |
| public int hashCode() { |
| int hashCode = 1; |
| |
| hashCode = hashCode * 8191 + ((isSetTinfo()) ? 131071 : 524287); |
| if (isSetTinfo()) |
| hashCode = hashCode * 8191 + tinfo.hashCode(); |
| |
| hashCode = hashCode * 8191 + ((isSetCredentials()) ? 131071 : 524287); |
| if (isSetCredentials()) |
| hashCode = hashCode * 8191 + credentials.hashCode(); |
| |
| return hashCode; |
| } |
| |
| @Override |
| public int compareTo(getRunningCompaction_args other) { |
| if (!getClass().equals(other.getClass())) { |
| return getClass().getName().compareTo(other.getClass().getName()); |
| } |
| |
| int lastComparison = 0; |
| |
| lastComparison = java.lang.Boolean.compare(isSetTinfo(), other.isSetTinfo()); |
| if (lastComparison != 0) { |
| return lastComparison; |
| } |
| if (isSetTinfo()) { |
| lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.tinfo, other.tinfo); |
| if (lastComparison != 0) { |
| return lastComparison; |
| } |
| } |
| lastComparison = java.lang.Boolean.compare(isSetCredentials(), other.isSetCredentials()); |
| if (lastComparison != 0) { |
| return lastComparison; |
| } |
| if (isSetCredentials()) { |
| lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.credentials, other.credentials); |
| if (lastComparison != 0) { |
| return lastComparison; |
| } |
| } |
| return 0; |
| } |
| |
| @org.apache.thrift.annotation.Nullable |
| @Override |
| public _Fields fieldForId(int fieldId) { |
| return _Fields.findByThriftId(fieldId); |
| } |
| |
| @Override |
| public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException { |
| scheme(iprot).read(iprot, this); |
| } |
| |
| @Override |
| public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException { |
| scheme(oprot).write(oprot, this); |
| } |
| |
| @Override |
| public java.lang.String toString() { |
| java.lang.StringBuilder sb = new java.lang.StringBuilder("getRunningCompaction_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; |
| 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, java.lang.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 getRunningCompaction_argsStandardSchemeFactory implements org.apache.thrift.scheme.SchemeFactory { |
| @Override |
| public getRunningCompaction_argsStandardScheme getScheme() { |
| return new getRunningCompaction_argsStandardScheme(); |
| } |
| } |
| |
| private static class getRunningCompaction_argsStandardScheme extends org.apache.thrift.scheme.StandardScheme<getRunningCompaction_args> { |
| |
| @Override |
| public void read(org.apache.thrift.protocol.TProtocol iprot, getRunningCompaction_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.core.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.securityImpl.thrift.TCredentials(); |
| struct.credentials.read(iprot); |
| struct.setCredentialsIsSet(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(); |
| } |
| |
| @Override |
| public void write(org.apache.thrift.protocol.TProtocol oprot, getRunningCompaction_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(); |
| } |
| oprot.writeFieldStop(); |
| oprot.writeStructEnd(); |
| } |
| |
| } |
| |
| private static class getRunningCompaction_argsTupleSchemeFactory implements org.apache.thrift.scheme.SchemeFactory { |
| @Override |
| public getRunningCompaction_argsTupleScheme getScheme() { |
| return new getRunningCompaction_argsTupleScheme(); |
| } |
| } |
| |
| private static class getRunningCompaction_argsTupleScheme extends org.apache.thrift.scheme.TupleScheme<getRunningCompaction_args> { |
| |
| @Override |
| public void write(org.apache.thrift.protocol.TProtocol prot, getRunningCompaction_args struct) throws org.apache.thrift.TException { |
| org.apache.thrift.protocol.TTupleProtocol oprot = (org.apache.thrift.protocol.TTupleProtocol) prot; |
| java.util.BitSet optionals = new java.util.BitSet(); |
| if (struct.isSetTinfo()) { |
| optionals.set(0); |
| } |
| if (struct.isSetCredentials()) { |
| optionals.set(1); |
| } |
| oprot.writeBitSet(optionals, 2); |
| if (struct.isSetTinfo()) { |
| struct.tinfo.write(oprot); |
| } |
| if (struct.isSetCredentials()) { |
| struct.credentials.write(oprot); |
| } |
| } |
| |
| @Override |
| public void read(org.apache.thrift.protocol.TProtocol prot, getRunningCompaction_args struct) throws org.apache.thrift.TException { |
| org.apache.thrift.protocol.TTupleProtocol iprot = (org.apache.thrift.protocol.TTupleProtocol) prot; |
| java.util.BitSet incoming = iprot.readBitSet(2); |
| if (incoming.get(0)) { |
| struct.tinfo = new org.apache.accumulo.core.trace.thrift.TInfo(); |
| struct.tinfo.read(iprot); |
| struct.setTinfoIsSet(true); |
| } |
| if (incoming.get(1)) { |
| struct.credentials = new org.apache.accumulo.core.securityImpl.thrift.TCredentials(); |
| struct.credentials.read(iprot); |
| struct.setCredentialsIsSet(true); |
| } |
| } |
| } |
| |
| private static <S extends org.apache.thrift.scheme.IScheme> S scheme(org.apache.thrift.protocol.TProtocol proto) { |
| return (org.apache.thrift.scheme.StandardScheme.class.equals(proto.getScheme()) ? STANDARD_SCHEME_FACTORY : TUPLE_SCHEME_FACTORY).getScheme(); |
| } |
| } |
| |
| @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"}) |
| public static class getRunningCompaction_result implements org.apache.thrift.TBase<getRunningCompaction_result, getRunningCompaction_result._Fields>, java.io.Serializable, Cloneable, Comparable<getRunningCompaction_result> { |
| private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("getRunningCompaction_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 org.apache.thrift.scheme.SchemeFactory STANDARD_SCHEME_FACTORY = new getRunningCompaction_resultStandardSchemeFactory(); |
| private static final org.apache.thrift.scheme.SchemeFactory TUPLE_SCHEME_FACTORY = new getRunningCompaction_resultTupleSchemeFactory(); |
| |
| public @org.apache.thrift.annotation.Nullable org.apache.accumulo.core.tabletserver.thrift.TExternalCompactionJob success; // required |
| public @org.apache.thrift.annotation.Nullable org.apache.accumulo.core.clientImpl.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 java.util.Map<java.lang.String, _Fields> byName = new java.util.HashMap<java.lang.String, _Fields>(); |
| |
| static { |
| for (_Fields field : java.util.EnumSet.allOf(_Fields.class)) { |
| byName.put(field.getFieldName(), field); |
| } |
| } |
| |
| /** |
| * Find the _Fields constant that matches fieldId, or null if its not found. |
| */ |
| @org.apache.thrift.annotation.Nullable |
| 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 java.lang.IllegalArgumentException("Field " + fieldId + " doesn't exist!"); |
| return fields; |
| } |
| |
| /** |
| * Find the _Fields constant that matches name, or null if its not found. |
| */ |
| @org.apache.thrift.annotation.Nullable |
| public static _Fields findByName(java.lang.String name) { |
| return byName.get(name); |
| } |
| |
| private final short _thriftId; |
| private final java.lang.String _fieldName; |
| |
| _Fields(short thriftId, java.lang.String fieldName) { |
| _thriftId = thriftId; |
| _fieldName = fieldName; |
| } |
| |
| @Override |
| public short getThriftFieldId() { |
| return _thriftId; |
| } |
| |
| @Override |
| public java.lang.String getFieldName() { |
| return _fieldName; |
| } |
| } |
| |
| // isset id assignments |
| public static final java.util.Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap; |
| static { |
| java.util.Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new java.util.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.tabletserver.thrift.TExternalCompactionJob.class))); |
| tmpMap.put(_Fields.SEC, new org.apache.thrift.meta_data.FieldMetaData("sec", org.apache.thrift.TFieldRequirementType.DEFAULT, |
| new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, org.apache.accumulo.core.clientImpl.thrift.ThriftSecurityException.class))); |
| metaDataMap = java.util.Collections.unmodifiableMap(tmpMap); |
| org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(getRunningCompaction_result.class, metaDataMap); |
| } |
| |
| public getRunningCompaction_result() { |
| } |
| |
| public getRunningCompaction_result( |
| org.apache.accumulo.core.tabletserver.thrift.TExternalCompactionJob success, |
| org.apache.accumulo.core.clientImpl.thrift.ThriftSecurityException sec) |
| { |
| this(); |
| this.success = success; |
| this.sec = sec; |
| } |
| |
| /** |
| * Performs a deep copy on <i>other</i>. |
| */ |
| public getRunningCompaction_result(getRunningCompaction_result other) { |
| if (other.isSetSuccess()) { |
| this.success = new org.apache.accumulo.core.tabletserver.thrift.TExternalCompactionJob(other.success); |
| } |
| if (other.isSetSec()) { |
| this.sec = new org.apache.accumulo.core.clientImpl.thrift.ThriftSecurityException(other.sec); |
| } |
| } |
| |
| @Override |
| public getRunningCompaction_result deepCopy() { |
| return new getRunningCompaction_result(this); |
| } |
| |
| @Override |
| public void clear() { |
| this.success = null; |
| this.sec = null; |
| } |
| |
| @org.apache.thrift.annotation.Nullable |
| public org.apache.accumulo.core.tabletserver.thrift.TExternalCompactionJob getSuccess() { |
| return this.success; |
| } |
| |
| public getRunningCompaction_result setSuccess(@org.apache.thrift.annotation.Nullable org.apache.accumulo.core.tabletserver.thrift.TExternalCompactionJob 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; |
| } |
| } |
| |
| @org.apache.thrift.annotation.Nullable |
| public org.apache.accumulo.core.clientImpl.thrift.ThriftSecurityException getSec() { |
| return this.sec; |
| } |
| |
| public getRunningCompaction_result setSec(@org.apache.thrift.annotation.Nullable org.apache.accumulo.core.clientImpl.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; |
| } |
| } |
| |
| @Override |
| public void setFieldValue(_Fields field, @org.apache.thrift.annotation.Nullable java.lang.Object value) { |
| switch (field) { |
| case SUCCESS: |
| if (value == null) { |
| unsetSuccess(); |
| } else { |
| setSuccess((org.apache.accumulo.core.tabletserver.thrift.TExternalCompactionJob)value); |
| } |
| break; |
| |
| case SEC: |
| if (value == null) { |
| unsetSec(); |
| } else { |
| setSec((org.apache.accumulo.core.clientImpl.thrift.ThriftSecurityException)value); |
| } |
| break; |
| |
| } |
| } |
| |
| @org.apache.thrift.annotation.Nullable |
| @Override |
| public java.lang.Object getFieldValue(_Fields field) { |
| switch (field) { |
| case SUCCESS: |
| return getSuccess(); |
| |
| case SEC: |
| return getSec(); |
| |
| } |
| throw new java.lang.IllegalStateException(); |
| } |
| |
| /** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */ |
| @Override |
| public boolean isSet(_Fields field) { |
| if (field == null) { |
| throw new java.lang.IllegalArgumentException(); |
| } |
| |
| switch (field) { |
| case SUCCESS: |
| return isSetSuccess(); |
| case SEC: |
| return isSetSec(); |
| } |
| throw new java.lang.IllegalStateException(); |
| } |
| |
| @Override |
| public boolean equals(java.lang.Object that) { |
| if (that instanceof getRunningCompaction_result) |
| return this.equals((getRunningCompaction_result)that); |
| return false; |
| } |
| |
| public boolean equals(getRunningCompaction_result that) { |
| if (that == null) |
| return false; |
| if (this == that) |
| return true; |
| |
| 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() { |
| int hashCode = 1; |
| |
| hashCode = hashCode * 8191 + ((isSetSuccess()) ? 131071 : 524287); |
| if (isSetSuccess()) |
| hashCode = hashCode * 8191 + success.hashCode(); |
| |
| hashCode = hashCode * 8191 + ((isSetSec()) ? 131071 : 524287); |
| if (isSetSec()) |
| hashCode = hashCode * 8191 + sec.hashCode(); |
| |
| return hashCode; |
| } |
| |
| @Override |
| public int compareTo(getRunningCompaction_result other) { |
| if (!getClass().equals(other.getClass())) { |
| return getClass().getName().compareTo(other.getClass().getName()); |
| } |
| |
| int lastComparison = 0; |
| |
| lastComparison = java.lang.Boolean.compare(isSetSuccess(), other.isSetSuccess()); |
| if (lastComparison != 0) { |
| return lastComparison; |
| } |
| if (isSetSuccess()) { |
| lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.success, other.success); |
| if (lastComparison != 0) { |
| return lastComparison; |
| } |
| } |
| lastComparison = java.lang.Boolean.compare(isSetSec(), other.isSetSec()); |
| if (lastComparison != 0) { |
| return lastComparison; |
| } |
| if (isSetSec()) { |
| lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.sec, other.sec); |
| if (lastComparison != 0) { |
| return lastComparison; |
| } |
| } |
| return 0; |
| } |
| |
| @org.apache.thrift.annotation.Nullable |
| @Override |
| public _Fields fieldForId(int fieldId) { |
| return _Fields.findByThriftId(fieldId); |
| } |
| |
| @Override |
| public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException { |
| scheme(iprot).read(iprot, this); |
| } |
| |
| public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException { |
| scheme(oprot).write(oprot, this); |
| } |
| |
| @Override |
| public java.lang.String toString() { |
| java.lang.StringBuilder sb = new java.lang.StringBuilder("getRunningCompaction_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, java.lang.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 getRunningCompaction_resultStandardSchemeFactory implements org.apache.thrift.scheme.SchemeFactory { |
| @Override |
| public getRunningCompaction_resultStandardScheme getScheme() { |
| return new getRunningCompaction_resultStandardScheme(); |
| } |
| } |
| |
| private static class getRunningCompaction_resultStandardScheme extends org.apache.thrift.scheme.StandardScheme<getRunningCompaction_result> { |
| |
| @Override |
| public void read(org.apache.thrift.protocol.TProtocol iprot, getRunningCompaction_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.tabletserver.thrift.TExternalCompactionJob(); |
| 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.clientImpl.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(); |
| } |
| |
| @Override |
| public void write(org.apache.thrift.protocol.TProtocol oprot, getRunningCompaction_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 getRunningCompaction_resultTupleSchemeFactory implements org.apache.thrift.scheme.SchemeFactory { |
| @Override |
| public getRunningCompaction_resultTupleScheme getScheme() { |
| return new getRunningCompaction_resultTupleScheme(); |
| } |
| } |
| |
| private static class getRunningCompaction_resultTupleScheme extends org.apache.thrift.scheme.TupleScheme<getRunningCompaction_result> { |
| |
| @Override |
| public void write(org.apache.thrift.protocol.TProtocol prot, getRunningCompaction_result struct) throws org.apache.thrift.TException { |
| org.apache.thrift.protocol.TTupleProtocol oprot = (org.apache.thrift.protocol.TTupleProtocol) prot; |
| java.util.BitSet optionals = new java.util.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, getRunningCompaction_result struct) throws org.apache.thrift.TException { |
| org.apache.thrift.protocol.TTupleProtocol iprot = (org.apache.thrift.protocol.TTupleProtocol) prot; |
| java.util.BitSet incoming = iprot.readBitSet(2); |
| if (incoming.get(0)) { |
| struct.success = new org.apache.accumulo.core.tabletserver.thrift.TExternalCompactionJob(); |
| struct.success.read(iprot); |
| struct.setSuccessIsSet(true); |
| } |
| if (incoming.get(1)) { |
| struct.sec = new org.apache.accumulo.core.clientImpl.thrift.ThriftSecurityException(); |
| struct.sec.read(iprot); |
| struct.setSecIsSet(true); |
| } |
| } |
| } |
| |
| private static <S extends org.apache.thrift.scheme.IScheme> S scheme(org.apache.thrift.protocol.TProtocol proto) { |
| return (org.apache.thrift.scheme.StandardScheme.class.equals(proto.getScheme()) ? STANDARD_SCHEME_FACTORY : TUPLE_SCHEME_FACTORY).getScheme(); |
| } |
| } |
| |
| @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"}) |
| public static class getRunningCompactionId_args implements org.apache.thrift.TBase<getRunningCompactionId_args, getRunningCompactionId_args._Fields>, java.io.Serializable, Cloneable, Comparable<getRunningCompactionId_args> { |
| private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("getRunningCompactionId_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.scheme.SchemeFactory STANDARD_SCHEME_FACTORY = new getRunningCompactionId_argsStandardSchemeFactory(); |
| private static final org.apache.thrift.scheme.SchemeFactory TUPLE_SCHEME_FACTORY = new getRunningCompactionId_argsTupleSchemeFactory(); |
| |
| public @org.apache.thrift.annotation.Nullable org.apache.accumulo.core.trace.thrift.TInfo tinfo; // required |
| public @org.apache.thrift.annotation.Nullable org.apache.accumulo.core.securityImpl.thrift.TCredentials credentials; // 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"); |
| |
| private static final java.util.Map<java.lang.String, _Fields> byName = new java.util.HashMap<java.lang.String, _Fields>(); |
| |
| static { |
| for (_Fields field : java.util.EnumSet.allOf(_Fields.class)) { |
| byName.put(field.getFieldName(), field); |
| } |
| } |
| |
| /** |
| * Find the _Fields constant that matches fieldId, or null if its not found. |
| */ |
| @org.apache.thrift.annotation.Nullable |
| public static _Fields findByThriftId(int fieldId) { |
| switch(fieldId) { |
| case 1: // TINFO |
| return TINFO; |
| case 2: // CREDENTIALS |
| return CREDENTIALS; |
| 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 java.lang.IllegalArgumentException("Field " + fieldId + " doesn't exist!"); |
| return fields; |
| } |
| |
| /** |
| * Find the _Fields constant that matches name, or null if its not found. |
| */ |
| @org.apache.thrift.annotation.Nullable |
| public static _Fields findByName(java.lang.String name) { |
| return byName.get(name); |
| } |
| |
| private final short _thriftId; |
| private final java.lang.String _fieldName; |
| |
| _Fields(short thriftId, java.lang.String fieldName) { |
| _thriftId = thriftId; |
| _fieldName = fieldName; |
| } |
| |
| @Override |
| public short getThriftFieldId() { |
| return _thriftId; |
| } |
| |
| @Override |
| public java.lang.String getFieldName() { |
| return _fieldName; |
| } |
| } |
| |
| // isset id assignments |
| public static final java.util.Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap; |
| static { |
| java.util.Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new java.util.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.core.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.securityImpl.thrift.TCredentials.class))); |
| metaDataMap = java.util.Collections.unmodifiableMap(tmpMap); |
| org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(getRunningCompactionId_args.class, metaDataMap); |
| } |
| |
| public getRunningCompactionId_args() { |
| } |
| |
| public getRunningCompactionId_args( |
| org.apache.accumulo.core.trace.thrift.TInfo tinfo, |
| org.apache.accumulo.core.securityImpl.thrift.TCredentials credentials) |
| { |
| this(); |
| this.tinfo = tinfo; |
| this.credentials = credentials; |
| } |
| |
| /** |
| * Performs a deep copy on <i>other</i>. |
| */ |
| public getRunningCompactionId_args(getRunningCompactionId_args other) { |
| if (other.isSetTinfo()) { |
| this.tinfo = new org.apache.accumulo.core.trace.thrift.TInfo(other.tinfo); |
| } |
| if (other.isSetCredentials()) { |
| this.credentials = new org.apache.accumulo.core.securityImpl.thrift.TCredentials(other.credentials); |
| } |
| } |
| |
| @Override |
| public getRunningCompactionId_args deepCopy() { |
| return new getRunningCompactionId_args(this); |
| } |
| |
| @Override |
| public void clear() { |
| this.tinfo = null; |
| this.credentials = null; |
| } |
| |
| @org.apache.thrift.annotation.Nullable |
| public org.apache.accumulo.core.trace.thrift.TInfo getTinfo() { |
| return this.tinfo; |
| } |
| |
| public getRunningCompactionId_args setTinfo(@org.apache.thrift.annotation.Nullable org.apache.accumulo.core.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; |
| } |
| } |
| |
| @org.apache.thrift.annotation.Nullable |
| public org.apache.accumulo.core.securityImpl.thrift.TCredentials getCredentials() { |
| return this.credentials; |
| } |
| |
| public getRunningCompactionId_args setCredentials(@org.apache.thrift.annotation.Nullable org.apache.accumulo.core.securityImpl.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; |
| } |
| } |
| |
| @Override |
| public void setFieldValue(_Fields field, @org.apache.thrift.annotation.Nullable java.lang.Object value) { |
| switch (field) { |
| case TINFO: |
| if (value == null) { |
| unsetTinfo(); |
| } else { |
| setTinfo((org.apache.accumulo.core.trace.thrift.TInfo)value); |
| } |
| break; |
| |
| case CREDENTIALS: |
| if (value == null) { |
| unsetCredentials(); |
| } else { |
| setCredentials((org.apache.accumulo.core.securityImpl.thrift.TCredentials)value); |
| } |
| break; |
| |
| } |
| } |
| |
| @org.apache.thrift.annotation.Nullable |
| @Override |
| public java.lang.Object getFieldValue(_Fields field) { |
| switch (field) { |
| case TINFO: |
| return getTinfo(); |
| |
| case CREDENTIALS: |
| return getCredentials(); |
| |
| } |
| throw new java.lang.IllegalStateException(); |
| } |
| |
| /** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */ |
| @Override |
| public boolean isSet(_Fields field) { |
| if (field == null) { |
| throw new java.lang.IllegalArgumentException(); |
| } |
| |
| switch (field) { |
| case TINFO: |
| return isSetTinfo(); |
| case CREDENTIALS: |
| return isSetCredentials(); |
| } |
| throw new java.lang.IllegalStateException(); |
| } |
| |
| @Override |
| public boolean equals(java.lang.Object that) { |
| if (that instanceof getRunningCompactionId_args) |
| return this.equals((getRunningCompactionId_args)that); |
| return false; |
| } |
| |
| public boolean equals(getRunningCompactionId_args that) { |
| if (that == null) |
| return false; |
| if (this == that) |
| return true; |
| |
| 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; |
| } |
| |
| return true; |
| } |
| |
| @Override |
| public int hashCode() { |
| int hashCode = 1; |
| |
| hashCode = hashCode * 8191 + ((isSetTinfo()) ? 131071 : 524287); |
| if (isSetTinfo()) |
| hashCode = hashCode * 8191 + tinfo.hashCode(); |
| |
| hashCode = hashCode * 8191 + ((isSetCredentials()) ? 131071 : 524287); |
| if (isSetCredentials()) |
| hashCode = hashCode * 8191 + credentials.hashCode(); |
| |
| return hashCode; |
| } |
| |
| @Override |
| public int compareTo(getRunningCompactionId_args other) { |
| if (!getClass().equals(other.getClass())) { |
| return getClass().getName().compareTo(other.getClass().getName()); |
| } |
| |
| int lastComparison = 0; |
| |
| lastComparison = java.lang.Boolean.compare(isSetTinfo(), other.isSetTinfo()); |
| if (lastComparison != 0) { |
| return lastComparison; |
| } |
| if (isSetTinfo()) { |
| lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.tinfo, other.tinfo); |
| if (lastComparison != 0) { |
| return lastComparison; |
| } |
| } |
| lastComparison = java.lang.Boolean.compare(isSetCredentials(), other.isSetCredentials()); |
| if (lastComparison != 0) { |
| return lastComparison; |
| } |
| if (isSetCredentials()) { |
| lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.credentials, other.credentials); |
| if (lastComparison != 0) { |
| return lastComparison; |
| } |
| } |
| return 0; |
| } |
| |
| @org.apache.thrift.annotation.Nullable |
| @Override |
| public _Fields fieldForId(int fieldId) { |
| return _Fields.findByThriftId(fieldId); |
| } |
| |
| @Override |
| public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException { |
| scheme(iprot).read(iprot, this); |
| } |
| |
| @Override |
| public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException { |
| scheme(oprot).write(oprot, this); |
| } |
| |
| @Override |
| public java.lang.String toString() { |
| java.lang.StringBuilder sb = new java.lang.StringBuilder("getRunningCompactionId_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; |
| 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, java.lang.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 getRunningCompactionId_argsStandardSchemeFactory implements org.apache.thrift.scheme.SchemeFactory { |
| @Override |
| public getRunningCompactionId_argsStandardScheme getScheme() { |
| return new getRunningCompactionId_argsStandardScheme(); |
| } |
| } |
| |
| private static class getRunningCompactionId_argsStandardScheme extends org.apache.thrift.scheme.StandardScheme<getRunningCompactionId_args> { |
| |
| @Override |
| public void read(org.apache.thrift.protocol.TProtocol iprot, getRunningCompactionId_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.core.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.securityImpl.thrift.TCredentials(); |
| struct.credentials.read(iprot); |
| struct.setCredentialsIsSet(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(); |
| } |
| |
| @Override |
| public void write(org.apache.thrift.protocol.TProtocol oprot, getRunningCompactionId_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(); |
| } |
| oprot.writeFieldStop(); |
| oprot.writeStructEnd(); |
| } |
| |
| } |
| |
| private static class getRunningCompactionId_argsTupleSchemeFactory implements org.apache.thrift.scheme.SchemeFactory { |
| @Override |
| public getRunningCompactionId_argsTupleScheme getScheme() { |
| return new getRunningCompactionId_argsTupleScheme(); |
| } |
| } |
| |
| private static class getRunningCompactionId_argsTupleScheme extends org.apache.thrift.scheme.TupleScheme<getRunningCompactionId_args> { |
| |
| @Override |
| public void write(org.apache.thrift.protocol.TProtocol prot, getRunningCompactionId_args struct) throws org.apache.thrift.TException { |
| org.apache.thrift.protocol.TTupleProtocol oprot = (org.apache.thrift.protocol.TTupleProtocol) prot; |
| java.util.BitSet optionals = new java.util.BitSet(); |
| if (struct.isSetTinfo()) { |
| optionals.set(0); |
| } |
| if (struct.isSetCredentials()) { |
| optionals.set(1); |
| } |
| oprot.writeBitSet(optionals, 2); |
| if (struct.isSetTinfo()) { |
| struct.tinfo.write(oprot); |
| } |
| if (struct.isSetCredentials()) { |
| struct.credentials.write(oprot); |
| } |
| } |
| |
| @Override |
| public void read(org.apache.thrift.protocol.TProtocol prot, getRunningCompactionId_args struct) throws org.apache.thrift.TException { |
| org.apache.thrift.protocol.TTupleProtocol iprot = (org.apache.thrift.protocol.TTupleProtocol) prot; |
| java.util.BitSet incoming = iprot.readBitSet(2); |
| if (incoming.get(0)) { |
| struct.tinfo = new org.apache.accumulo.core.trace.thrift.TInfo(); |
| struct.tinfo.read(iprot); |
| struct.setTinfoIsSet(true); |
| } |
| if (incoming.get(1)) { |
| struct.credentials = new org.apache.accumulo.core.securityImpl.thrift.TCredentials(); |
| struct.credentials.read(iprot); |
| struct.setCredentialsIsSet(true); |
| } |
| } |
| } |
| |
| private static <S extends org.apache.thrift.scheme.IScheme> S scheme(org.apache.thrift.protocol.TProtocol proto) { |
| return (org.apache.thrift.scheme.StandardScheme.class.equals(proto.getScheme()) ? STANDARD_SCHEME_FACTORY : TUPLE_SCHEME_FACTORY).getScheme(); |
| } |
| } |
| |
| @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"}) |
| public static class getRunningCompactionId_result implements org.apache.thrift.TBase<getRunningCompactionId_result, getRunningCompactionId_result._Fields>, java.io.Serializable, Cloneable, Comparable<getRunningCompactionId_result> { |
| private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("getRunningCompactionId_result"); |
| |
| private static final org.apache.thrift.protocol.TField SUCCESS_FIELD_DESC = new org.apache.thrift.protocol.TField("success", org.apache.thrift.protocol.TType.STRING, (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 org.apache.thrift.scheme.SchemeFactory STANDARD_SCHEME_FACTORY = new getRunningCompactionId_resultStandardSchemeFactory(); |
| private static final org.apache.thrift.scheme.SchemeFactory TUPLE_SCHEME_FACTORY = new getRunningCompactionId_resultTupleSchemeFactory(); |
| |
| public @org.apache.thrift.annotation.Nullable java.lang.String success; // required |
| public @org.apache.thrift.annotation.Nullable org.apache.accumulo.core.clientImpl.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 java.util.Map<java.lang.String, _Fields> byName = new java.util.HashMap<java.lang.String, _Fields>(); |
| |
| static { |
| for (_Fields field : java.util.EnumSet.allOf(_Fields.class)) { |
| byName.put(field.getFieldName(), field); |
| } |
| } |
| |
| /** |
| * Find the _Fields constant that matches fieldId, or null if its not found. |
| */ |
| @org.apache.thrift.annotation.Nullable |
| 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 java.lang.IllegalArgumentException("Field " + fieldId + " doesn't exist!"); |
| return fields; |
| } |
| |
| /** |
| * Find the _Fields constant that matches name, or null if its not found. |
| */ |
| @org.apache.thrift.annotation.Nullable |
| public static _Fields findByName(java.lang.String name) { |
| return byName.get(name); |
| } |
| |
| private final short _thriftId; |
| private final java.lang.String _fieldName; |
| |
| _Fields(short thriftId, java.lang.String fieldName) { |
| _thriftId = thriftId; |
| _fieldName = fieldName; |
| } |
| |
| @Override |
| public short getThriftFieldId() { |
| return _thriftId; |
| } |
| |
| @Override |
| public java.lang.String getFieldName() { |
| return _fieldName; |
| } |
| } |
| |
| // isset id assignments |
| public static final java.util.Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap; |
| static { |
| java.util.Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new java.util.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.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); |
| tmpMap.put(_Fields.SEC, new org.apache.thrift.meta_data.FieldMetaData("sec", org.apache.thrift.TFieldRequirementType.DEFAULT, |
| new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, org.apache.accumulo.core.clientImpl.thrift.ThriftSecurityException.class))); |
| metaDataMap = java.util.Collections.unmodifiableMap(tmpMap); |
| org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(getRunningCompactionId_result.class, metaDataMap); |
| } |
| |
| public getRunningCompactionId_result() { |
| } |
| |
| public getRunningCompactionId_result( |
| java.lang.String success, |
| org.apache.accumulo.core.clientImpl.thrift.ThriftSecurityException sec) |
| { |
| this(); |
| this.success = success; |
| this.sec = sec; |
| } |
| |
| /** |
| * Performs a deep copy on <i>other</i>. |
| */ |
| public getRunningCompactionId_result(getRunningCompactionId_result other) { |
| if (other.isSetSuccess()) { |
| this.success = other.success; |
| } |
| if (other.isSetSec()) { |
| this.sec = new org.apache.accumulo.core.clientImpl.thrift.ThriftSecurityException(other.sec); |
| } |
| } |
| |
| @Override |
| public getRunningCompactionId_result deepCopy() { |
| return new getRunningCompactionId_result(this); |
| } |
| |
| @Override |
| public void clear() { |
| this.success = null; |
| this.sec = null; |
| } |
| |
| @org.apache.thrift.annotation.Nullable |
| public java.lang.String getSuccess() { |
| return this.success; |
| } |
| |
| public getRunningCompactionId_result setSuccess(@org.apache.thrift.annotation.Nullable java.lang.String 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; |
| } |
| } |
| |
| @org.apache.thrift.annotation.Nullable |
| public org.apache.accumulo.core.clientImpl.thrift.ThriftSecurityException getSec() { |
| return this.sec; |
| } |
| |
| public getRunningCompactionId_result setSec(@org.apache.thrift.annotation.Nullable org.apache.accumulo.core.clientImpl.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; |
| } |
| } |
| |
| @Override |
| public void setFieldValue(_Fields field, @org.apache.thrift.annotation.Nullable java.lang.Object value) { |
| switch (field) { |
| case SUCCESS: |
| if (value == null) { |
| unsetSuccess(); |
| } else { |
| setSuccess((java.lang.String)value); |
| } |
| break; |
| |
| case SEC: |
| if (value == null) { |
| unsetSec(); |
| } else { |
| setSec((org.apache.accumulo.core.clientImpl.thrift.ThriftSecurityException)value); |
| } |
| break; |
| |
| } |
| } |
| |
| @org.apache.thrift.annotation.Nullable |
| @Override |
| public java.lang.Object getFieldValue(_Fields field) { |
| switch (field) { |
| case SUCCESS: |
| return getSuccess(); |
| |
| case SEC: |
| return getSec(); |
| |
| } |
| throw new java.lang.IllegalStateException(); |
| } |
| |
| /** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */ |
| @Override |
| public boolean isSet(_Fields field) { |
| if (field == null) { |
| throw new java.lang.IllegalArgumentException(); |
| } |
| |
| switch (field) { |
| case SUCCESS: |
| return isSetSuccess(); |
| case SEC: |
| return isSetSec(); |
| } |
| throw new java.lang.IllegalStateException(); |
| } |
| |
| @Override |
| public boolean equals(java.lang.Object that) { |
| if (that instanceof getRunningCompactionId_result) |
| return this.equals((getRunningCompactionId_result)that); |
| return false; |
| } |
| |
| public boolean equals(getRunningCompactionId_result that) { |
| if (that == null) |
| return false; |
| if (this == that) |
| return true; |
| |
| 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() { |
| int hashCode = 1; |
| |
| hashCode = hashCode * 8191 + ((isSetSuccess()) ? 131071 : 524287); |
| if (isSetSuccess()) |
| hashCode = hashCode * 8191 + success.hashCode(); |
| |
| hashCode = hashCode * 8191 + ((isSetSec()) ? 131071 : 524287); |
| if (isSetSec()) |
| hashCode = hashCode * 8191 + sec.hashCode(); |
| |
| return hashCode; |
| } |
| |
| @Override |
| public int compareTo(getRunningCompactionId_result other) { |
| if (!getClass().equals(other.getClass())) { |
| return getClass().getName().compareTo(other.getClass().getName()); |
| } |
| |
| int lastComparison = 0; |
| |
| lastComparison = java.lang.Boolean.compare(isSetSuccess(), other.isSetSuccess()); |
| if (lastComparison != 0) { |
| return lastComparison; |
| } |
| if (isSetSuccess()) { |
| lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.success, other.success); |
| if (lastComparison != 0) { |
| return lastComparison; |
| } |
| } |
| lastComparison = java.lang.Boolean.compare(isSetSec(), other.isSetSec()); |
| if (lastComparison != 0) { |
| return lastComparison; |
| } |
| if (isSetSec()) { |
| lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.sec, other.sec); |
| if (lastComparison != 0) { |
| return lastComparison; |
| } |
| } |
| return 0; |
| } |
| |
| @org.apache.thrift.annotation.Nullable |
| @Override |
| public _Fields fieldForId(int fieldId) { |
| return _Fields.findByThriftId(fieldId); |
| } |
| |
| @Override |
| public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException { |
| scheme(iprot).read(iprot, this); |
| } |
| |
| public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException { |
| scheme(oprot).write(oprot, this); |
| } |
| |
| @Override |
| public java.lang.String toString() { |
| java.lang.StringBuilder sb = new java.lang.StringBuilder("getRunningCompactionId_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 |
| } |
| |
| 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, java.lang.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 getRunningCompactionId_resultStandardSchemeFactory implements org.apache.thrift.scheme.SchemeFactory { |
| @Override |
| public getRunningCompactionId_resultStandardScheme getScheme() { |
| return new getRunningCompactionId_resultStandardScheme(); |
| } |
| } |
| |
| private static class getRunningCompactionId_resultStandardScheme extends org.apache.thrift.scheme.StandardScheme<getRunningCompactionId_result> { |
| |
| @Override |
| public void read(org.apache.thrift.protocol.TProtocol iprot, getRunningCompactionId_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.STRING) { |
| struct.success = iprot.readString(); |
| 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.clientImpl.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(); |
| } |
| |
| @Override |
| public void write(org.apache.thrift.protocol.TProtocol oprot, getRunningCompactionId_result struct) throws org.apache.thrift.TException { |
| struct.validate(); |
| |
| oprot.writeStructBegin(STRUCT_DESC); |
| if (struct.success != null) { |
| oprot.writeFieldBegin(SUCCESS_FIELD_DESC); |
| oprot.writeString(struct.success); |
| oprot.writeFieldEnd(); |
| } |
| if (struct.sec != null) { |
| oprot.writeFieldBegin(SEC_FIELD_DESC); |
| struct.sec.write(oprot); |
| oprot.writeFieldEnd(); |
| } |
| oprot.writeFieldStop(); |
| oprot.writeStructEnd(); |
| } |
| |
| } |
| |
| private static class getRunningCompactionId_resultTupleSchemeFactory implements org.apache.thrift.scheme.SchemeFactory { |
| @Override |
| public getRunningCompactionId_resultTupleScheme getScheme() { |
| return new getRunningCompactionId_resultTupleScheme(); |
| } |
| } |
| |
| private static class getRunningCompactionId_resultTupleScheme extends org.apache.thrift.scheme.TupleScheme<getRunningCompactionId_result> { |
| |
| @Override |
| public void write(org.apache.thrift.protocol.TProtocol prot, getRunningCompactionId_result struct) throws org.apache.thrift.TException { |
| org.apache.thrift.protocol.TTupleProtocol oprot = (org.apache.thrift.protocol.TTupleProtocol) prot; |
| java.util.BitSet optionals = new java.util.BitSet(); |
| if (struct.isSetSuccess()) { |
| optionals.set(0); |
| } |
| if (struct.isSetSec()) { |
| optionals.set(1); |
| } |
| oprot.writeBitSet(optionals, 2); |
| if (struct.isSetSuccess()) { |
| oprot.writeString(struct.success); |
| } |
| if (struct.isSetSec()) { |
| struct.sec.write(oprot); |
| } |
| } |
| |
| @Override |
| public void read(org.apache.thrift.protocol.TProtocol prot, getRunningCompactionId_result struct) throws org.apache.thrift.TException { |
| org.apache.thrift.protocol.TTupleProtocol iprot = (org.apache.thrift.protocol.TTupleProtocol) prot; |
| java.util.BitSet incoming = iprot.readBitSet(2); |
| if (incoming.get(0)) { |
| struct.success = iprot.readString(); |
| struct.setSuccessIsSet(true); |
| } |
| if (incoming.get(1)) { |
| struct.sec = new org.apache.accumulo.core.clientImpl.thrift.ThriftSecurityException(); |
| struct.sec.read(iprot); |
| struct.setSecIsSet(true); |
| } |
| } |
| } |
| |
| private static <S extends org.apache.thrift.scheme.IScheme> S scheme(org.apache.thrift.protocol.TProtocol proto) { |
| return (org.apache.thrift.scheme.StandardScheme.class.equals(proto.getScheme()) ? STANDARD_SCHEME_FACTORY : TUPLE_SCHEME_FACTORY).getScheme(); |
| } |
| } |
| |
| @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"}) |
| public static class getActiveCompactions_args implements org.apache.thrift.TBase<getActiveCompactions_args, getActiveCompactions_args._Fields>, java.io.Serializable, Cloneable, Comparable<getActiveCompactions_args> { |
| private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("getActiveCompactions_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)2); |
| 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)1); |
| |
| private static final org.apache.thrift.scheme.SchemeFactory STANDARD_SCHEME_FACTORY = new getActiveCompactions_argsStandardSchemeFactory(); |
| private static final org.apache.thrift.scheme.SchemeFactory TUPLE_SCHEME_FACTORY = new getActiveCompactions_argsTupleSchemeFactory(); |
| |
| public @org.apache.thrift.annotation.Nullable org.apache.accumulo.core.trace.thrift.TInfo tinfo; // required |
| public @org.apache.thrift.annotation.Nullable org.apache.accumulo.core.securityImpl.thrift.TCredentials credentials; // 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)2, "tinfo"), |
| CREDENTIALS((short)1, "credentials"); |
| |
| private static final java.util.Map<java.lang.String, _Fields> byName = new java.util.HashMap<java.lang.String, _Fields>(); |
| |
| static { |
| for (_Fields field : java.util.EnumSet.allOf(_Fields.class)) { |
| byName.put(field.getFieldName(), field); |
| } |
| } |
| |
| /** |
| * Find the _Fields constant that matches fieldId, or null if its not found. |
| */ |
| @org.apache.thrift.annotation.Nullable |
| public static _Fields findByThriftId(int fieldId) { |
| switch(fieldId) { |
| case 2: // TINFO |
| return TINFO; |
| case 1: // CREDENTIALS |
| return CREDENTIALS; |
| 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 java.lang.IllegalArgumentException("Field " + fieldId + " doesn't exist!"); |
| return fields; |
| } |
| |
| /** |
| * Find the _Fields constant that matches name, or null if its not found. |
| */ |
| @org.apache.thrift.annotation.Nullable |
| public static _Fields findByName(java.lang.String name) { |
| return byName.get(name); |
| } |
| |
| private final short _thriftId; |
| private final java.lang.String _fieldName; |
| |
| _Fields(short thriftId, java.lang.String fieldName) { |
| _thriftId = thriftId; |
| _fieldName = fieldName; |
| } |
| |
| @Override |
| public short getThriftFieldId() { |
| return _thriftId; |
| } |
| |
| @Override |
| public java.lang.String getFieldName() { |
| return _fieldName; |
| } |
| } |
| |
| // isset id assignments |
| public static final java.util.Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap; |
| static { |
| java.util.Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new java.util.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.core.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.securityImpl.thrift.TCredentials.class))); |
| metaDataMap = java.util.Collections.unmodifiableMap(tmpMap); |
| org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(getActiveCompactions_args.class, metaDataMap); |
| } |
| |
| public getActiveCompactions_args() { |
| } |
| |
| public getActiveCompactions_args( |
| org.apache.accumulo.core.trace.thrift.TInfo tinfo, |
| org.apache.accumulo.core.securityImpl.thrift.TCredentials credentials) |
| { |
| this(); |
| this.tinfo = tinfo; |
| this.credentials = credentials; |
| } |
| |
| /** |
| * Performs a deep copy on <i>other</i>. |
| */ |
| public getActiveCompactions_args(getActiveCompactions_args other) { |
| if (other.isSetTinfo()) { |
| this.tinfo = new org.apache.accumulo.core.trace.thrift.TInfo(other.tinfo); |
| } |
| if (other.isSetCredentials()) { |
| this.credentials = new org.apache.accumulo.core.securityImpl.thrift.TCredentials(other.credentials); |
| } |
| } |
| |
| @Override |
| public getActiveCompactions_args deepCopy() { |
| return new getActiveCompactions_args(this); |
| } |
| |
| @Override |
| public void clear() { |
| this.tinfo = null; |
| this.credentials = null; |
| } |
| |
| @org.apache.thrift.annotation.Nullable |
| public org.apache.accumulo.core.trace.thrift.TInfo getTinfo() { |
| return this.tinfo; |
| } |
| |
| public getActiveCompactions_args setTinfo(@org.apache.thrift.annotation.Nullable org.apache.accumulo.core.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; |
| } |
| } |
| |
| @org.apache.thrift.annotation.Nullable |
| public org.apache.accumulo.core.securityImpl.thrift.TCredentials getCredentials() { |
| return this.credentials; |
| } |
| |
| public getActiveCompactions_args setCredentials(@org.apache.thrift.annotation.Nullable org.apache.accumulo.core.securityImpl.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; |
| } |
| } |
| |
| @Override |
| public void setFieldValue(_Fields field, @org.apache.thrift.annotation.Nullable java.lang.Object value) { |
| switch (field) { |
| case TINFO: |
| if (value == null) { |
| unsetTinfo(); |
| } else { |
| setTinfo((org.apache.accumulo.core.trace.thrift.TInfo)value); |
| } |
| break; |
| |
| case CREDENTIALS: |
| if (value == null) { |
| unsetCredentials(); |
| } else { |
| setCredentials((org.apache.accumulo.core.securityImpl.thrift.TCredentials)value); |
| } |
| break; |
| |
| } |
| } |
| |
| @org.apache.thrift.annotation.Nullable |
| @Override |
| public java.lang.Object getFieldValue(_Fields field) { |
| switch (field) { |
| case TINFO: |
| return getTinfo(); |
| |
| case CREDENTIALS: |
| return getCredentials(); |
| |
| } |
| throw new java.lang.IllegalStateException(); |
| } |
| |
| /** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */ |
| @Override |
| public boolean isSet(_Fields field) { |
| if (field == null) { |
| throw new java.lang.IllegalArgumentException(); |
| } |
| |
| switch (field) { |
| case TINFO: |
| return isSetTinfo(); |
| case CREDENTIALS: |
| return isSetCredentials(); |
| } |
| throw new java.lang.IllegalStateException(); |
| } |
| |
| @Override |
| public boolean equals(java.lang.Object that) { |
| if (that instanceof getActiveCompactions_args) |
| return this.equals((getActiveCompactions_args)that); |
| return false; |
| } |
| |
| public boolean equals(getActiveCompactions_args that) { |
| if (that == null) |
| return false; |
| if (this == that) |
| return true; |
| |
| 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; |
| } |
| |
| return true; |
| } |
| |
| @Override |
| public int hashCode() { |
| int hashCode = 1; |
| |
| hashCode = hashCode * 8191 + ((isSetTinfo()) ? 131071 : 524287); |
| if (isSetTinfo()) |
| hashCode = hashCode * 8191 + tinfo.hashCode(); |
| |
| hashCode = hashCode * 8191 + ((isSetCredentials()) ? 131071 : 524287); |
| if (isSetCredentials()) |
| hashCode = hashCode * 8191 + credentials.hashCode(); |
| |
| return hashCode; |
| } |
| |
| @Override |
| public int compareTo(getActiveCompactions_args other) { |
| if (!getClass().equals(other.getClass())) { |
| return getClass().getName().compareTo(other.getClass().getName()); |
| } |
| |
| int lastComparison = 0; |
| |
| lastComparison = java.lang.Boolean.compare(isSetTinfo(), other.isSetTinfo()); |
| if (lastComparison != 0) { |
| return lastComparison; |
| } |
| if (isSetTinfo()) { |
| lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.tinfo, other.tinfo); |
| if (lastComparison != 0) { |
| return lastComparison; |
| } |
| } |
| lastComparison = java.lang.Boolean.compare(isSetCredentials(), other.isSetCredentials()); |
| if (lastComparison != 0) { |
| return lastComparison; |
| } |
| if (isSetCredentials()) { |
| lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.credentials, other.credentials); |
| if (lastComparison != 0) { |
| return lastComparison; |
| } |
| } |
| return 0; |
| } |
| |
| @org.apache.thrift.annotation.Nullable |
| @Override |
| public _Fields fieldForId(int fieldId) { |
| return _Fields.findByThriftId(fieldId); |
| } |
| |
| @Override |
| public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException { |
| scheme(iprot).read(iprot, this); |
| } |
| |
| @Override |
| public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException { |
| scheme(oprot).write(oprot, this); |
| } |
| |
| @Override |
| public java.lang.String toString() { |
| java.lang.StringBuilder sb = new java.lang.StringBuilder("getActiveCompactions_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; |
| 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, java.lang.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 getActiveCompactions_argsStandardSchemeFactory implements org.apache.thrift.scheme.SchemeFactory { |
| @Override |
| public getActiveCompactions_argsStandardScheme getScheme() { |
| return new getActiveCompactions_argsStandardScheme(); |
| } |
| } |
| |
| private static class getActiveCompactions_argsStandardScheme extends org.apache.thrift.scheme.StandardScheme<getActiveCompactions_args> { |
| |
| @Override |
| public void read(org.apache.thrift.protocol.TProtocol iprot, getActiveCompactions_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 2: // TINFO |
| if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) { |
| struct.tinfo = new org.apache.accumulo.core.trace.thrift.TInfo(); |
| struct.tinfo.read(iprot); |
| struct.setTinfoIsSet(true); |
| } else { |
| org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); |
| } |
| break; |
| case 1: // CREDENTIALS |
| if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) { |
| struct.credentials = new org.apache.accumulo.core.securityImpl.thrift.TCredentials(); |
| struct.credentials.read(iprot); |
| struct.setCredentialsIsSet(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(); |
| } |
| |
| @Override |
| public void write(org.apache.thrift.protocol.TProtocol oprot, getActiveCompactions_args struct) throws org.apache.thrift.TException { |
| struct.validate(); |
| |
| oprot.writeStructBegin(STRUCT_DESC); |
| if (struct.credentials != null) { |
| oprot.writeFieldBegin(CREDENTIALS_FIELD_DESC); |
| struct.credentials.write(oprot); |
| oprot.writeFieldEnd(); |
| } |
| if (struct.tinfo != null) { |
| oprot.writeFieldBegin(TINFO_FIELD_DESC); |
| struct.tinfo.write(oprot); |
| oprot.writeFieldEnd(); |
| } |
| oprot.writeFieldStop(); |
| oprot.writeStructEnd(); |
| } |
| |
| } |
| |
| private static class getActiveCompactions_argsTupleSchemeFactory implements org.apache.thrift.scheme.SchemeFactory { |
| @Override |
| public getActiveCompactions_argsTupleScheme getScheme() { |
| return new getActiveCompactions_argsTupleScheme(); |
| } |
| } |
| |
| private static class getActiveCompactions_argsTupleScheme extends org.apache.thrift.scheme.TupleScheme<getActiveCompactions_args> { |
| |
| @Override |
| public void write(org.apache.thrift.protocol.TProtocol prot, getActiveCompactions_args struct) throws org.apache.thrift.TException { |
| org.apache.thrift.protocol.TTupleProtocol oprot = (org.apache.thrift.protocol.TTupleProtocol) prot; |
| java.util.BitSet optionals = new java.util.BitSet(); |
| if (struct.isSetTinfo()) { |
| optionals.set(0); |
| } |
| if (struct.isSetCredentials()) { |
| optionals.set(1); |
| } |
| oprot.writeBitSet(optionals, 2); |
| if (struct.isSetTinfo()) { |
| struct.tinfo.write(oprot); |
| } |
| if (struct.isSetCredentials()) { |
| struct.credentials.write(oprot); |
| } |
| } |
| |
| @Override |
| public void read(org.apache.thrift.protocol.TProtocol prot, getActiveCompactions_args struct) throws org.apache.thrift.TException { |
| org.apache.thrift.protocol.TTupleProtocol iprot = (org.apache.thrift.protocol.TTupleProtocol) prot; |
| java.util.BitSet incoming = iprot.readBitSet(2); |
| if (incoming.get(0)) { |
| struct.tinfo = new org.apache.accumulo.core.trace.thrift.TInfo(); |
| struct.tinfo.read(iprot); |
| struct.setTinfoIsSet(true); |
| } |
| if (incoming.get(1)) { |
| struct.credentials = new org.apache.accumulo.core.securityImpl.thrift.TCredentials(); |
| struct.credentials.read(iprot); |
| struct.setCredentialsIsSet(true); |
| } |
| } |
| } |
| |
| private static <S extends org.apache.thrift.scheme.IScheme> S scheme(org.apache.thrift.protocol.TProtocol proto) { |
| return (org.apache.thrift.scheme.StandardScheme.class.equals(proto.getScheme()) ? STANDARD_SCHEME_FACTORY : TUPLE_SCHEME_FACTORY).getScheme(); |
| } |
| } |
| |
| @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"}) |
| public static class getActiveCompactions_result implements org.apache.thrift.TBase<getActiveCompactions_result, getActiveCompactions_result._Fields>, java.io.Serializable, Cloneable, Comparable<getActiveCompactions_result> { |
| private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("getActiveCompactions_result"); |
| |
| private static final org.apache.thrift.protocol.TField SUCCESS_FIELD_DESC = new org.apache.thrift.protocol.TField("success", org.apache.thrift.protocol.TType.LIST, (short)0); |
| private static final org.apache.thrift.protocol.TField SEC_FIELD_DESC = new org.apache.thrift.protocol.TField("sec", org.apache.thrift.protocol.TType.STRUCT, (short)1); |
| |
| private static final org.apache.thrift.scheme.SchemeFactory STANDARD_SCHEME_FACTORY = new getActiveCompactions_resultStandardSchemeFactory(); |
| private static final org.apache.thrift.scheme.SchemeFactory TUPLE_SCHEME_FACTORY = new getActiveCompactions_resultTupleSchemeFactory(); |
| |
| public @org.apache.thrift.annotation.Nullable java.util.List<org.apache.accumulo.core.tabletserver.thrift.ActiveCompaction> success; // required |
| public @org.apache.thrift.annotation.Nullable org.apache.accumulo.core.clientImpl.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 java.util.Map<java.lang.String, _Fields> byName = new java.util.HashMap<java.lang.String, _Fields>(); |
| |
| static { |
| for (_Fields field : java.util.EnumSet.allOf(_Fields.class)) { |
| byName.put(field.getFieldName(), field); |
| } |
| } |
| |
| /** |
| * Find the _Fields constant that matches fieldId, or null if its not found. |
| */ |
| @org.apache.thrift.annotation.Nullable |
| 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 java.lang.IllegalArgumentException("Field " + fieldId + " doesn't exist!"); |
| return fields; |
| } |
| |
| /** |
| * Find the _Fields constant that matches name, or null if its not found. |
| */ |
| @org.apache.thrift.annotation.Nullable |
| public static _Fields findByName(java.lang.String name) { |
| return byName.get(name); |
| } |
| |
| private final short _thriftId; |
| private final java.lang.String _fieldName; |
| |
| _Fields(short thriftId, java.lang.String fieldName) { |
| _thriftId = thriftId; |
| _fieldName = fieldName; |
| } |
| |
| @Override |
| public short getThriftFieldId() { |
| return _thriftId; |
| } |
| |
| @Override |
| public java.lang.String getFieldName() { |
| return _fieldName; |
| } |
| } |
| |
| // isset id assignments |
| public static final java.util.Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap; |
| static { |
| java.util.Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new java.util.EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class); |
| tmpMap.put(_Fields.SUCCESS, new org.apache.thrift.meta_data.FieldMetaData("success", org.apache.thrift.TFieldRequirementType.DEFAULT, |
| new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST, |
| new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, org.apache.accumulo.core.tabletserver.thrift.ActiveCompaction.class)))); |
| tmpMap.put(_Fields.SEC, new org.apache.thrift.meta_data.FieldMetaData("sec", org.apache.thrift.TFieldRequirementType.DEFAULT, |
| new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, org.apache.accumulo.core.clientImpl.thrift.ThriftSecurityException.class))); |
| metaDataMap = java.util.Collections.unmodifiableMap(tmpMap); |
| org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(getActiveCompactions_result.class, metaDataMap); |
| } |
| |
| public getActiveCompactions_result() { |
| } |
| |
| public getActiveCompactions_result( |
| java.util.List<org.apache.accumulo.core.tabletserver.thrift.ActiveCompaction> success, |
| org.apache.accumulo.core.clientImpl.thrift.ThriftSecurityException sec) |
| { |
| this(); |
| this.success = success; |
| this.sec = sec; |
| } |
| |
| /** |
| * Performs a deep copy on <i>other</i>. |
| */ |
| public getActiveCompactions_result(getActiveCompactions_result other) { |
| if (other.isSetSuccess()) { |
| java.util.List<org.apache.accumulo.core.tabletserver.thrift.ActiveCompaction> __this__success = new java.util.ArrayList<org.apache.accumulo.core.tabletserver.thrift.ActiveCompaction>(other.success.size()); |
| for (org.apache.accumulo.core.tabletserver.thrift.ActiveCompaction other_element : other.success) { |
| __this__success.add(new org.apache.accumulo.core.tabletserver.thrift.ActiveCompaction(other_element)); |
| } |
| this.success = __this__success; |
| } |
| if (other.isSetSec()) { |
| this.sec = new org.apache.accumulo.core.clientImpl.thrift.ThriftSecurityException(other.sec); |
| } |
| } |
| |
| @Override |
| public getActiveCompactions_result deepCopy() { |
| return new getActiveCompactions_result(this); |
| } |
| |
| @Override |
| public void clear() { |
| this.success = null; |
| this.sec = null; |
| } |
| |
| public int getSuccessSize() { |
| return (this.success == null) ? 0 : this.success.size(); |
| } |
| |
| @org.apache.thrift.annotation.Nullable |
| public java.util.Iterator<org.apache.accumulo.core.tabletserver.thrift.ActiveCompaction> getSuccessIterator() { |
| return (this.success == null) ? null : this.success.iterator(); |
| } |
| |
| public void addToSuccess(org.apache.accumulo.core.tabletserver.thrift.ActiveCompaction elem) { |
| if (this.success == null) { |
| this.success = new java.util.ArrayList<org.apache.accumulo.core.tabletserver.thrift.ActiveCompaction>(); |
| } |
| this.success.add(elem); |
| } |
| |
| @org.apache.thrift.annotation.Nullable |
| public java.util.List<org.apache.accumulo.core.tabletserver.thrift.ActiveCompaction> getSuccess() { |
| return this.success; |
| } |
| |
| public getActiveCompactions_result setSuccess(@org.apache.thrift.annotation.Nullable java.util.List<org.apache.accumulo.core.tabletserver.thrift.ActiveCompaction> 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; |
| } |
| } |
| |
| @org.apache.thrift.annotation.Nullable |
| public org.apache.accumulo.core.clientImpl.thrift.ThriftSecurityException getSec() { |
| return this.sec; |
| } |
| |
| public getActiveCompactions_result setSec(@org.apache.thrift.annotation.Nullable org.apache.accumulo.core.clientImpl.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; |
| } |
| } |
| |
| @Override |
| public void setFieldValue(_Fields field, @org.apache.thrift.annotation.Nullable java.lang.Object value) { |
| switch (field) { |
| case SUCCESS: |
| if (value == null) { |
| unsetSuccess(); |
| } else { |
| setSuccess((java.util.List<org.apache.accumulo.core.tabletserver.thrift.ActiveCompaction>)value); |
| } |
| break; |
| |
| case SEC: |
| if (value == null) { |
| unsetSec(); |
| } else { |
| setSec((org.apache.accumulo.core.clientImpl.thrift.ThriftSecurityException)value); |
| } |
| break; |
| |
| } |
| } |
| |
| @org.apache.thrift.annotation.Nullable |
| @Override |
| public java.lang.Object getFieldValue(_Fields field) { |
| switch (field) { |
| case SUCCESS: |
| return getSuccess(); |
| |
| case SEC: |
| return getSec(); |
| |
| } |
| throw new java.lang.IllegalStateException(); |
| } |
| |
| /** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */ |
| @Override |
| public boolean isSet(_Fields field) { |
| if (field == null) { |
| throw new java.lang.IllegalArgumentException(); |
| } |
| |
| switch (field) { |
| case SUCCESS: |
| return isSetSuccess(); |
| case SEC: |
| return isSetSec(); |
| } |
| throw new java.lang.IllegalStateException(); |
| } |
| |
| @Override |
| public boolean equals(java.lang.Object that) { |
| if (that instanceof getActiveCompactions_result) |
| return this.equals((getActiveCompactions_result)that); |
| return false; |
| } |
| |
| public boolean equals(getActiveCompactions_result that) { |
| if (that == null) |
| return false; |
| if (this == that) |
| return true; |
| |
| 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() { |
| int hashCode = 1; |
| |
| hashCode = hashCode * 8191 + ((isSetSuccess()) ? 131071 : 524287); |
| if (isSetSuccess()) |
| hashCode = hashCode * 8191 + success.hashCode(); |
| |
| hashCode = hashCode * 8191 + ((isSetSec()) ? 131071 : 524287); |
| if (isSetSec()) |
| hashCode = hashCode * 8191 + sec.hashCode(); |
| |
| return hashCode; |
| } |
| |
| @Override |
| public int compareTo(getActiveCompactions_result other) { |
| if (!getClass().equals(other.getClass())) { |
| return getClass().getName().compareTo(other.getClass().getName()); |
| } |
| |
| int lastComparison = 0; |
| |
| lastComparison = java.lang.Boolean.compare(isSetSuccess(), other.isSetSuccess()); |
| if (lastComparison != 0) { |
| return lastComparison; |
| } |
| if (isSetSuccess()) { |
| lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.success, other.success); |
| if (lastComparison != 0) { |
| return lastComparison; |
| } |
| } |
| lastComparison = java.lang.Boolean.compare(isSetSec(), other.isSetSec()); |
| if (lastComparison != 0) { |
| return lastComparison; |
| } |
| if (isSetSec()) { |
| lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.sec, other.sec); |
| if (lastComparison != 0) { |
| return lastComparison; |
| } |
| } |
| return 0; |
| } |
| |
| @org.apache.thrift.annotation.Nullable |
| @Override |
| public _Fields fieldForId(int fieldId) { |
| return _Fields.findByThriftId(fieldId); |
| } |
| |
| @Override |
| public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException { |
| scheme(iprot).read(iprot, this); |
| } |
| |
| public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException { |
| scheme(oprot).write(oprot, this); |
| } |
| |
| @Override |
| public java.lang.String toString() { |
| java.lang.StringBuilder sb = new java.lang.StringBuilder("getActiveCompactions_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 |
| } |
| |
| 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, java.lang.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 getActiveCompactions_resultStandardSchemeFactory implements org.apache.thrift.scheme.SchemeFactory { |
| @Override |
| public getActiveCompactions_resultStandardScheme getScheme() { |
| return new getActiveCompactions_resultStandardScheme(); |
| } |
| } |
| |
| private static class getActiveCompactions_resultStandardScheme extends org.apache.thrift.scheme.StandardScheme<getActiveCompactions_result> { |
| |
| @Override |
| public void read(org.apache.thrift.protocol.TProtocol iprot, getActiveCompactions_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.LIST) { |
| { |
| org.apache.thrift.protocol.TList _list20 = iprot.readListBegin(); |
| struct.success = new java.util.ArrayList<org.apache.accumulo.core.tabletserver.thrift.ActiveCompaction>(_list20.size); |
| @org.apache.thrift.annotation.Nullable org.apache.accumulo.core.tabletserver.thrift.ActiveCompaction _elem21; |
| for (int _i22 = 0; _i22 < _list20.size; ++_i22) |
| { |
| _elem21 = new org.apache.accumulo.core.tabletserver.thrift.ActiveCompaction(); |
| _elem21.read(iprot); |
| struct.success.add(_elem21); |
| } |
| iprot.readListEnd(); |
| } |
| 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.clientImpl.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(); |
| } |
| |
| @Override |
| public void write(org.apache.thrift.protocol.TProtocol oprot, getActiveCompactions_result struct) throws org.apache.thrift.TException { |
| struct.validate(); |
| |
| oprot.writeStructBegin(STRUCT_DESC); |
| if (struct.success != null) { |
| oprot.writeFieldBegin(SUCCESS_FIELD_DESC); |
| { |
| oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.success.size())); |
| for (org.apache.accumulo.core.tabletserver.thrift.ActiveCompaction _iter23 : struct.success) |
| { |
| _iter23.write(oprot); |
| } |
| oprot.writeListEnd(); |
| } |
| oprot.writeFieldEnd(); |
| } |
| if (struct.sec != null) { |
| oprot.writeFieldBegin(SEC_FIELD_DESC); |
| struct.sec.write(oprot); |
| oprot.writeFieldEnd(); |
| } |
| oprot.writeFieldStop(); |
| oprot.writeStructEnd(); |
| } |
| |
| } |
| |
| private static class getActiveCompactions_resultTupleSchemeFactory implements org.apache.thrift.scheme.SchemeFactory { |
| @Override |
| public getActiveCompactions_resultTupleScheme getScheme() { |
| return new getActiveCompactions_resultTupleScheme(); |
| } |
| } |
| |
| private static class getActiveCompactions_resultTupleScheme extends org.apache.thrift.scheme.TupleScheme<getActiveCompactions_result> { |
| |
| @Override |
| public void write(org.apache.thrift.protocol.TProtocol prot, getActiveCompactions_result struct) throws org.apache.thrift.TException { |
| org.apache.thrift.protocol.TTupleProtocol oprot = (org.apache.thrift.protocol.TTupleProtocol) prot; |
| java.util.BitSet optionals = new java.util.BitSet(); |
| if (struct.isSetSuccess()) { |
| optionals.set(0); |
| } |
| if (struct.isSetSec()) { |
| optionals.set(1); |
| } |
| oprot.writeBitSet(optionals, 2); |
| if (struct.isSetSuccess()) { |
| { |
| oprot.writeI32(struct.success.size()); |
| for (org.apache.accumulo.core.tabletserver.thrift.ActiveCompaction _iter24 : struct.success) |
| { |
| _iter24.write(oprot); |
| } |
| } |
| } |
| if (struct.isSetSec()) { |
| struct.sec.write(oprot); |
| } |
| } |
| |
| @Override |
| public void read(org.apache.thrift.protocol.TProtocol prot, getActiveCompactions_result struct) throws org.apache.thrift.TException { |
| org.apache.thrift.protocol.TTupleProtocol iprot = (org.apache.thrift.protocol.TTupleProtocol) prot; |
| java.util.BitSet incoming = iprot.readBitSet(2); |
| if (incoming.get(0)) { |
| { |
| org.apache.thrift.protocol.TList _list25 = iprot.readListBegin(org.apache.thrift.protocol.TType.STRUCT); |
| struct.success = new java.util.ArrayList<org.apache.accumulo.core.tabletserver.thrift.ActiveCompaction>(_list25.size); |
| @org.apache.thrift.annotation.Nullable org.apache.accumulo.core.tabletserver.thrift.ActiveCompaction _elem26; |
| for (int _i27 = 0; _i27 < _list25.size; ++_i27) |
| { |
| _elem26 = new org.apache.accumulo.core.tabletserver.thrift.ActiveCompaction(); |
| _elem26.read(iprot); |
| struct.success.add(_elem26); |
| } |
| } |
| struct.setSuccessIsSet(true); |
| } |
| if (incoming.get(1)) { |
| struct.sec = new org.apache.accumulo.core.clientImpl.thrift.ThriftSecurityException(); |
| struct.sec.read(iprot); |
| struct.setSecIsSet(true); |
| } |
| } |
| } |
| |
| private static <S extends org.apache.thrift.scheme.IScheme> S scheme(org.apache.thrift.protocol.TProtocol proto) { |
| return (org.apache.thrift.scheme.StandardScheme.class.equals(proto.getScheme()) ? STANDARD_SCHEME_FACTORY : TUPLE_SCHEME_FACTORY).getScheme(); |
| } |
| } |
| |
| @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"}) |
| public static class cancel_args implements org.apache.thrift.TBase<cancel_args, cancel_args._Fields>, java.io.Serializable, Cloneable, Comparable<cancel_args> { |
| private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("cancel_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 EXTERNAL_COMPACTION_ID_FIELD_DESC = new org.apache.thrift.protocol.TField("externalCompactionId", org.apache.thrift.protocol.TType.STRING, (short)3); |
| |
| private static final org.apache.thrift.scheme.SchemeFactory STANDARD_SCHEME_FACTORY = new cancel_argsStandardSchemeFactory(); |
| private static final org.apache.thrift.scheme.SchemeFactory TUPLE_SCHEME_FACTORY = new cancel_argsTupleSchemeFactory(); |
| |
| public @org.apache.thrift.annotation.Nullable org.apache.accumulo.core.trace.thrift.TInfo tinfo; // required |
| public @org.apache.thrift.annotation.Nullable org.apache.accumulo.core.securityImpl.thrift.TCredentials credentials; // required |
| public @org.apache.thrift.annotation.Nullable java.lang.String externalCompactionId; // 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"), |
| EXTERNAL_COMPACTION_ID((short)3, "externalCompactionId"); |
| |
| private static final java.util.Map<java.lang.String, _Fields> byName = new java.util.HashMap<java.lang.String, _Fields>(); |
| |
| static { |
| for (_Fields field : java.util.EnumSet.allOf(_Fields.class)) { |
| byName.put(field.getFieldName(), field); |
| } |
| } |
| |
| /** |
| * Find the _Fields constant that matches fieldId, or null if its not found. |
| */ |
| @org.apache.thrift.annotation.Nullable |
| public static _Fields findByThriftId(int fieldId) { |
| switch(fieldId) { |
| case 1: // TINFO |
| return TINFO; |
| case 2: // CREDENTIALS |
| return CREDENTIALS; |
| case 3: // EXTERNAL_COMPACTION_ID |
| return EXTERNAL_COMPACTION_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 java.lang.IllegalArgumentException("Field " + fieldId + " doesn't exist!"); |
| return fields; |
| } |
| |
| /** |
| * Find the _Fields constant that matches name, or null if its not found. |
| */ |
| @org.apache.thrift.annotation.Nullable |
| public static _Fields findByName(java.lang.String name) { |
| return byName.get(name); |
| } |
| |
| private final short _thriftId; |
| private final java.lang.String _fieldName; |
| |
| _Fields(short thriftId, java.lang.String fieldName) { |
| _thriftId = thriftId; |
| _fieldName = fieldName; |
| } |
| |
| @Override |
| public short getThriftFieldId() { |
| return _thriftId; |
| } |
| |
| @Override |
| public java.lang.String getFieldName() { |
| return _fieldName; |
| } |
| } |
| |
| // isset id assignments |
| public static final java.util.Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap; |
| static { |
| java.util.Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new java.util.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.core.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.securityImpl.thrift.TCredentials.class))); |
| tmpMap.put(_Fields.EXTERNAL_COMPACTION_ID, new org.apache.thrift.meta_data.FieldMetaData("externalCompactionId", org.apache.thrift.TFieldRequirementType.DEFAULT, |
| new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); |
| metaDataMap = java.util.Collections.unmodifiableMap(tmpMap); |
| org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(cancel_args.class, metaDataMap); |
| } |
| |
| public cancel_args() { |
| } |
| |
| public cancel_args( |
| org.apache.accumulo.core.trace.thrift.TInfo tinfo, |
| org.apache.accumulo.core.securityImpl.thrift.TCredentials credentials, |
| java.lang.String externalCompactionId) |
| { |
| this(); |
| this.tinfo = tinfo; |
| this.credentials = credentials; |
| this.externalCompactionId = externalCompactionId; |
| } |
| |
| /** |
| * Performs a deep copy on <i>other</i>. |
| */ |
| public cancel_args(cancel_args other) { |
| if (other.isSetTinfo()) { |
| this.tinfo = new org.apache.accumulo.core.trace.thrift.TInfo(other.tinfo); |
| } |
| if (other.isSetCredentials()) { |
| this.credentials = new org.apache.accumulo.core.securityImpl.thrift.TCredentials(other.credentials); |
| } |
| if (other.isSetExternalCompactionId()) { |
| this.externalCompactionId = other.externalCompactionId; |
| } |
| } |
| |
| @Override |
| public cancel_args deepCopy() { |
| return new cancel_args(this); |
| } |
| |
| @Override |
| public void clear() { |
| this.tinfo = null; |
| this.credentials = null; |
| this.externalCompactionId = null; |
| } |
| |
| @org.apache.thrift.annotation.Nullable |
| public org.apache.accumulo.core.trace.thrift.TInfo getTinfo() { |
| return this.tinfo; |
| } |
| |
| public cancel_args setTinfo(@org.apache.thrift.annotation.Nullable org.apache.accumulo.core.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; |
| } |
| } |
| |
| @org.apache.thrift.annotation.Nullable |
| public org.apache.accumulo.core.securityImpl.thrift.TCredentials getCredentials() { |
| return this.credentials; |
| } |
| |
| public cancel_args setCredentials(@org.apache.thrift.annotation.Nullable org.apache.accumulo.core.securityImpl.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; |
| } |
| } |
| |
| @org.apache.thrift.annotation.Nullable |
| public java.lang.String getExternalCompactionId() { |
| return this.externalCompactionId; |
| } |
| |
| public cancel_args setExternalCompactionId(@org.apache.thrift.annotation.Nullable java.lang.String externalCompactionId) { |
| this.externalCompactionId = externalCompactionId; |
| return this; |
| } |
| |
| public void unsetExternalCompactionId() { |
| this.externalCompactionId = null; |
| } |
| |
| /** Returns true if field externalCompactionId is set (has been assigned a value) and false otherwise */ |
| public boolean isSetExternalCompactionId() { |
| return this.externalCompactionId != null; |
| } |
| |
| public void setExternalCompactionIdIsSet(boolean value) { |
| if (!value) { |
| this.externalCompactionId = null; |
| } |
| } |
| |
| @Override |
| public void setFieldValue(_Fields field, @org.apache.thrift.annotation.Nullable java.lang.Object value) { |
| switch (field) { |
| case TINFO: |
| if (value == null) { |
| unsetTinfo(); |
| } else { |
| setTinfo((org.apache.accumulo.core.trace.thrift.TInfo)value); |
| } |
| break; |
| |
| case CREDENTIALS: |
| if (value == null) { |
| unsetCredentials(); |
| } else { |
| setCredentials((org.apache.accumulo.core.securityImpl.thrift.TCredentials)value); |
| } |
| break; |
| |
| case EXTERNAL_COMPACTION_ID: |
| if (value == null) { |
| unsetExternalCompactionId(); |
| } else { |
| setExternalCompactionId((java.lang.String)value); |
| } |
| break; |
| |
| } |
| } |
| |
| @org.apache.thrift.annotation.Nullable |
| @Override |
| public java.lang.Object getFieldValue(_Fields field) { |
| switch (field) { |
| case TINFO: |
| return getTinfo(); |
| |
| case CREDENTIALS: |
| return getCredentials(); |
| |
| case EXTERNAL_COMPACTION_ID: |
| return getExternalCompactionId(); |
| |
| } |
| throw new java.lang.IllegalStateException(); |
| } |
| |
| /** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */ |
| @Override |
| public boolean isSet(_Fields field) { |
| if (field == null) { |
| throw new java.lang.IllegalArgumentException(); |
| } |
| |
| switch (field) { |
| case TINFO: |
| return isSetTinfo(); |
| case CREDENTIALS: |
| return isSetCredentials(); |
| case EXTERNAL_COMPACTION_ID: |
| return isSetExternalCompactionId(); |
| } |
| throw new java.lang.IllegalStateException(); |
| } |
| |
| @Override |
| public boolean equals(java.lang.Object that) { |
| if (that instanceof cancel_args) |
| return this.equals((cancel_args)that); |
| return false; |
| } |
| |
| public boolean equals(cancel_args that) { |
| if (that == null) |
| return false; |
| if (this == that) |
| return true; |
| |
| 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_externalCompactionId = true && this.isSetExternalCompactionId(); |
| boolean that_present_externalCompactionId = true && that.isSetExternalCompactionId(); |
| if (this_present_externalCompactionId || that_present_externalCompactionId) { |
| if (!(this_present_externalCompactionId && that_present_externalCompactionId)) |
| return false; |
| if (!this.externalCompactionId.equals(that.externalCompactionId)) |
| return false; |
| } |
| |
| return true; |
| } |
| |
| @Override |
| public int hashCode() { |
| int hashCode = 1; |
| |
| hashCode = hashCode * 8191 + ((isSetTinfo()) ? 131071 : 524287); |
| if (isSetTinfo()) |
| hashCode = hashCode * 8191 + tinfo.hashCode(); |
| |
| hashCode = hashCode * 8191 + ((isSetCredentials()) ? 131071 : 524287); |
| if (isSetCredentials()) |
| hashCode = hashCode * 8191 + credentials.hashCode(); |
| |
| hashCode = hashCode * 8191 + ((isSetExternalCompactionId()) ? 131071 : 524287); |
| if (isSetExternalCompactionId()) |
| hashCode = hashCode * 8191 + externalCompactionId.hashCode(); |
| |
| return hashCode; |
| } |
| |
| @Override |
| public int compareTo(cancel_args other) { |
| if (!getClass().equals(other.getClass())) { |
| return getClass().getName().compareTo(other.getClass().getName()); |
| } |
| |
| int lastComparison = 0; |
| |
| lastComparison = java.lang.Boolean.compare(isSetTinfo(), other.isSetTinfo()); |
| if (lastComparison != 0) { |
| return lastComparison; |
| } |
| if (isSetTinfo()) { |
| lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.tinfo, other.tinfo); |
| if (lastComparison != 0) { |
| return lastComparison; |
| } |
| } |
| lastComparison = java.lang.Boolean.compare(isSetCredentials(), other.isSetCredentials()); |
| if (lastComparison != 0) { |
| return lastComparison; |
| } |
| if (isSetCredentials()) { |
| lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.credentials, other.credentials); |
| if (lastComparison != 0) { |
| return lastComparison; |
| } |
| } |
| lastComparison = java.lang.Boolean.compare(isSetExternalCompactionId(), other.isSetExternalCompactionId()); |
| if (lastComparison != 0) { |
| return lastComparison; |
| } |
| if (isSetExternalCompactionId()) { |
| lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.externalCompactionId, other.externalCompactionId); |
| if (lastComparison != 0) { |
| return lastComparison; |
| } |
| } |
| return 0; |
| } |
| |
| @org.apache.thrift.annotation.Nullable |
| @Override |
| public _Fields fieldForId(int fieldId) { |
| return _Fields.findByThriftId(fieldId); |
| } |
| |
| @Override |
| public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException { |
| scheme(iprot).read(iprot, this); |
| } |
| |
| @Override |
| public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException { |
| scheme(oprot).write(oprot, this); |
| } |
| |
| @Override |
| public java.lang.String toString() { |
| java.lang.StringBuilder sb = new java.lang.StringBuilder("cancel_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("externalCompactionId:"); |
| if (this.externalCompactionId == null) { |
| sb.append("null"); |
| } else { |
| sb.append(this.externalCompactionId); |
| } |
| 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, java.lang.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 cancel_argsStandardSchemeFactory implements org.apache.thrift.scheme.SchemeFactory { |
| @Override |
| public cancel_argsStandardScheme getScheme() { |
| return new cancel_argsStandardScheme(); |
| } |
| } |
| |
| private static class cancel_argsStandardScheme extends org.apache.thrift.scheme.StandardScheme<cancel_args> { |
| |
| @Override |
| public void read(org.apache.thrift.protocol.TProtocol iprot, cancel_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.core.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.securityImpl.thrift.TCredentials(); |
| struct.credentials.read(iprot); |
| struct.setCredentialsIsSet(true); |
| } else { |
| org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); |
| } |
| break; |
| case 3: // EXTERNAL_COMPACTION_ID |
| if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { |
| struct.externalCompactionId = iprot.readString(); |
| struct.setExternalCompactionIdIsSet(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(); |
| } |
| |
| @Override |
| public void write(org.apache.thrift.protocol.TProtocol oprot, cancel_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.externalCompactionId != null) { |
| oprot.writeFieldBegin(EXTERNAL_COMPACTION_ID_FIELD_DESC); |
| oprot.writeString(struct.externalCompactionId); |
| oprot.writeFieldEnd(); |
| } |
| oprot.writeFieldStop(); |
| oprot.writeStructEnd(); |
| } |
| |
| } |
| |
| private static class cancel_argsTupleSchemeFactory implements org.apache.thrift.scheme.SchemeFactory { |
| @Override |
| public cancel_argsTupleScheme getScheme() { |
| return new cancel_argsTupleScheme(); |
| } |
| } |
| |
| private static class cancel_argsTupleScheme extends org.apache.thrift.scheme.TupleScheme<cancel_args> { |
| |
| @Override |
| public void write(org.apache.thrift.protocol.TProtocol prot, cancel_args struct) throws org.apache.thrift.TException { |
| org.apache.thrift.protocol.TTupleProtocol oprot = (org.apache.thrift.protocol.TTupleProtocol) prot; |
| java.util.BitSet optionals = new java.util.BitSet(); |
| if (struct.isSetTinfo()) { |
| optionals.set(0); |
| } |
| if (struct.isSetCredentials()) { |
| optionals.set(1); |
| } |
| if (struct.isSetExternalCompactionId()) { |
| optionals.set(2); |
| } |
| oprot.writeBitSet(optionals, 3); |
| if (struct.isSetTinfo()) { |
| struct.tinfo.write(oprot); |
| } |
| if (struct.isSetCredentials()) { |
| struct.credentials.write(oprot); |
| } |
| if (struct.isSetExternalCompactionId()) { |
| oprot.writeString(struct.externalCompactionId); |
| } |
| } |
| |
| @Override |
| public void read(org.apache.thrift.protocol.TProtocol prot, cancel_args struct) throws org.apache.thrift.TException { |
| org.apache.thrift.protocol.TTupleProtocol iprot = (org.apache.thrift.protocol.TTupleProtocol) prot; |
| java.util.BitSet incoming = iprot.readBitSet(3); |
| if (incoming.get(0)) { |
| struct.tinfo = new org.apache.accumulo.core.trace.thrift.TInfo(); |
| struct.tinfo.read(iprot); |
| struct.setTinfoIsSet(true); |
| } |
| if (incoming.get(1)) { |
| struct.credentials = new org.apache.accumulo.core.securityImpl.thrift.TCredentials(); |
| struct.credentials.read(iprot); |
| struct.setCredentialsIsSet(true); |
| } |
| if (incoming.get(2)) { |
| struct.externalCompactionId = iprot.readString(); |
| struct.setExternalCompactionIdIsSet(true); |
| } |
| } |
| } |
| |
| private static <S extends org.apache.thrift.scheme.IScheme> S scheme(org.apache.thrift.protocol.TProtocol proto) { |
| return (org.apache.thrift.scheme.StandardScheme.class.equals(proto.getScheme()) ? STANDARD_SCHEME_FACTORY : TUPLE_SCHEME_FACTORY).getScheme(); |
| } |
| } |
| |
| @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"}) |
| public static class cancel_result implements org.apache.thrift.TBase<cancel_result, cancel_result._Fields>, java.io.Serializable, Cloneable, Comparable<cancel_result> { |
| private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("cancel_result"); |
| |
| |
| private static final org.apache.thrift.scheme.SchemeFactory STANDARD_SCHEME_FACTORY = new cancel_resultStandardSchemeFactory(); |
| private static final org.apache.thrift.scheme.SchemeFactory TUPLE_SCHEME_FACTORY = new cancel_resultTupleSchemeFactory(); |
| |
| |
| /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ |
| public enum _Fields implements org.apache.thrift.TFieldIdEnum { |
| ; |
| |
| private static final java.util.Map<java.lang.String, _Fields> byName = new java.util.HashMap<java.lang.String, _Fields>(); |
| |
| static { |
| for (_Fields field : java.util.EnumSet.allOf(_Fields.class)) { |
| byName.put(field.getFieldName(), field); |
| } |
| } |
| |
| /** |
| * Find the _Fields constant that matches fieldId, or null if its not found. |
| */ |
| @org.apache.thrift.annotation.Nullable |
| public static _Fields findByThriftId(int fieldId) { |
| switch(fieldId) { |
| 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 java.lang.IllegalArgumentException("Field " + fieldId + " doesn't exist!"); |
| return fields; |
| } |
| |
| /** |
| * Find the _Fields constant that matches name, or null if its not found. |
| */ |
| @org.apache.thrift.annotation.Nullable |
| public static _Fields findByName(java.lang.String name) { |
| return byName.get(name); |
| } |
| |
| private final short _thriftId; |
| private final java.lang.String _fieldName; |
| |
| _Fields(short thriftId, java.lang.String fieldName) { |
| _thriftId = thriftId; |
| _fieldName = fieldName; |
| } |
| |
| @Override |
| public short getThriftFieldId() { |
| return _thriftId; |
| } |
| |
| @Override |
| public java.lang.String getFieldName() { |
| return _fieldName; |
| } |
| } |
| public static final java.util.Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap; |
| static { |
| java.util.Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new java.util.EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class); |
| metaDataMap = java.util.Collections.unmodifiableMap(tmpMap); |
| org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(cancel_result.class, metaDataMap); |
| } |
| |
| public cancel_result() { |
| } |
| |
| /** |
| * Performs a deep copy on <i>other</i>. |
| */ |
| public cancel_result(cancel_result other) { |
| } |
| |
| @Override |
| public cancel_result deepCopy() { |
| return new cancel_result(this); |
| } |
| |
| @Override |
| public void clear() { |
| } |
| |
| @Override |
| public void setFieldValue(_Fields field, @org.apache.thrift.annotation.Nullable java.lang.Object value) { |
| switch (field) { |
| } |
| } |
| |
| @org.apache.thrift.annotation.Nullable |
| @Override |
| public java.lang.Object getFieldValue(_Fields field) { |
| switch (field) { |
| } |
| throw new java.lang.IllegalStateException(); |
| } |
| |
| /** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */ |
| @Override |
| public boolean isSet(_Fields field) { |
| if (field == null) { |
| throw new java.lang.IllegalArgumentException(); |
| } |
| |
| switch (field) { |
| } |
| throw new java.lang.IllegalStateException(); |
| } |
| |
| @Override |
| public boolean equals(java.lang.Object that) { |
| if (that instanceof cancel_result) |
| return this.equals((cancel_result)that); |
| return false; |
| } |
| |
| public boolean equals(cancel_result that) { |
| if (that == null) |
| return false; |
| if (this == that) |
| return true; |
| |
| return true; |
| } |
| |
| @Override |
| public int hashCode() { |
| int hashCode = 1; |
| |
| return hashCode; |
| } |
| |
| @Override |
| public int compareTo(cancel_result other) { |
| if (!getClass().equals(other.getClass())) { |
| return getClass().getName().compareTo(other.getClass().getName()); |
| } |
| |
| int lastComparison = 0; |
| |
| return 0; |
| } |
| |
| @org.apache.thrift.annotation.Nullable |
| @Override |
| public _Fields fieldForId(int fieldId) { |
| return _Fields.findByThriftId(fieldId); |
| } |
| |
| @Override |
| public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException { |
| scheme(iprot).read(iprot, this); |
| } |
| |
| public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException { |
| scheme(oprot).write(oprot, this); |
| } |
| |
| @Override |
| public java.lang.String toString() { |
| java.lang.StringBuilder sb = new java.lang.StringBuilder("cancel_result("); |
| boolean first = true; |
| |
| sb.append(")"); |
| return sb.toString(); |
| } |
| |
| public void validate() throws org.apache.thrift.TException { |
| // check for required fields |
| // check for sub-struct validity |
| } |
| |
| 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, java.lang.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 cancel_resultStandardSchemeFactory implements org.apache.thrift.scheme.SchemeFactory { |
| @Override |
| public cancel_resultStandardScheme getScheme() { |
| return new cancel_resultStandardScheme(); |
| } |
| } |
| |
| private static class cancel_resultStandardScheme extends org.apache.thrift.scheme.StandardScheme<cancel_result> { |
| |
| @Override |
| public void read(org.apache.thrift.protocol.TProtocol iprot, cancel_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) { |
| 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(); |
| } |
| |
| @Override |
| public void write(org.apache.thrift.protocol.TProtocol oprot, cancel_result struct) throws org.apache.thrift.TException { |
| struct.validate(); |
| |
| oprot.writeStructBegin(STRUCT_DESC); |
| oprot.writeFieldStop(); |
| oprot.writeStructEnd(); |
| } |
| |
| } |
| |
| private static class cancel_resultTupleSchemeFactory implements org.apache.thrift.scheme.SchemeFactory { |
| @Override |
| public cancel_resultTupleScheme getScheme() { |
| return new cancel_resultTupleScheme(); |
| } |
| } |
| |
| private static class cancel_resultTupleScheme extends org.apache.thrift.scheme.TupleScheme<cancel_result> { |
| |
| @Override |
| public void write(org.apache.thrift.protocol.TProtocol prot, cancel_result struct) throws org.apache.thrift.TException { |
| org.apache.thrift.protocol.TTupleProtocol oprot = (org.apache.thrift.protocol.TTupleProtocol) prot; |
| } |
| |
| @Override |
| public void read(org.apache.thrift.protocol.TProtocol prot, cancel_result struct) throws org.apache.thrift.TException { |
| org.apache.thrift.protocol.TTupleProtocol iprot = (org.apache.thrift.protocol.TTupleProtocol) prot; |
| } |
| } |
| |
| private static <S extends org.apache.thrift.scheme.IScheme> S scheme(org.apache.thrift.protocol.TProtocol proto) { |
| return (org.apache.thrift.scheme.StandardScheme.class.equals(proto.getScheme()) ? STANDARD_SCHEME_FACTORY : TUPLE_SCHEME_FACTORY).getScheme(); |
| } |
| } |
| |
| private static void unusedMethod() {} |
| } |
