ACCUMULO-3444 Remove unused thrift classes. These were early variants that were later consolidated into other classes. The thrift IDL was cleaned up, but the generated classes weren't.
Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/095d641e Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/095d641e Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/095d641e Branch: refs/heads/master Commit: 095d641e5ff7bd40d998d94e40ca1a984c85d2c9 Parents: 06b626e Author: Josh Elser <els...@apache.org> Authored: Mon Dec 22 13:57:38 2014 -0500 Committer: Josh Elser <els...@apache.org> Committed: Mon Dec 22 13:57:38 2014 -0500 ---------------------------------------------------------------------- .../core/replication/thrift/Replication.java | 1917 ------------------ .../thrift/ReplicationFailedException.java | 402 ---- 2 files changed, 2319 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/accumulo/blob/095d641e/core/src/main/java/org/apache/accumulo/core/replication/thrift/Replication.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/accumulo/core/replication/thrift/Replication.java b/core/src/main/java/org/apache/accumulo/core/replication/thrift/Replication.java deleted file mode 100644 index 2390d3c..0000000 --- a/core/src/main/java/org/apache/accumulo/core/replication/thrift/Replication.java +++ /dev/null @@ -1,1917 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -/** - * Autogenerated by Thrift Compiler (0.9.0) - * - * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING - * @generated - */ -package org.apache.accumulo.core.replication.thrift; - -import org.apache.thrift.scheme.IScheme; -import org.apache.thrift.scheme.SchemeFactory; -import org.apache.thrift.scheme.StandardScheme; - -import org.apache.thrift.scheme.TupleScheme; -import org.apache.thrift.protocol.TTupleProtocol; -import org.apache.thrift.protocol.TProtocolException; -import org.apache.thrift.EncodingUtils; -import org.apache.thrift.TException; -import java.util.List; -import java.util.ArrayList; -import java.util.Map; -import java.util.HashMap; -import java.util.EnumMap; -import java.util.Set; -import java.util.HashSet; -import java.util.EnumSet; -import java.util.Collections; -import java.util.BitSet; -import java.nio.ByteBuffer; -import java.util.Arrays; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - -@SuppressWarnings("all") public class Replication { - - public interface Iface { - - public void replicateLog(int remoteTableId, WalEdits data) throws RemoteReplicationException, org.apache.thrift.TException; - - public void replicateKeyValues(int remoteTableId, KeyValues data) throws RemoteReplicationException, org.apache.thrift.TException; - - } - - public interface AsyncIface { - - public void replicateLog(int remoteTableId, WalEdits data, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.replicateLog_call> resultHandler) throws org.apache.thrift.TException; - - public void replicateKeyValues(int remoteTableId, KeyValues data, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.replicateKeyValues_call> 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() {} - public Client getClient(org.apache.thrift.protocol.TProtocol prot) { - return new Client(prot); - } - 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); - } - - public void replicateLog(int remoteTableId, WalEdits data) throws RemoteReplicationException, org.apache.thrift.TException - { - send_replicateLog(remoteTableId, data); - recv_replicateLog(); - } - - public void send_replicateLog(int remoteTableId, WalEdits data) throws org.apache.thrift.TException - { - replicateLog_args args = new replicateLog_args(); - args.setRemoteTableId(remoteTableId); - args.setData(data); - sendBase("replicateLog", args); - } - - public void recv_replicateLog() throws RemoteReplicationException, org.apache.thrift.TException - { - replicateLog_result result = new replicateLog_result(); - receiveBase(result, "replicateLog"); - if (result.e != null) { - throw result.e; - } - return; - } - - public void replicateKeyValues(int remoteTableId, KeyValues data) throws RemoteReplicationException, org.apache.thrift.TException - { - send_replicateKeyValues(remoteTableId, data); - recv_replicateKeyValues(); - } - - public void send_replicateKeyValues(int remoteTableId, KeyValues data) throws org.apache.thrift.TException - { - replicateKeyValues_args args = new replicateKeyValues_args(); - args.setRemoteTableId(remoteTableId); - args.setData(data); - sendBase("replicateKeyValues", args); - } - - public void recv_replicateKeyValues() throws RemoteReplicationException, org.apache.thrift.TException - { - replicateKeyValues_result result = new replicateKeyValues_result(); - receiveBase(result, "replicateKeyValues"); - if (result.e != null) { - throw result.e; - } - 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; - } - 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); - } - - public void replicateLog(int remoteTableId, WalEdits data, org.apache.thrift.async.AsyncMethodCallback<replicateLog_call> resultHandler) throws org.apache.thrift.TException { - checkReady(); - replicateLog_call method_call = new replicateLog_call(remoteTableId, data, resultHandler, this, ___protocolFactory, ___transport); - this.___currentMethod = method_call; - ___manager.call(method_call); - } - - public static class replicateLog_call extends org.apache.thrift.async.TAsyncMethodCall { - private int remoteTableId; - private WalEdits data; - public replicateLog_call(int remoteTableId, WalEdits data, org.apache.thrift.async.AsyncMethodCallback<replicateLog_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { - super(client, protocolFactory, transport, resultHandler, false); - this.remoteTableId = remoteTableId; - this.data = data; - } - - public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { - prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("replicateLog", org.apache.thrift.protocol.TMessageType.CALL, 0)); - replicateLog_args args = new replicateLog_args(); - args.setRemoteTableId(remoteTableId); - args.setData(data); - args.write(prot); - prot.writeMessageEnd(); - } - - public void getResult() throws RemoteReplicationException, org.apache.thrift.TException { - if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { - throw new IllegalStateException("Method call not finished!"); - } - org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); - org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport); - (new Client(prot)).recv_replicateLog(); - } - } - - public void replicateKeyValues(int remoteTableId, KeyValues data, org.apache.thrift.async.AsyncMethodCallback<replicateKeyValues_call> resultHandler) throws org.apache.thrift.TException { - checkReady(); - replicateKeyValues_call method_call = new replicateKeyValues_call(remoteTableId, data, resultHandler, this, ___protocolFactory, ___transport); - this.___currentMethod = method_call; - ___manager.call(method_call); - } - - public static class replicateKeyValues_call extends org.apache.thrift.async.TAsyncMethodCall { - private int remoteTableId; - private KeyValues data; - public replicateKeyValues_call(int remoteTableId, KeyValues data, org.apache.thrift.async.AsyncMethodCallback<replicateKeyValues_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { - super(client, protocolFactory, transport, resultHandler, false); - this.remoteTableId = remoteTableId; - this.data = data; - } - - public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { - prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("replicateKeyValues", org.apache.thrift.protocol.TMessageType.CALL, 0)); - replicateKeyValues_args args = new replicateKeyValues_args(); - args.setRemoteTableId(remoteTableId); - args.setData(data); - args.write(prot); - prot.writeMessageEnd(); - } - - public void getResult() throws RemoteReplicationException, org.apache.thrift.TException { - if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { - throw new IllegalStateException("Method call not finished!"); - } - org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); - org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport); - (new Client(prot)).recv_replicateKeyValues(); - } - } - - } - - public static class Processor<I extends Iface> extends org.apache.thrift.TBaseProcessor<I> implements org.apache.thrift.TProcessor { - private static final Logger LOGGER = LoggerFactory.getLogger(Processor.class.getName()); - public Processor(I iface) { - super(iface, getProcessMap(new HashMap<String, org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>>())); - } - - protected Processor(I iface, Map<String, org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>> processMap) { - super(iface, getProcessMap(processMap)); - } - - private static <I extends Iface> Map<String, org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>> getProcessMap(Map<String, org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>> processMap) { - processMap.put("replicateLog", new replicateLog()); - processMap.put("replicateKeyValues", new replicateKeyValues()); - return processMap; - } - - public static class replicateLog<I extends Iface> extends org.apache.thrift.ProcessFunction<I, replicateLog_args> { - public replicateLog() { - super("replicateLog"); - } - - public replicateLog_args getEmptyArgsInstance() { - return new replicateLog_args(); - } - - protected boolean isOneway() { - return false; - } - - public replicateLog_result getResult(I iface, replicateLog_args args) throws org.apache.thrift.TException { - replicateLog_result result = new replicateLog_result(); - try { - iface.replicateLog(args.remoteTableId, args.data); - } catch (RemoteReplicationException e) { - result.e = e; - } - return result; - } - } - - public static class replicateKeyValues<I extends Iface> extends org.apache.thrift.ProcessFunction<I, replicateKeyValues_args> { - public replicateKeyValues() { - super("replicateKeyValues"); - } - - public replicateKeyValues_args getEmptyArgsInstance() { - return new replicateKeyValues_args(); - } - - protected boolean isOneway() { - return false; - } - - public replicateKeyValues_result getResult(I iface, replicateKeyValues_args args) throws org.apache.thrift.TException { - replicateKeyValues_result result = new replicateKeyValues_result(); - try { - iface.replicateKeyValues(args.remoteTableId, args.data); - } catch (RemoteReplicationException e) { - result.e = e; - } - return result; - } - } - - } - - public static class replicateLog_args implements org.apache.thrift.TBase<replicateLog_args, replicateLog_args._Fields>, java.io.Serializable, Cloneable { - private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("replicateLog_args"); - - private static final org.apache.thrift.protocol.TField REMOTE_TABLE_ID_FIELD_DESC = new org.apache.thrift.protocol.TField("remoteTableId", org.apache.thrift.protocol.TType.I32, (short)1); - private static final org.apache.thrift.protocol.TField DATA_FIELD_DESC = new org.apache.thrift.protocol.TField("data", org.apache.thrift.protocol.TType.STRUCT, (short)2); - - private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); - static { - schemes.put(StandardScheme.class, new replicateLog_argsStandardSchemeFactory()); - schemes.put(TupleScheme.class, new replicateLog_argsTupleSchemeFactory()); - } - - public int remoteTableId; // required - public WalEdits data; // required - - /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ - @SuppressWarnings("all") public enum _Fields implements org.apache.thrift.TFieldIdEnum { - REMOTE_TABLE_ID((short)1, "remoteTableId"), - DATA((short)2, "data"); - - private static final Map<String, _Fields> byName = new HashMap<String, _Fields>(); - - static { - for (_Fields field : EnumSet.allOf(_Fields.class)) { - byName.put(field.getFieldName(), field); - } - } - - /** - * Find the _Fields constant that matches fieldId, or null if its not found. - */ - public static _Fields findByThriftId(int fieldId) { - switch(fieldId) { - case 1: // REMOTE_TABLE_ID - return REMOTE_TABLE_ID; - case 2: // DATA - return DATA; - default: - return null; - } - } - - /** - * Find the _Fields constant that matches fieldId, throwing an exception - * if it is not found. - */ - public static _Fields findByThriftIdOrThrow(int fieldId) { - _Fields fields = findByThriftId(fieldId); - if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!"); - return fields; - } - - /** - * Find the _Fields constant that matches name, or null if its not found. - */ - public static _Fields findByName(String name) { - return byName.get(name); - } - - private final short _thriftId; - private final String _fieldName; - - _Fields(short thriftId, String fieldName) { - _thriftId = thriftId; - _fieldName = fieldName; - } - - public short getThriftFieldId() { - return _thriftId; - } - - public String getFieldName() { - return _fieldName; - } - } - - // isset id assignments - private static final int __REMOTETABLEID_ISSET_ID = 0; - private byte __isset_bitfield = 0; - public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap; - static { - Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class); - tmpMap.put(_Fields.REMOTE_TABLE_ID, new org.apache.thrift.meta_data.FieldMetaData("remoteTableId", org.apache.thrift.TFieldRequirementType.DEFAULT, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32))); - tmpMap.put(_Fields.DATA, new org.apache.thrift.meta_data.FieldMetaData("data", org.apache.thrift.TFieldRequirementType.DEFAULT, - new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, WalEdits.class))); - metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(replicateLog_args.class, metaDataMap); - } - - public replicateLog_args() { - } - - public replicateLog_args( - int remoteTableId, - WalEdits data) - { - this(); - this.remoteTableId = remoteTableId; - setRemoteTableIdIsSet(true); - this.data = data; - } - - /** - * Performs a deep copy on <i>other</i>. - */ - public replicateLog_args(replicateLog_args other) { - __isset_bitfield = other.__isset_bitfield; - this.remoteTableId = other.remoteTableId; - if (other.isSetData()) { - this.data = new WalEdits(other.data); - } - } - - public replicateLog_args deepCopy() { - return new replicateLog_args(this); - } - - @Override - public void clear() { - setRemoteTableIdIsSet(false); - this.remoteTableId = 0; - this.data = null; - } - - public int getRemoteTableId() { - return this.remoteTableId; - } - - public replicateLog_args setRemoteTableId(int remoteTableId) { - this.remoteTableId = remoteTableId; - setRemoteTableIdIsSet(true); - return this; - } - - public void unsetRemoteTableId() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __REMOTETABLEID_ISSET_ID); - } - - /** Returns true if field remoteTableId is set (has been assigned a value) and false otherwise */ - public boolean isSetRemoteTableId() { - return EncodingUtils.testBit(__isset_bitfield, __REMOTETABLEID_ISSET_ID); - } - - public void setRemoteTableIdIsSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __REMOTETABLEID_ISSET_ID, value); - } - - public WalEdits getData() { - return this.data; - } - - public replicateLog_args setData(WalEdits data) { - this.data = data; - return this; - } - - public void unsetData() { - this.data = null; - } - - /** Returns true if field data is set (has been assigned a value) and false otherwise */ - public boolean isSetData() { - return this.data != null; - } - - public void setDataIsSet(boolean value) { - if (!value) { - this.data = null; - } - } - - public void setFieldValue(_Fields field, Object value) { - switch (field) { - case REMOTE_TABLE_ID: - if (value == null) { - unsetRemoteTableId(); - } else { - setRemoteTableId((Integer)value); - } - break; - - case DATA: - if (value == null) { - unsetData(); - } else { - setData((WalEdits)value); - } - break; - - } - } - - public Object getFieldValue(_Fields field) { - switch (field) { - case REMOTE_TABLE_ID: - return Integer.valueOf(getRemoteTableId()); - - case DATA: - return getData(); - - } - throw new IllegalStateException(); - } - - /** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */ - public boolean isSet(_Fields field) { - if (field == null) { - throw new IllegalArgumentException(); - } - - switch (field) { - case REMOTE_TABLE_ID: - return isSetRemoteTableId(); - case DATA: - return isSetData(); - } - throw new IllegalStateException(); - } - - @Override - public boolean equals(Object that) { - if (that == null) - return false; - if (that instanceof replicateLog_args) - return this.equals((replicateLog_args)that); - return false; - } - - public boolean equals(replicateLog_args that) { - if (that == null) - return false; - - boolean this_present_remoteTableId = true; - boolean that_present_remoteTableId = true; - if (this_present_remoteTableId || that_present_remoteTableId) { - if (!(this_present_remoteTableId && that_present_remoteTableId)) - return false; - if (this.remoteTableId != that.remoteTableId) - return false; - } - - boolean this_present_data = true && this.isSetData(); - boolean that_present_data = true && that.isSetData(); - if (this_present_data || that_present_data) { - if (!(this_present_data && that_present_data)) - return false; - if (!this.data.equals(that.data)) - return false; - } - - return true; - } - - @Override - public int hashCode() { - return 0; - } - - public int compareTo(replicateLog_args other) { - if (!getClass().equals(other.getClass())) { - return getClass().getName().compareTo(other.getClass().getName()); - } - - int lastComparison = 0; - replicateLog_args typedOther = (replicateLog_args)other; - - lastComparison = Boolean.valueOf(isSetRemoteTableId()).compareTo(typedOther.isSetRemoteTableId()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetRemoteTableId()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.remoteTableId, typedOther.remoteTableId); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(isSetData()).compareTo(typedOther.isSetData()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetData()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.data, typedOther.data); - if (lastComparison != 0) { - return lastComparison; - } - } - return 0; - } - - public _Fields fieldForId(int fieldId) { - return _Fields.findByThriftId(fieldId); - } - - public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException { - schemes.get(iprot.getScheme()).getScheme().read(iprot, this); - } - - public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException { - schemes.get(oprot.getScheme()).getScheme().write(oprot, this); - } - - @Override - public String toString() { - StringBuilder sb = new StringBuilder("replicateLog_args("); - boolean first = true; - - sb.append("remoteTableId:"); - sb.append(this.remoteTableId); - first = false; - if (!first) sb.append(", "); - sb.append("data:"); - if (this.data == null) { - sb.append("null"); - } else { - sb.append(this.data); - } - 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 (data != null) { - data.validate(); - } - } - - private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException { - try { - write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out))); - } catch (org.apache.thrift.TException te) { - throw new java.io.IOException(te); - } - } - - private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException { - try { - // it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor. - __isset_bitfield = 0; - read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in))); - } catch (org.apache.thrift.TException te) { - throw new java.io.IOException(te); - } - } - - private static class replicateLog_argsStandardSchemeFactory implements SchemeFactory { - public replicateLog_argsStandardScheme getScheme() { - return new replicateLog_argsStandardScheme(); - } - } - - private static class replicateLog_argsStandardScheme extends StandardScheme<replicateLog_args> { - - public void read(org.apache.thrift.protocol.TProtocol iprot, replicateLog_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: // REMOTE_TABLE_ID - if (schemeField.type == org.apache.thrift.protocol.TType.I32) { - struct.remoteTableId = iprot.readI32(); - struct.setRemoteTableIdIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 2: // DATA - if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) { - struct.data = new WalEdits(); - struct.data.read(iprot); - struct.setDataIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - default: - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - iprot.readFieldEnd(); - } - iprot.readStructEnd(); - - // check for required fields of primitive type, which can't be checked in the validate method - struct.validate(); - } - - public void write(org.apache.thrift.protocol.TProtocol oprot, replicateLog_args struct) throws org.apache.thrift.TException { - struct.validate(); - - oprot.writeStructBegin(STRUCT_DESC); - oprot.writeFieldBegin(REMOTE_TABLE_ID_FIELD_DESC); - oprot.writeI32(struct.remoteTableId); - oprot.writeFieldEnd(); - if (struct.data != null) { - oprot.writeFieldBegin(DATA_FIELD_DESC); - struct.data.write(oprot); - oprot.writeFieldEnd(); - } - oprot.writeFieldStop(); - oprot.writeStructEnd(); - } - - } - - private static class replicateLog_argsTupleSchemeFactory implements SchemeFactory { - public replicateLog_argsTupleScheme getScheme() { - return new replicateLog_argsTupleScheme(); - } - } - - private static class replicateLog_argsTupleScheme extends TupleScheme<replicateLog_args> { - - @Override - public void write(org.apache.thrift.protocol.TProtocol prot, replicateLog_args struct) throws org.apache.thrift.TException { - TTupleProtocol oprot = (TTupleProtocol) prot; - BitSet optionals = new BitSet(); - if (struct.isSetRemoteTableId()) { - optionals.set(0); - } - if (struct.isSetData()) { - optionals.set(1); - } - oprot.writeBitSet(optionals, 2); - if (struct.isSetRemoteTableId()) { - oprot.writeI32(struct.remoteTableId); - } - if (struct.isSetData()) { - struct.data.write(oprot); - } - } - - @Override - public void read(org.apache.thrift.protocol.TProtocol prot, replicateLog_args struct) throws org.apache.thrift.TException { - TTupleProtocol iprot = (TTupleProtocol) prot; - BitSet incoming = iprot.readBitSet(2); - if (incoming.get(0)) { - struct.remoteTableId = iprot.readI32(); - struct.setRemoteTableIdIsSet(true); - } - if (incoming.get(1)) { - struct.data = new WalEdits(); - struct.data.read(iprot); - struct.setDataIsSet(true); - } - } - } - - } - - public static class replicateLog_result implements org.apache.thrift.TBase<replicateLog_result, replicateLog_result._Fields>, java.io.Serializable, Cloneable { - private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("replicateLog_result"); - - private static final org.apache.thrift.protocol.TField E_FIELD_DESC = new org.apache.thrift.protocol.TField("e", org.apache.thrift.protocol.TType.STRUCT, (short)1); - - private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); - static { - schemes.put(StandardScheme.class, new replicateLog_resultStandardSchemeFactory()); - schemes.put(TupleScheme.class, new replicateLog_resultTupleSchemeFactory()); - } - - public RemoteReplicationException e; // required - - /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ - @SuppressWarnings("all") public enum _Fields implements org.apache.thrift.TFieldIdEnum { - E((short)1, "e"); - - private static final Map<String, _Fields> byName = new HashMap<String, _Fields>(); - - static { - for (_Fields field : EnumSet.allOf(_Fields.class)) { - byName.put(field.getFieldName(), field); - } - } - - /** - * Find the _Fields constant that matches fieldId, or null if its not found. - */ - public static _Fields findByThriftId(int fieldId) { - switch(fieldId) { - case 1: // E - return E; - default: - return null; - } - } - - /** - * Find the _Fields constant that matches fieldId, throwing an exception - * if it is not found. - */ - public static _Fields findByThriftIdOrThrow(int fieldId) { - _Fields fields = findByThriftId(fieldId); - if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!"); - return fields; - } - - /** - * Find the _Fields constant that matches name, or null if its not found. - */ - public static _Fields findByName(String name) { - return byName.get(name); - } - - private final short _thriftId; - private final String _fieldName; - - _Fields(short thriftId, String fieldName) { - _thriftId = thriftId; - _fieldName = fieldName; - } - - public short getThriftFieldId() { - return _thriftId; - } - - public String getFieldName() { - return _fieldName; - } - } - - // isset id assignments - public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap; - static { - Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class); - tmpMap.put(_Fields.E, new org.apache.thrift.meta_data.FieldMetaData("e", org.apache.thrift.TFieldRequirementType.DEFAULT, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT))); - metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(replicateLog_result.class, metaDataMap); - } - - public replicateLog_result() { - } - - public replicateLog_result( - RemoteReplicationException e) - { - this(); - this.e = e; - } - - /** - * Performs a deep copy on <i>other</i>. - */ - public replicateLog_result(replicateLog_result other) { - if (other.isSetE()) { - this.e = new RemoteReplicationException(other.e); - } - } - - public replicateLog_result deepCopy() { - return new replicateLog_result(this); - } - - @Override - public void clear() { - this.e = null; - } - - public RemoteReplicationException getE() { - return this.e; - } - - public replicateLog_result setE(RemoteReplicationException e) { - this.e = e; - return this; - } - - public void unsetE() { - this.e = null; - } - - /** Returns true if field e is set (has been assigned a value) and false otherwise */ - public boolean isSetE() { - return this.e != null; - } - - public void setEIsSet(boolean value) { - if (!value) { - this.e = null; - } - } - - public void setFieldValue(_Fields field, Object value) { - switch (field) { - case E: - if (value == null) { - unsetE(); - } else { - setE((RemoteReplicationException)value); - } - break; - - } - } - - public Object getFieldValue(_Fields field) { - switch (field) { - case E: - return getE(); - - } - throw new IllegalStateException(); - } - - /** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */ - public boolean isSet(_Fields field) { - if (field == null) { - throw new IllegalArgumentException(); - } - - switch (field) { - case E: - return isSetE(); - } - throw new IllegalStateException(); - } - - @Override - public boolean equals(Object that) { - if (that == null) - return false; - if (that instanceof replicateLog_result) - return this.equals((replicateLog_result)that); - return false; - } - - public boolean equals(replicateLog_result that) { - if (that == null) - return false; - - boolean this_present_e = true && this.isSetE(); - boolean that_present_e = true && that.isSetE(); - if (this_present_e || that_present_e) { - if (!(this_present_e && that_present_e)) - return false; - if (!this.e.equals(that.e)) - return false; - } - - return true; - } - - @Override - public int hashCode() { - return 0; - } - - public int compareTo(replicateLog_result other) { - if (!getClass().equals(other.getClass())) { - return getClass().getName().compareTo(other.getClass().getName()); - } - - int lastComparison = 0; - replicateLog_result typedOther = (replicateLog_result)other; - - lastComparison = Boolean.valueOf(isSetE()).compareTo(typedOther.isSetE()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetE()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.e, typedOther.e); - if (lastComparison != 0) { - return lastComparison; - } - } - return 0; - } - - public _Fields fieldForId(int fieldId) { - return _Fields.findByThriftId(fieldId); - } - - public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException { - schemes.get(iprot.getScheme()).getScheme().read(iprot, this); - } - - public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException { - schemes.get(oprot.getScheme()).getScheme().write(oprot, this); - } - - @Override - public String toString() { - StringBuilder sb = new StringBuilder("replicateLog_result("); - boolean first = true; - - sb.append("e:"); - if (this.e == null) { - sb.append("null"); - } else { - sb.append(this.e); - } - 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, 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 replicateLog_resultStandardSchemeFactory implements SchemeFactory { - public replicateLog_resultStandardScheme getScheme() { - return new replicateLog_resultStandardScheme(); - } - } - - private static class replicateLog_resultStandardScheme extends StandardScheme<replicateLog_result> { - - public void read(org.apache.thrift.protocol.TProtocol iprot, replicateLog_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 1: // E - if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) { - struct.e = new RemoteReplicationException(); - struct.e.read(iprot); - struct.setEIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - default: - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - iprot.readFieldEnd(); - } - iprot.readStructEnd(); - - // check for required fields of primitive type, which can't be checked in the validate method - struct.validate(); - } - - public void write(org.apache.thrift.protocol.TProtocol oprot, replicateLog_result struct) throws org.apache.thrift.TException { - struct.validate(); - - oprot.writeStructBegin(STRUCT_DESC); - if (struct.e != null) { - oprot.writeFieldBegin(E_FIELD_DESC); - struct.e.write(oprot); - oprot.writeFieldEnd(); - } - oprot.writeFieldStop(); - oprot.writeStructEnd(); - } - - } - - private static class replicateLog_resultTupleSchemeFactory implements SchemeFactory { - public replicateLog_resultTupleScheme getScheme() { - return new replicateLog_resultTupleScheme(); - } - } - - private static class replicateLog_resultTupleScheme extends TupleScheme<replicateLog_result> { - - @Override - public void write(org.apache.thrift.protocol.TProtocol prot, replicateLog_result struct) throws org.apache.thrift.TException { - TTupleProtocol oprot = (TTupleProtocol) prot; - BitSet optionals = new BitSet(); - if (struct.isSetE()) { - optionals.set(0); - } - oprot.writeBitSet(optionals, 1); - if (struct.isSetE()) { - struct.e.write(oprot); - } - } - - @Override - public void read(org.apache.thrift.protocol.TProtocol prot, replicateLog_result struct) throws org.apache.thrift.TException { - TTupleProtocol iprot = (TTupleProtocol) prot; - BitSet incoming = iprot.readBitSet(1); - if (incoming.get(0)) { - struct.e = new RemoteReplicationException(); - struct.e.read(iprot); - struct.setEIsSet(true); - } - } - } - - } - - public static class replicateKeyValues_args implements org.apache.thrift.TBase<replicateKeyValues_args, replicateKeyValues_args._Fields>, java.io.Serializable, Cloneable { - private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("replicateKeyValues_args"); - - private static final org.apache.thrift.protocol.TField REMOTE_TABLE_ID_FIELD_DESC = new org.apache.thrift.protocol.TField("remoteTableId", org.apache.thrift.protocol.TType.I32, (short)1); - private static final org.apache.thrift.protocol.TField DATA_FIELD_DESC = new org.apache.thrift.protocol.TField("data", org.apache.thrift.protocol.TType.STRUCT, (short)2); - - private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); - static { - schemes.put(StandardScheme.class, new replicateKeyValues_argsStandardSchemeFactory()); - schemes.put(TupleScheme.class, new replicateKeyValues_argsTupleSchemeFactory()); - } - - public int remoteTableId; // required - public KeyValues data; // required - - /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ - @SuppressWarnings("all") public enum _Fields implements org.apache.thrift.TFieldIdEnum { - REMOTE_TABLE_ID((short)1, "remoteTableId"), - DATA((short)2, "data"); - - private static final Map<String, _Fields> byName = new HashMap<String, _Fields>(); - - static { - for (_Fields field : EnumSet.allOf(_Fields.class)) { - byName.put(field.getFieldName(), field); - } - } - - /** - * Find the _Fields constant that matches fieldId, or null if its not found. - */ - public static _Fields findByThriftId(int fieldId) { - switch(fieldId) { - case 1: // REMOTE_TABLE_ID - return REMOTE_TABLE_ID; - case 2: // DATA - return DATA; - default: - return null; - } - } - - /** - * Find the _Fields constant that matches fieldId, throwing an exception - * if it is not found. - */ - public static _Fields findByThriftIdOrThrow(int fieldId) { - _Fields fields = findByThriftId(fieldId); - if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!"); - return fields; - } - - /** - * Find the _Fields constant that matches name, or null if its not found. - */ - public static _Fields findByName(String name) { - return byName.get(name); - } - - private final short _thriftId; - private final String _fieldName; - - _Fields(short thriftId, String fieldName) { - _thriftId = thriftId; - _fieldName = fieldName; - } - - public short getThriftFieldId() { - return _thriftId; - } - - public String getFieldName() { - return _fieldName; - } - } - - // isset id assignments - private static final int __REMOTETABLEID_ISSET_ID = 0; - private byte __isset_bitfield = 0; - public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap; - static { - Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class); - tmpMap.put(_Fields.REMOTE_TABLE_ID, new org.apache.thrift.meta_data.FieldMetaData("remoteTableId", org.apache.thrift.TFieldRequirementType.DEFAULT, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32))); - tmpMap.put(_Fields.DATA, new org.apache.thrift.meta_data.FieldMetaData("data", org.apache.thrift.TFieldRequirementType.DEFAULT, - new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, KeyValues.class))); - metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(replicateKeyValues_args.class, metaDataMap); - } - - public replicateKeyValues_args() { - } - - public replicateKeyValues_args( - int remoteTableId, - KeyValues data) - { - this(); - this.remoteTableId = remoteTableId; - setRemoteTableIdIsSet(true); - this.data = data; - } - - /** - * Performs a deep copy on <i>other</i>. - */ - public replicateKeyValues_args(replicateKeyValues_args other) { - __isset_bitfield = other.__isset_bitfield; - this.remoteTableId = other.remoteTableId; - if (other.isSetData()) { - this.data = new KeyValues(other.data); - } - } - - public replicateKeyValues_args deepCopy() { - return new replicateKeyValues_args(this); - } - - @Override - public void clear() { - setRemoteTableIdIsSet(false); - this.remoteTableId = 0; - this.data = null; - } - - public int getRemoteTableId() { - return this.remoteTableId; - } - - public replicateKeyValues_args setRemoteTableId(int remoteTableId) { - this.remoteTableId = remoteTableId; - setRemoteTableIdIsSet(true); - return this; - } - - public void unsetRemoteTableId() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __REMOTETABLEID_ISSET_ID); - } - - /** Returns true if field remoteTableId is set (has been assigned a value) and false otherwise */ - public boolean isSetRemoteTableId() { - return EncodingUtils.testBit(__isset_bitfield, __REMOTETABLEID_ISSET_ID); - } - - public void setRemoteTableIdIsSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __REMOTETABLEID_ISSET_ID, value); - } - - public KeyValues getData() { - return this.data; - } - - public replicateKeyValues_args setData(KeyValues data) { - this.data = data; - return this; - } - - public void unsetData() { - this.data = null; - } - - /** Returns true if field data is set (has been assigned a value) and false otherwise */ - public boolean isSetData() { - return this.data != null; - } - - public void setDataIsSet(boolean value) { - if (!value) { - this.data = null; - } - } - - public void setFieldValue(_Fields field, Object value) { - switch (field) { - case REMOTE_TABLE_ID: - if (value == null) { - unsetRemoteTableId(); - } else { - setRemoteTableId((Integer)value); - } - break; - - case DATA: - if (value == null) { - unsetData(); - } else { - setData((KeyValues)value); - } - break; - - } - } - - public Object getFieldValue(_Fields field) { - switch (field) { - case REMOTE_TABLE_ID: - return Integer.valueOf(getRemoteTableId()); - - case DATA: - return getData(); - - } - throw new IllegalStateException(); - } - - /** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */ - public boolean isSet(_Fields field) { - if (field == null) { - throw new IllegalArgumentException(); - } - - switch (field) { - case REMOTE_TABLE_ID: - return isSetRemoteTableId(); - case DATA: - return isSetData(); - } - throw new IllegalStateException(); - } - - @Override - public boolean equals(Object that) { - if (that == null) - return false; - if (that instanceof replicateKeyValues_args) - return this.equals((replicateKeyValues_args)that); - return false; - } - - public boolean equals(replicateKeyValues_args that) { - if (that == null) - return false; - - boolean this_present_remoteTableId = true; - boolean that_present_remoteTableId = true; - if (this_present_remoteTableId || that_present_remoteTableId) { - if (!(this_present_remoteTableId && that_present_remoteTableId)) - return false; - if (this.remoteTableId != that.remoteTableId) - return false; - } - - boolean this_present_data = true && this.isSetData(); - boolean that_present_data = true && that.isSetData(); - if (this_present_data || that_present_data) { - if (!(this_present_data && that_present_data)) - return false; - if (!this.data.equals(that.data)) - return false; - } - - return true; - } - - @Override - public int hashCode() { - return 0; - } - - public int compareTo(replicateKeyValues_args other) { - if (!getClass().equals(other.getClass())) { - return getClass().getName().compareTo(other.getClass().getName()); - } - - int lastComparison = 0; - replicateKeyValues_args typedOther = (replicateKeyValues_args)other; - - lastComparison = Boolean.valueOf(isSetRemoteTableId()).compareTo(typedOther.isSetRemoteTableId()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetRemoteTableId()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.remoteTableId, typedOther.remoteTableId); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(isSetData()).compareTo(typedOther.isSetData()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetData()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.data, typedOther.data); - if (lastComparison != 0) { - return lastComparison; - } - } - return 0; - } - - public _Fields fieldForId(int fieldId) { - return _Fields.findByThriftId(fieldId); - } - - public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException { - schemes.get(iprot.getScheme()).getScheme().read(iprot, this); - } - - public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException { - schemes.get(oprot.getScheme()).getScheme().write(oprot, this); - } - - @Override - public String toString() { - StringBuilder sb = new StringBuilder("replicateKeyValues_args("); - boolean first = true; - - sb.append("remoteTableId:"); - sb.append(this.remoteTableId); - first = false; - if (!first) sb.append(", "); - sb.append("data:"); - if (this.data == null) { - sb.append("null"); - } else { - sb.append(this.data); - } - 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 (data != null) { - data.validate(); - } - } - - private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException { - try { - write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out))); - } catch (org.apache.thrift.TException te) { - throw new java.io.IOException(te); - } - } - - private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException { - try { - // it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor. - __isset_bitfield = 0; - read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in))); - } catch (org.apache.thrift.TException te) { - throw new java.io.IOException(te); - } - } - - private static class replicateKeyValues_argsStandardSchemeFactory implements SchemeFactory { - public replicateKeyValues_argsStandardScheme getScheme() { - return new replicateKeyValues_argsStandardScheme(); - } - } - - private static class replicateKeyValues_argsStandardScheme extends StandardScheme<replicateKeyValues_args> { - - public void read(org.apache.thrift.protocol.TProtocol iprot, replicateKeyValues_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: // REMOTE_TABLE_ID - if (schemeField.type == org.apache.thrift.protocol.TType.I32) { - struct.remoteTableId = iprot.readI32(); - struct.setRemoteTableIdIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 2: // DATA - if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) { - struct.data = new KeyValues(); - struct.data.read(iprot); - struct.setDataIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - default: - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - iprot.readFieldEnd(); - } - iprot.readStructEnd(); - - // check for required fields of primitive type, which can't be checked in the validate method - struct.validate(); - } - - public void write(org.apache.thrift.protocol.TProtocol oprot, replicateKeyValues_args struct) throws org.apache.thrift.TException { - struct.validate(); - - oprot.writeStructBegin(STRUCT_DESC); - oprot.writeFieldBegin(REMOTE_TABLE_ID_FIELD_DESC); - oprot.writeI32(struct.remoteTableId); - oprot.writeFieldEnd(); - if (struct.data != null) { - oprot.writeFieldBegin(DATA_FIELD_DESC); - struct.data.write(oprot); - oprot.writeFieldEnd(); - } - oprot.writeFieldStop(); - oprot.writeStructEnd(); - } - - } - - private static class replicateKeyValues_argsTupleSchemeFactory implements SchemeFactory { - public replicateKeyValues_argsTupleScheme getScheme() { - return new replicateKeyValues_argsTupleScheme(); - } - } - - private static class replicateKeyValues_argsTupleScheme extends TupleScheme<replicateKeyValues_args> { - - @Override - public void write(org.apache.thrift.protocol.TProtocol prot, replicateKeyValues_args struct) throws org.apache.thrift.TException { - TTupleProtocol oprot = (TTupleProtocol) prot; - BitSet optionals = new BitSet(); - if (struct.isSetRemoteTableId()) { - optionals.set(0); - } - if (struct.isSetData()) { - optionals.set(1); - } - oprot.writeBitSet(optionals, 2); - if (struct.isSetRemoteTableId()) { - oprot.writeI32(struct.remoteTableId); - } - if (struct.isSetData()) { - struct.data.write(oprot); - } - } - - @Override - public void read(org.apache.thrift.protocol.TProtocol prot, replicateKeyValues_args struct) throws org.apache.thrift.TException { - TTupleProtocol iprot = (TTupleProtocol) prot; - BitSet incoming = iprot.readBitSet(2); - if (incoming.get(0)) { - struct.remoteTableId = iprot.readI32(); - struct.setRemoteTableIdIsSet(true); - } - if (incoming.get(1)) { - struct.data = new KeyValues(); - struct.data.read(iprot); - struct.setDataIsSet(true); - } - } - } - - } - - public static class replicateKeyValues_result implements org.apache.thrift.TBase<replicateKeyValues_result, replicateKeyValues_result._Fields>, java.io.Serializable, Cloneable { - private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("replicateKeyValues_result"); - - private static final org.apache.thrift.protocol.TField E_FIELD_DESC = new org.apache.thrift.protocol.TField("e", org.apache.thrift.protocol.TType.STRUCT, (short)1); - - private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); - static { - schemes.put(StandardScheme.class, new replicateKeyValues_resultStandardSchemeFactory()); - schemes.put(TupleScheme.class, new replicateKeyValues_resultTupleSchemeFactory()); - } - - public RemoteReplicationException e; // required - - /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ - @SuppressWarnings("all") public enum _Fields implements org.apache.thrift.TFieldIdEnum { - E((short)1, "e"); - - private static final Map<String, _Fields> byName = new HashMap<String, _Fields>(); - - static { - for (_Fields field : EnumSet.allOf(_Fields.class)) { - byName.put(field.getFieldName(), field); - } - } - - /** - * Find the _Fields constant that matches fieldId, or null if its not found. - */ - public static _Fields findByThriftId(int fieldId) { - switch(fieldId) { - case 1: // E - return E; - default: - return null; - } - } - - /** - * Find the _Fields constant that matches fieldId, throwing an exception - * if it is not found. - */ - public static _Fields findByThriftIdOrThrow(int fieldId) { - _Fields fields = findByThriftId(fieldId); - if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!"); - return fields; - } - - /** - * Find the _Fields constant that matches name, or null if its not found. - */ - public static _Fields findByName(String name) { - return byName.get(name); - } - - private final short _thriftId; - private final String _fieldName; - - _Fields(short thriftId, String fieldName) { - _thriftId = thriftId; - _fieldName = fieldName; - } - - public short getThriftFieldId() { - return _thriftId; - } - - public String getFieldName() { - return _fieldName; - } - } - - // isset id assignments - public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap; - static { - Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class); - tmpMap.put(_Fields.E, new org.apache.thrift.meta_data.FieldMetaData("e", org.apache.thrift.TFieldRequirementType.DEFAULT, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT))); - metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(replicateKeyValues_result.class, metaDataMap); - } - - public replicateKeyValues_result() { - } - - public replicateKeyValues_result( - RemoteReplicationException e) - { - this(); - this.e = e; - } - - /** - * Performs a deep copy on <i>other</i>. - */ - public replicateKeyValues_result(replicateKeyValues_result other) { - if (other.isSetE()) { - this.e = new RemoteReplicationException(other.e); - } - } - - public replicateKeyValues_result deepCopy() { - return new replicateKeyValues_result(this); - } - - @Override - public void clear() { - this.e = null; - } - - public RemoteReplicationException getE() { - return this.e; - } - - public replicateKeyValues_result setE(RemoteReplicationException e) { - this.e = e; - return this; - } - - public void unsetE() { - this.e = null; - } - - /** Returns true if field e is set (has been assigned a value) and false otherwise */ - public boolean isSetE() { - return this.e != null; - } - - public void setEIsSet(boolean value) { - if (!value) { - this.e = null; - } - } - - public void setFieldValue(_Fields field, Object value) { - switch (field) { - case E: - if (value == null) { - unsetE(); - } else { - setE((RemoteReplicationException)value); - } - break; - - } - } - - public Object getFieldValue(_Fields field) { - switch (field) { - case E: - return getE(); - - } - throw new IllegalStateException(); - } - - /** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */ - public boolean isSet(_Fields field) { - if (field == null) { - throw new IllegalArgumentException(); - } - - switch (field) { - case E: - return isSetE(); - } - throw new IllegalStateException(); - } - - @Override - public boolean equals(Object that) { - if (that == null) - return false; - if (that instanceof replicateKeyValues_result) - return this.equals((replicateKeyValues_result)that); - return false; - } - - public boolean equals(replicateKeyValues_result that) { - if (that == null) - return false; - - boolean this_present_e = true && this.isSetE(); - boolean that_present_e = true && that.isSetE(); - if (this_present_e || that_present_e) { - if (!(this_present_e && that_present_e)) - return false; - if (!this.e.equals(that.e)) - return false; - } - - return true; - } - - @Override - public int hashCode() { - return 0; - } - - public int compareTo(replicateKeyValues_result other) { - if (!getClass().equals(other.getClass())) { - return getClass().getName().compareTo(other.getClass().getName()); - } - - int lastComparison = 0; - replicateKeyValues_result typedOther = (replicateKeyValues_result)other; - - lastComparison = Boolean.valueOf(isSetE()).compareTo(typedOther.isSetE()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetE()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.e, typedOther.e); - if (lastComparison != 0) { - return lastComparison; - } - } - return 0; - } - - public _Fields fieldForId(int fieldId) { - return _Fields.findByThriftId(fieldId); - } - - public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException { - schemes.get(iprot.getScheme()).getScheme().read(iprot, this); - } - - public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException { - schemes.get(oprot.getScheme()).getScheme().write(oprot, this); - } - - @Override - public String toString() { - StringBuilder sb = new StringBuilder("replicateKeyValues_result("); - boolean first = true; - - sb.append("e:"); - if (this.e == null) { - sb.append("null"); - } else { - sb.append(this.e); - } - 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, 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 replicateKeyValues_resultStandardSchemeFactory implements SchemeFactory { - public replicateKeyValues_resultStandardScheme getScheme() { - return new replicateKeyValues_resultStandardScheme(); - } - } - - private static class replicateKeyValues_resultStandardScheme extends StandardScheme<replicateKeyValues_result> { - - public void read(org.apache.thrift.protocol.TProtocol iprot, replicateKeyValues_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 1: // E - if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) { - struct.e = new RemoteReplicationException(); - struct.e.read(iprot); - struct.setEIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - default: - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - iprot.readFieldEnd(); - } - iprot.readStructEnd(); - - // check for required fields of primitive type, which can't be checked in the validate method - struct.validate(); - } - - public void write(org.apache.thrift.protocol.TProtocol oprot, replicateKeyValues_result struct) throws org.apache.thrift.TException { - struct.validate(); - - oprot.writeStructBegin(STRUCT_DESC); - if (struct.e != null) { - oprot.writeFieldBegin(E_FIELD_DESC); - struct.e.write(oprot); - oprot.writeFieldEnd(); - } - oprot.writeFieldStop(); - oprot.writeStructEnd(); - } - - } - - private static class replicateKeyValues_resultTupleSchemeFactory implements SchemeFactory { - public replicateKeyValues_resultTupleScheme getScheme() { - return new replicateKeyValues_resultTupleScheme(); - } - } - - private static class replicateKeyValues_resultTupleScheme extends TupleScheme<replicateKeyValues_result> { - - @Override - public void write(org.apache.thrift.protocol.TProtocol prot, replicateKeyValues_result struct) throws org.apache.thrift.TException { - TTupleProtocol oprot = (TTupleProtocol) prot; - BitSet optionals = new BitSet(); - if (struct.isSetE()) { - optionals.set(0); - } - oprot.writeBitSet(optionals, 1); - if (struct.isSetE()) { - struct.e.write(oprot); - } - } - - @Override - public void read(org.apache.thrift.protocol.TProtocol prot, replicateKeyValues_result struct) throws org.apache.thrift.TException { - TTupleProtocol iprot = (TTupleProtocol) prot; - BitSet incoming = iprot.readBitSet(1); - if (incoming.get(0)) { - struct.e = new RemoteReplicationException(); - struct.e.read(iprot); - struct.setEIsSet(true); - } - } - } - - } - -} http://git-wip-us.apache.org/repos/asf/accumulo/blob/095d641e/core/src/main/java/org/apache/accumulo/core/tabletserver/thrift/ReplicationFailedException.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/accumulo/core/tabletserver/thrift/ReplicationFailedException.java b/core/src/main/java/org/apache/accumulo/core/tabletserver/thrift/ReplicationFailedException.java deleted file mode 100644 index 63c6e00..0000000 --- a/core/src/main/java/org/apache/accumulo/core/tabletserver/thrift/ReplicationFailedException.java +++ /dev/null @@ -1,402 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -/** - * Autogenerated by Thrift Compiler (0.9.0) - * - * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING - * @generated - */ -package org.apache.accumulo.core.tabletserver.thrift; - -import org.apache.thrift.scheme.IScheme; -import org.apache.thrift.scheme.SchemeFactory; -import org.apache.thrift.scheme.StandardScheme; - -import org.apache.thrift.scheme.TupleScheme; -import org.apache.thrift.protocol.TTupleProtocol; -import org.apache.thrift.protocol.TProtocolException; -import org.apache.thrift.EncodingUtils; -import org.apache.thrift.TException; -import java.util.List; -import java.util.ArrayList; -import java.util.Map; -import java.util.HashMap; -import java.util.EnumMap; -import java.util.Set; -import java.util.HashSet; -import java.util.EnumSet; -import java.util.Collections; -import java.util.BitSet; -import java.nio.ByteBuffer; -import java.util.Arrays; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - -@SuppressWarnings("all") public class ReplicationFailedException extends TException implements org.apache.thrift.TBase<ReplicationFailedException, ReplicationFailedException._Fields>, java.io.Serializable, Cloneable { - private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("ReplicationFailedException"); - - private static final org.apache.thrift.protocol.TField REASON_FIELD_DESC = new org.apache.thrift.protocol.TField("reason", org.apache.thrift.protocol.TType.STRING, (short)1); - - private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); - static { - schemes.put(StandardScheme.class, new ReplicationFailedExceptionStandardSchemeFactory()); - schemes.put(TupleScheme.class, new ReplicationFailedExceptionTupleSchemeFactory()); - } - - public String reason; // required - - /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ - @SuppressWarnings("all") public enum _Fields implements org.apache.thrift.TFieldIdEnum { - REASON((short)1, "reason"); - - private static final Map<String, _Fields> byName = new HashMap<String, _Fields>(); - - static { - for (_Fields field : EnumSet.allOf(_Fields.class)) { - byName.put(field.getFieldName(), field); - } - } - - /** - * Find the _Fields constant that matches fieldId, or null if its not found. - */ - public static _Fields findByThriftId(int fieldId) { - switch(fieldId) { - case 1: // REASON - return REASON; - default: - return null; - } - } - - /** - * Find the _Fields constant that matches fieldId, throwing an exception - * if it is not found. - */ - public static _Fields findByThriftIdOrThrow(int fieldId) { - _Fields fields = findByThriftId(fieldId); - if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!"); - return fields; - } - - /** - * Find the _Fields constant that matches name, or null if its not found. - */ - public static _Fields findByName(String name) { - return byName.get(name); - } - - private final short _thriftId; - private final String _fieldName; - - _Fields(short thriftId, String fieldName) { - _thriftId = thriftId; - _fieldName = fieldName; - } - - public short getThriftFieldId() { - return _thriftId; - } - - public String getFieldName() { - return _fieldName; - } - } - - // isset id assignments - public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap; - static { - Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class); - tmpMap.put(_Fields.REASON, new org.apache.thrift.meta_data.FieldMetaData("reason", org.apache.thrift.TFieldRequirementType.DEFAULT, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); - metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(ReplicationFailedException.class, metaDataMap); - } - - public ReplicationFailedException() { - } - - public ReplicationFailedException( - String reason) - { - this(); - this.reason = reason; - } - - /** - * Performs a deep copy on <i>other</i>. - */ - public ReplicationFailedException(ReplicationFailedException other) { - if (other.isSetReason()) { - this.reason = other.reason; - } - } - - public ReplicationFailedException deepCopy() { - return new ReplicationFailedException(this); - } - - @Override - public void clear() { - this.reason = null; - } - - public String getReason() { - return this.reason; - } - - public ReplicationFailedException setReason(String reason) { - this.reason = reason; - return this; - } - - public void unsetReason() { - this.reason = null; - } - - /** Returns true if field reason is set (has been assigned a value) and false otherwise */ - public boolean isSetReason() { - return this.reason != null; - } - - public void setReasonIsSet(boolean value) { - if (!value) { - this.reason = null; - } - } - - public void setFieldValue(_Fields field, Object value) { - switch (field) { - case REASON: - if (value == null) { - unsetReason(); - } else { - setReason((String)value); - } - break; - - } - } - - public Object getFieldValue(_Fields field) { - switch (field) { - case REASON: - return getReason(); - - } - throw new IllegalStateException(); - } - - /** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */ - public boolean isSet(_Fields field) { - if (field == null) { - throw new IllegalArgumentException(); - } - - switch (field) { - case REASON: - return isSetReason(); - } - throw new IllegalStateException(); - } - - @Override - public boolean equals(Object that) { - if (that == null) - return false; - if (that instanceof ReplicationFailedException) - return this.equals((ReplicationFailedException)that); - return false; - } - - public boolean equals(ReplicationFailedException that) { - if (that == null) - return false; - - boolean this_present_reason = true && this.isSetReason(); - boolean that_present_reason = true && that.isSetReason(); - if (this_present_reason || that_present_reason) { - if (!(this_present_reason && that_present_reason)) - return false; - if (!this.reason.equals(that.reason)) - return false; - } - - return true; - } - - @Override - public int hashCode() { - return 0; - } - - public int compareTo(ReplicationFailedException other) { - if (!getClass().equals(other.getClass())) { - return getClass().getName().compareTo(other.getClass().getName()); - } - - int lastComparison = 0; - ReplicationFailedException typedOther = (ReplicationFailedException)other; - - lastComparison = Boolean.valueOf(isSetReason()).compareTo(typedOther.isSetReason()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetReason()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.reason, typedOther.reason); - if (lastComparison != 0) { - return lastComparison; - } - } - return 0; - } - - public _Fields fieldForId(int fieldId) { - return _Fields.findByThriftId(fieldId); - } - - public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException { - schemes.get(iprot.getScheme()).getScheme().read(iprot, this); - } - - public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException { - schemes.get(oprot.getScheme()).getScheme().write(oprot, this); - } - - @Override - public String toString() { - StringBuilder sb = new StringBuilder("ReplicationFailedException("); - boolean first = true; - - sb.append("reason:"); - if (this.reason == null) { - sb.append("null"); - } else { - sb.append(this.reason); - } - 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, 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 ReplicationFailedExceptionStandardSchemeFactory implements SchemeFactory { - public ReplicationFailedExceptionStandardScheme getScheme() { - return new ReplicationFailedExceptionStandardScheme(); - } - } - - private static class ReplicationFailedExceptionStandardScheme extends StandardScheme<ReplicationFailedException> { - - public void read(org.apache.thrift.protocol.TProtocol iprot, ReplicationFailedException 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: // REASON - if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { - struct.reason = iprot.readString(); - struct.setReasonIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - default: - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - iprot.readFieldEnd(); - } - iprot.readStructEnd(); - - // check for required fields of primitive type, which can't be checked in the validate method - struct.validate(); - } - - public void write(org.apache.thrift.protocol.TProtocol oprot, ReplicationFailedException struct) throws org.apache.thrift.TException { - struct.validate(); - - oprot.writeStructBegin(STRUCT_DESC); - if (struct.reason != null) { - oprot.writeFieldBegin(REASON_FIELD_DESC); - oprot.writeString(struct.reason); - oprot.writeFieldEnd(); - } - oprot.writeFieldStop(); - oprot.writeStructEnd(); - } - - } - - private static class ReplicationFailedExceptionTupleSchemeFactory implements SchemeFactory { - public ReplicationFailedExceptionTupleScheme getScheme() { - return new ReplicationFailedExceptionTupleScheme(); - } - } - - private static class ReplicationFailedExceptionTupleScheme extends TupleScheme<ReplicationFailedException> { - - @Override - public void write(org.apache.thrift.protocol.TProtocol prot, ReplicationFailedException struct) throws org.apache.thrift.TException { - TTupleProtocol oprot = (TTupleProtocol) prot; - BitSet optionals = new BitSet(); - if (struct.isSetReason()) { - optionals.set(0); - } - oprot.writeBitSet(optionals, 1); - if (struct.isSetReason()) { - oprot.writeString(struct.reason); - } - } - - @Override - public void read(org.apache.thrift.protocol.TProtocol prot, ReplicationFailedException struct) throws org.apache.thrift.TException { - TTupleProtocol iprot = (TTupleProtocol) prot; - BitSet incoming = iprot.readBitSet(1); - if (incoming.get(0)) { - struct.reason = iprot.readString(); - struct.setReasonIsSet(true); - } - } - } - -} -
