Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
Autogenerated by Thrift Compiler (0.9.0) DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING

Generated:
   
   package com.twitter.zipkin.gen;
   
   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.Map;
  import java.util.HashMap;
  import java.util.EnumMap;
  import java.util.Set;
  import java.util.HashSet;
  import java.util.EnumSet;
  import java.util.BitSet;
  import java.util.Arrays;
  import org.slf4j.Logger;
  
  public class ZipkinCollector {
  
    public interface Iface extends com.twitter.zipkin.gen.scribe.Iface {

    
Aggregates methods

Parameters:
service_name
annotations
  
      public void storeTopAnnotations(String service_nameList<Stringannotationsthrows StoreAggregatesException, org.apache.thrift.TException;
  
      public void storeTopKeyValueAnnotations(String service_nameList<Stringannotationsthrows StoreAggregatesException, org.apache.thrift.TException;
  
      public void storeDependencies(String service_nameList<Stringendpointsthrows StoreAggregatesException, org.apache.thrift.TException;
  
    }
  
    public interface AsyncIface extends com.twitter.zipkin.gen.scribe .AsyncIface {
  
      public void storeTopAnnotations(String service_nameList<Stringannotations, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.storeTopAnnotations_callresultHandlerthrows org.apache.thrift.TException;
  
      public void storeTopKeyValueAnnotations(String service_nameList<Stringannotations, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.storeTopKeyValueAnnotations_callresultHandlerthrows org.apache.thrift.TException;
  
      public void storeDependencies(String service_nameList<Stringendpoints, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.storeDependencies_callresultHandlerthrows org.apache.thrift.TException;
  
    }
  
    public static class Client extends com.twitter.zipkin.gen.scribe.Client 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(iprotoprot);
        }
      }
  
      public Client(org.apache.thrift.protocol.TProtocol prot)
      {
        super(protprot);
      }
  
      public Client(org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) {
        super(iprotoprot);
      }
  
      public void storeTopAnnotations(String service_nameList<Stringannotationsthrows StoreAggregatesException, org.apache.thrift.TException
      {
        send_storeTopAnnotations(service_nameannotations);
        recv_storeTopAnnotations();
      }
  
      public void send_storeTopAnnotations(String service_nameList<Stringannotationsthrows org.apache.thrift.TException
      {
        storeTopAnnotations_args args = new storeTopAnnotations_args();
        args.setService_name(service_name);
        args.setAnnotations(annotations);
        sendBase("storeTopAnnotations"args);
      }
  
      public void recv_storeTopAnnotations() throws StoreAggregatesException, org.apache.thrift.TException
      {
        storeTopAnnotations_result result = new storeTopAnnotations_result();
        receiveBase(result"storeTopAnnotations");
        if (result.e != null) {
         throw result.e;
       }
       return;
     }
 
     public void storeTopKeyValueAnnotations(String service_nameList<Stringannotationsthrows StoreAggregatesException, org.apache.thrift.TException
     {
       send_storeTopKeyValueAnnotations(service_nameannotations);
     }
 
     public void send_storeTopKeyValueAnnotations(String service_nameList<Stringannotationsthrows org.apache.thrift.TException
     {
       args.setService_name(service_name);
       args.setAnnotations(annotations);
       sendBase("storeTopKeyValueAnnotations"args);
     }
 
     public void recv_storeTopKeyValueAnnotations() throws StoreAggregatesException, org.apache.thrift.TException
     {
       receiveBase(result"storeTopKeyValueAnnotations");
       if (result.e != null) {
         throw result.e;
       }
       return;
     }
 
     public void storeDependencies(String service_nameList<Stringendpointsthrows StoreAggregatesException, org.apache.thrift.TException
     {
       send_storeDependencies(service_nameendpoints);
       recv_storeDependencies();
     }
 
     public void send_storeDependencies(String service_nameList<Stringendpointsthrows org.apache.thrift.TException
     {
       storeDependencies_args args = new storeDependencies_args();
       args.setService_name(service_name);
       args.setEndpoints(endpoints);
       sendBase("storeDependencies"args);
     }
 
     public void recv_storeDependencies() throws StoreAggregatesException, org.apache.thrift.TException
     {
       storeDependencies_result result = new storeDependencies_result();
       receiveBase(result"storeDependencies");
       if (result.e != null) {
         throw result.e;
       }
       return;
     }
 
   }
   public static class AsyncClient extends com.twitter.zipkin.gen.scribe.AsyncClient 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;
         this. = protocolFactory;
       }
       public AsyncClient getAsyncClient(org.apache.thrift.transport.TNonblockingTransport transport) {
         return new AsyncClient(transport);
       }
     }
 
     public AsyncClient(org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.async.TAsyncClientManager clientManager, org.apache.thrift.transport.TNonblockingTransport transport) {
       super(protocolFactoryclientManagertransport);
     }
 
     public void storeTopAnnotations(String service_nameList<Stringannotations, org.apache.thrift.async.AsyncMethodCallback<storeTopAnnotations_callresultHandlerthrows org.apache.thrift.TException {
       checkReady();
       storeTopAnnotations_call method_call = new storeTopAnnotations_call(service_nameannotationsresultHandlerthis, ___protocolFactory, ___transport);
       this. = method_call;
       ___manager.call(method_call);
     }
 
     public static class storeTopAnnotations_call extends org.apache.thrift.async.TAsyncMethodCall {
       private String service_name;
       private List<Stringannotations;
       public storeTopAnnotations_call(String service_nameList<Stringannotations, org.apache.thrift.async.AsyncMethodCallback<storeTopAnnotations_callresultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transportthrows org.apache.thrift.TException {
         super(clientprotocolFactorytransportresultHandlerfalse);
         this. = service_name;
         this. = annotations;
       }
 
       public void write_args(org.apache.thrift.protocol.TProtocol protthrows org.apache.thrift.TException {
         prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("storeTopAnnotations", org.apache.thrift.protocol.TMessageType.CALL, 0));
         storeTopAnnotations_args args = new storeTopAnnotations_args();
         args.setService_name();
         args.setAnnotations();
         args.write(prot);
         prot.writeMessageEnd();
       }
 
       public void getResult() throws StoreAggregatesException, 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_storeTopAnnotations();
       }
     }
 
     public void storeTopKeyValueAnnotations(String service_nameList<Stringannotations, org.apache.thrift.async.AsyncMethodCallback<storeTopKeyValueAnnotations_callresultHandlerthrows org.apache.thrift.TException {
       checkReady();
       storeTopKeyValueAnnotations_call method_call = new storeTopKeyValueAnnotations_call(service_nameannotationsresultHandlerthis, ___protocolFactory, ___transport);
       this. = method_call;
       ___manager.call(method_call);
     }
 
     public static class storeTopKeyValueAnnotations_call extends org.apache.thrift.async.TAsyncMethodCall {
       private String service_name;
       private List<Stringannotations;
       public storeTopKeyValueAnnotations_call(String service_nameList<Stringannotations, org.apache.thrift.async.AsyncMethodCallback<storeTopKeyValueAnnotations_callresultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transportthrows org.apache.thrift.TException {
         super(clientprotocolFactorytransportresultHandlerfalse);
         this. = service_name;
         this. = annotations;
       }
 
       public void write_args(org.apache.thrift.protocol.TProtocol protthrows org.apache.thrift.TException {
         prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("storeTopKeyValueAnnotations", org.apache.thrift.protocol.TMessageType.CALL, 0));
         args.setService_name();
         args.setAnnotations();
         args.write(prot);
         prot.writeMessageEnd();
       }
 
       public void getResult() throws StoreAggregatesException, 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_storeTopKeyValueAnnotations();
       }
     }
 
     public void storeDependencies(String service_nameList<Stringendpoints, org.apache.thrift.async.AsyncMethodCallback<storeDependencies_callresultHandlerthrows org.apache.thrift.TException {
       checkReady();
       storeDependencies_call method_call = new storeDependencies_call(service_nameendpointsresultHandlerthis, ___protocolFactory, ___transport);
       this. = method_call;
       ___manager.call(method_call);
     }
 
     public static class storeDependencies_call extends org.apache.thrift.async.TAsyncMethodCall {
       private String service_name;
       private List<Stringendpoints;
       public storeDependencies_call(String service_nameList<Stringendpoints, org.apache.thrift.async.AsyncMethodCallback<storeDependencies_callresultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transportthrows org.apache.thrift.TException {
         super(clientprotocolFactorytransportresultHandlerfalse);
         this. = service_name;
         this. = endpoints;
       }
 
       public void write_args(org.apache.thrift.protocol.TProtocol protthrows org.apache.thrift.TException {
         prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("storeDependencies", org.apache.thrift.protocol.TMessageType.CALL, 0));
         storeDependencies_args args = new storeDependencies_args();
         args.setService_name();
         args.setEndpoints();
         args.write(prot);
         prot.writeMessageEnd();
       }
 
       public void getResult() throws StoreAggregatesException, 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_storeDependencies();
       }
     }
 
   }
 
   public static class Processor<I extends Ifaceextends com.twitter.zipkin.gen.scribe.Processor<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 ifaceMap<String,  org.apache.thrift.ProcessFunction<I, ? extends  org.apache.thrift.TBase>> processMap) {
       super(iface, getProcessMap(processMap));
     }
 
     private static <I extends IfaceMap<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("storeTopAnnotations"new storeTopAnnotations());
       processMap.put("storeTopKeyValueAnnotations"new storeTopKeyValueAnnotations());
       processMap.put("storeDependencies"new storeDependencies());
       return processMap;
     }
 
     public static class storeTopAnnotations<I extends Ifaceextends org.apache.thrift.ProcessFunction<I, storeTopAnnotations_args> {
       public storeTopAnnotations() {
         super("storeTopAnnotations");
       }
 
         return new storeTopAnnotations_args();
       }
 
       protected boolean isOneway() {
         return false;
       }
 
       public storeTopAnnotations_result getResult(I ifacestoreTopAnnotations_args argsthrows org.apache.thrift.TException {
         storeTopAnnotations_result result = new storeTopAnnotations_result();
         try {
           iface.storeTopAnnotations(args.service_nameargs.annotations);
         } catch (StoreAggregatesException e) {
           result.e = e;
         }
         return result;
       }
     }
 
     public static class storeTopKeyValueAnnotations<I extends Ifaceextends org.apache.thrift.ProcessFunction<I, storeTopKeyValueAnnotations_args> {
       public storeTopKeyValueAnnotations() {
         super("storeTopKeyValueAnnotations");
       }
 
         return new storeTopKeyValueAnnotations_args();
       }
 
       protected boolean isOneway() {
         return false;
       }
 
       public storeTopKeyValueAnnotations_result getResult(I ifacestoreTopKeyValueAnnotations_args argsthrows org.apache.thrift.TException {
         try {
           iface.storeTopKeyValueAnnotations(args.service_nameargs.annotations);
         } catch (StoreAggregatesException e) {
           result.e = e;
         }
         return result;
       }
     }
 
     public static class storeDependencies<I extends Ifaceextends org.apache.thrift.ProcessFunction<I, storeDependencies_args> {
       public storeDependencies() {
         super("storeDependencies");
       }
 
         return new storeDependencies_args();
       }
 
       protected boolean isOneway() {
         return false;
       }
 
       public storeDependencies_result getResult(I ifacestoreDependencies_args argsthrows org.apache.thrift.TException {
         storeDependencies_result result = new storeDependencies_result();
         try {
           iface.storeDependencies(args.service_nameargs.endpoints);
         } catch (StoreAggregatesException e) {
           result.e = e;
         }
         return result;
       }
     }
 
   }
 
   public static class storeTopAnnotations_args implements org.apache.thrift.TBase<storeTopAnnotations_argsstoreTopAnnotations_args._Fields>, java.io.SerializableCloneable   {
     private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("storeTopAnnotations_args");
 
     private static final org.apache.thrift.protocol.TField SERVICE_NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("service_name", org.apache.thrift.protocol.TType.STRING, (short)1);
     private static final org.apache.thrift.protocol.TField ANNOTATIONS_FIELD_DESC = new org.apache.thrift.protocol.TField("annotations", org.apache.thrift.protocol.TType.LIST, (short)2);
 
     private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
     static {
       .put(StandardScheme.classnew storeTopAnnotations_argsStandardSchemeFactory());
       .put(TupleScheme.classnew storeTopAnnotations_argsTupleSchemeFactory());
     }
 
     private String service_name// required
     private List<Stringannotations// 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 {
       SERVICE_NAME((short)1, "service_name"),
       ANNOTATIONS((short)2, "annotations");
 
       private static final Map<String_FieldsbyName = new HashMap<String_Fields>();
 
       static {
         for (_Fields field : EnumSet.allOf(_Fields.class)) {
           .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: // SERVICE_NAME
             return ;
           case 2: // ANNOTATIONS
             return ;
           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 == nullthrow 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 .get(name);
       }
 
       private final short _thriftId;
       private final String _fieldName;
 
       _Fields(short thriftIdString fieldName) {
          = thriftId;
          = fieldName;
       }
 
       public short getThriftFieldId() {
         return ;
       }
 
       public String getFieldName() {
         return ;
       }
     }
 
     // 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(.new org.apache.thrift.meta_data.FieldMetaData("service_name", org.apache.thrift.TFieldRequirementType.DEFAULT, 
           new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
       tmpMap.put(.new org.apache.thrift.meta_data.FieldMetaData("annotations", org.apache.thrift.TFieldRequirementType.DEFAULT, 
           new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST, 
               new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))));
        = Collections.unmodifiableMap(tmpMap);
       org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(storeTopAnnotations_args.class);
     }
 
     public storeTopAnnotations_args() {
     }
 
     public storeTopAnnotations_args(
       String service_name,
       List<Stringannotations)
     {
       this();
       this. = service_name;
       this. = annotations;
     }

    
Performs a deep copy on other.
 
       if (other.isSetService_name()) {
         this. = other.service_name;
       }
       if (other.isSetAnnotations()) {
         List<String__this__annotations = new ArrayList<String>();
         for (String other_element : other.annotations) {
           __this__annotations.add(other_element);
         }
         this. = __this__annotations;
       }
     }
 
     public storeTopAnnotations_args deepCopy() {
       return new storeTopAnnotations_args(this);
     }
 
     @Override
     public void clear() {
       this. = null;
       this. = null;
     }
 
     public String getService_name() {
       return this.;
     }
 
     public storeTopAnnotations_args setService_name(String service_name) {
       this. = service_name;
       return this;
     }
 
     public void unsetService_name() {
       this. = null;
     }

    
Returns true if field service_name is set (has been assigned a value) and false otherwise
 
     public boolean isSetService_name() {
       return this. != null;
     }
 
     public void setService_nameIsSet(boolean value) {
       if (!value) {
         this. = null;
       }
     }
 
     public int getAnnotationsSize() {
       return (this. == null) ? 0 : this..size();
     }
 
       return (this. == null) ? null : this..iterator();
     }
 
     public void addToAnnotations(String elem) {
       if (this. == null) {
         this. = new ArrayList<String>();
       }
       this..add(elem);
     }
 
     public List<StringgetAnnotations() {
       return this.;
     }
 
     public storeTopAnnotations_args setAnnotations(List<Stringannotations) {
       this. = annotations;
       return this;
     }
 
     public void unsetAnnotations() {
       this. = null;
     }

    
Returns true if field annotations is set (has been assigned a value) and false otherwise
 
     public boolean isSetAnnotations() {
       return this. != null;
     }
 
     public void setAnnotationsIsSet(boolean value) {
       if (!value) {
         this. = null;
       }
     }
 
     public void setFieldValue(_Fields fieldObject value) {
       switch (field) {
       case :
         if (value == null) {
           unsetService_name();
         } else {
           setService_name((String)value);
         }
         break;
 
       case :
         if (value == null) {
           unsetAnnotations();
         } else {
           setAnnotations((List<String>)value);
         }
         break;
 
       }
     }
 
     public Object getFieldValue(_Fields field) {
       switch (field) {
       case :
         return getService_name();
 
       case :
         return getAnnotations();
 
       }
       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 :
         return isSetService_name();
       case :
         return isSetAnnotations();
       }
       throw new IllegalStateException();
     }
 
     @Override
     public boolean equals(Object that) {
       if (that == null)
         return false;
       if (that instanceof storeTopAnnotations_args)
         return this.equals((storeTopAnnotations_args)that);
       return false;
     }
 
     public boolean equals(storeTopAnnotations_args that) {
       if (that == null)
         return false;
 
       boolean this_present_service_name = true && this.isSetService_name();
       boolean that_present_service_name = true && that.isSetService_name();
       if (this_present_service_name || that_present_service_name) {
         if (!(this_present_service_name && that_present_service_name))
           return false;
         if (!this..equals(that.service_name))
           return false;
       }
 
       boolean this_present_annotations = true && this.isSetAnnotations();
       boolean that_present_annotations = true && that.isSetAnnotations();
       if (this_present_annotations || that_present_annotations) {
         if (!(this_present_annotations && that_present_annotations))
           return false;
         if (!this..equals(that.annotations))
           return false;
       }
 
       return true;
     }
 
     @Override
     public int hashCode() {
       return 0;
     }
 
     public int compareTo(storeTopAnnotations_args other) {
       if (!getClass().equals(other.getClass())) {
         return getClass().getName().compareTo(other.getClass().getName());
       }
 
       int lastComparison = 0;
       storeTopAnnotations_args typedOther = (storeTopAnnotations_args)other;
 
       lastComparison = Boolean.valueOf(isSetService_name()).compareTo(typedOther.isSetService_name());
       if (lastComparison != 0) {
         return lastComparison;
       }
       if (isSetService_name()) {
         lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.typedOther.service_name);
         if (lastComparison != 0) {
           return lastComparison;
         }
       }
       lastComparison = Boolean.valueOf(isSetAnnotations()).compareTo(typedOther.isSetAnnotations());
       if (lastComparison != 0) {
         return lastComparison;
       }
       if (isSetAnnotations()) {
         lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.typedOther.annotations);
         if (lastComparison != 0) {
           return lastComparison;
         }
       }
       return 0;
     }
 
     public _Fields fieldForId(int fieldId) {
       return _Fields.findByThriftId(fieldId);
     }
 
     public void read(org.apache.thrift.protocol.TProtocol iprotthrows org.apache.thrift.TException {
       .get(iprot.getScheme()).getScheme().read(iprotthis);
     }
 
     public void write(org.apache.thrift.protocol.TProtocol oprotthrows org.apache.thrift.TException {
       .get(oprot.getScheme()).getScheme().write(oprotthis);
     }
 
     @Override
     public String toString() {
       StringBuilder sb = new StringBuilder("storeTopAnnotations_args(");
       boolean first = true;
 
       sb.append("service_name:");
       if (this. == null) {
         sb.append("null");
       } else {
         sb.append(this.);
       }
       first = false;
       if (!firstsb.append(", ");
       sb.append("annotations:");
       if (this. == null) {
         sb.append("null");
       } else {
         sb.append(this.);
       }
       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 outthrows 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 inthrows java.io.IOExceptionClassNotFoundException {
       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 storeTopAnnotations_argsStandardSchemeFactory implements SchemeFactory {
         return new storeTopAnnotations_argsStandardScheme();
       }
     }
 
     private static class storeTopAnnotations_argsStandardScheme extends StandardScheme<storeTopAnnotations_args> {
 
       public void read(org.apache.thrift.protocol.TProtocol iprotstoreTopAnnotations_args structthrows 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: // SERVICE_NAME
               if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
                 struct.service_name = iprot.readString();
                 struct.setService_nameIsSet(true);
               } else { 
                 org.apache.thrift.protocol.TProtocolUtil.skip(iprotschemeField.type);
               }
               break;
             case 2: // ANNOTATIONS
               if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
                 {
                   org.apache.thrift.protocol.TList _list0 = iprot.readListBegin();
                   struct.annotations = new ArrayList<String>(_list0.size);
                   for (int _i1 = 0; _i1 < _list0.size; ++_i1)
                   {
                     String _elem2// required
                     _elem2 = iprot.readString();
                     struct.annotations.add(_elem2);
                   }
                   iprot.readListEnd();
                 }
                 struct.setAnnotationsIsSet(true);
               } else { 
                 org.apache.thrift.protocol.TProtocolUtil.skip(iprotschemeField.type);
               }
               break;
             default:
               org.apache.thrift.protocol.TProtocolUtil.skip(iprotschemeField.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 oprotstoreTopAnnotations_args structthrows org.apache.thrift.TException {
         struct.validate();
 
         oprot.writeStructBegin();
         if (struct.service_name != null) {
           oprot.writeFieldBegin();
           oprot.writeString(struct.service_name);
           oprot.writeFieldEnd();
         }
         if (struct.annotations != null) {
           oprot.writeFieldBegin();
           {
             oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.annotations.size()));
             for (String _iter3 : struct.annotations)
             {
               oprot.writeString(_iter3);
             }
             oprot.writeListEnd();
           }
           oprot.writeFieldEnd();
         }
         oprot.writeFieldStop();
         oprot.writeStructEnd();
       }
 
     }
 
     private static class storeTopAnnotations_argsTupleSchemeFactory implements SchemeFactory {
         return new storeTopAnnotations_argsTupleScheme();
       }
     }
 
     private static class storeTopAnnotations_argsTupleScheme extends TupleScheme<storeTopAnnotations_args> {
 
       @Override
       public void write(org.apache.thrift.protocol.TProtocol protstoreTopAnnotations_args structthrows org.apache.thrift.TException {
         TTupleProtocol oprot = (TTupleProtocol) prot;
         BitSet optionals = new BitSet();
         if (struct.isSetService_name()) {
           optionals.set(0);
         }
         if (struct.isSetAnnotations()) {
           optionals.set(1);
         }
         oprot.writeBitSet(optionals, 2);
         if (struct.isSetService_name()) {
           oprot.writeString(struct.service_name);
         }
         if (struct.isSetAnnotations()) {
           {
             oprot.writeI32(struct.annotations.size());
             for (String _iter4 : struct.annotations)
             {
               oprot.writeString(_iter4);
             }
           }
         }
       }
 
       @Override
       public void read(org.apache.thrift.protocol.TProtocol protstoreTopAnnotations_args structthrows org.apache.thrift.TException {
         TTupleProtocol iprot = (TTupleProtocol) prot;
         BitSet incoming = iprot.readBitSet(2);
         if (incoming.get(0)) {
           struct.service_name = iprot.readString();
           struct.setService_nameIsSet(true);
         }
         if (incoming.get(1)) {
           {
             org.apache.thrift.protocol.TList _list5 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
             struct.annotations = new ArrayList<String>(_list5.size);
             for (int _i6 = 0; _i6 < _list5.size; ++_i6)
             {
               String _elem7// required
               _elem7 = iprot.readString();
               struct.annotations.add(_elem7);
             }
           }
           struct.setAnnotationsIsSet(true);
         }
       }
     }
 
   }
 
   public static class storeTopAnnotations_result implements org.apache.thrift.TBase<storeTopAnnotations_resultstoreTopAnnotations_result._Fields>, java.io.SerializableCloneable   {
     private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("storeTopAnnotations_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 {
       .put(StandardScheme.classnew storeTopAnnotations_resultStandardSchemeFactory());
       .put(TupleScheme.classnew storeTopAnnotations_resultTupleSchemeFactory());
     }
 
     private StoreAggregatesException e// 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 {
       E((short)1, "e");
 
       private static final Map<String_FieldsbyName = new HashMap<String_Fields>();
 
       static {
         for (_Fields field : EnumSet.allOf(_Fields.class)) {
           .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 ;
           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 == nullthrow 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 .get(name);
       }
 
       private final short _thriftId;
       private final String _fieldName;
 
       _Fields(short thriftIdString fieldName) {
          = thriftId;
          = fieldName;
       }
 
       public short getThriftFieldId() {
         return ;
       }
 
       public String getFieldName() {
         return ;
       }
     }
 
     // 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(.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)));
        = Collections.unmodifiableMap(tmpMap);
       org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(storeTopAnnotations_result.class);
     }
 
     public storeTopAnnotations_result() {
     }
 
       StoreAggregatesException e)
     {
       this();
       this. = e;
     }

    
Performs a deep copy on other.
 
       if (other.isSetE()) {
         this. = new StoreAggregatesException(other.e);
       }
     }
 
     public storeTopAnnotations_result deepCopy() {
       return new storeTopAnnotations_result(this);
     }
 
     @Override
     public void clear() {
       this. = null;
     }
 
     public StoreAggregatesException getE() {
       return this.;
     }
 
       this. = e;
       return this;
     }
 
     public void unsetE() {
       this. = null;
     }

    
Returns true if field e is set (has been assigned a value) and false otherwise
 
     public boolean isSetE() {
       return this. != null;
    }
    public void setEIsSet(boolean value) {
      if (!value) {
        this. = null;
      }
    }
    public void setFieldValue(_Fields fieldObject value) {
      switch (field) {
      case :
        if (value == null) {
          unsetE();
        } else {
          setE((StoreAggregatesException)value);
        }
        break;
      }
    }
    public Object getFieldValue(_Fields field) {
      switch (field) {
      case :
        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 :
        return isSetE();
      }
      throw new IllegalStateException();
    }
    @Override
    public boolean equals(Object that) {
      if (that == null)
        return false;
      if (that instanceof storeTopAnnotations_result)
        return this.equals((storeTopAnnotations_result)that);
      return false;
    }
    public boolean equals(storeTopAnnotations_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..equals(that.e))
          return false;
      }
      return true;
    }
    @Override
    public int hashCode() {
      return 0;
    }
    public int compareTo(storeTopAnnotations_result other) {
      if (!getClass().equals(other.getClass())) {
        return getClass().getName().compareTo(other.getClass().getName());
      }
      int lastComparison = 0;
      lastComparison = Boolean.valueOf(isSetE()).compareTo(typedOther.isSetE());
      if (lastComparison != 0) {
        return lastComparison;
      }
      if (isSetE()) {
        lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.typedOther.e);