incubator-blur-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From amccu...@apache.org
Subject [2/8] Working on https://issues.apache.org/jira/browse/BLUR-42. Not tested yet, and no cancel implementation.
Date Tue, 29 Jan 2013 15:01:02 GMT
http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/a2585810/src/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/TableDescriptor.java
----------------------------------------------------------------------
diff --git a/src/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/TableDescriptor.java b/src/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/TableDescriptor.java
index e5a267a..585c20d 100644
--- a/src/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/TableDescriptor.java
+++ b/src/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/TableDescriptor.java
@@ -1074,15 +1074,15 @@ public class TableDescriptor implements org.apache.thrift.TBase<TableDescriptor,
           case 8: // PROPERTIES
             if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
               {
-                org.apache.thrift.protocol.TMap _map44 = iprot.readMapBegin();
-                struct.properties = new HashMap<String,String>(2*_map44.size);
-                for (int _i45 = 0; _i45 < _map44.size; ++_i45)
+                org.apache.thrift.protocol.TMap _map34 = iprot.readMapBegin();
+                struct.properties = new HashMap<String,String>(2*_map34.size);
+                for (int _i35 = 0; _i35 < _map34.size; ++_i35)
                 {
-                  String _key46; // required
-                  String _val47; // optional
-                  _key46 = iprot.readString();
-                  _val47 = iprot.readString();
-                  struct.properties.put(_key46, _val47);
+                  String _key36; // required
+                  String _val37; // optional
+                  _key36 = iprot.readString();
+                  _val37 = iprot.readString();
+                  struct.properties.put(_key36, _val37);
                 }
                 iprot.readMapEnd();
               }
@@ -1139,10 +1139,10 @@ public class TableDescriptor implements org.apache.thrift.TBase<TableDescriptor,
         oprot.writeFieldBegin(PROPERTIES_FIELD_DESC);
         {
           oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, struct.properties.size()));
-          for (Map.Entry<String, String> _iter48 : struct.properties.entrySet())
+          for (Map.Entry<String, String> _iter38 : struct.properties.entrySet())
           {
-            oprot.writeString(_iter48.getKey());
-            oprot.writeString(_iter48.getValue());
+            oprot.writeString(_iter38.getKey());
+            oprot.writeString(_iter38.getValue());
           }
           oprot.writeMapEnd();
         }
@@ -1215,10 +1215,10 @@ public class TableDescriptor implements org.apache.thrift.TBase<TableDescriptor,
       if (struct.isSetProperties()) {
         {
           oprot.writeI32(struct.properties.size());
-          for (Map.Entry<String, String> _iter49 : struct.properties.entrySet())
+          for (Map.Entry<String, String> _iter39 : struct.properties.entrySet())
           {
-            oprot.writeString(_iter49.getKey());
-            oprot.writeString(_iter49.getValue());
+            oprot.writeString(_iter39.getKey());
+            oprot.writeString(_iter39.getValue());
           }
         }
       }
@@ -1259,15 +1259,15 @@ public class TableDescriptor implements org.apache.thrift.TBase<TableDescriptor,
       }
       if (incoming.get(7)) {
         {
-          org.apache.thrift.protocol.TMap _map50 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, iprot.readI32());
-          struct.properties = new HashMap<String,String>(2*_map50.size);
-          for (int _i51 = 0; _i51 < _map50.size; ++_i51)
+          org.apache.thrift.protocol.TMap _map40 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+          struct.properties = new HashMap<String,String>(2*_map40.size);
+          for (int _i41 = 0; _i41 < _map40.size; ++_i41)
           {
-            String _key52; // required
-            String _val53; // optional
-            _key52 = iprot.readString();
-            _val53 = iprot.readString();
-            struct.properties.put(_key52, _val53);
+            String _key42; // required
+            String _val43; // optional
+            _key42 = iprot.readString();
+            _val43 = iprot.readString();
+            struct.properties.put(_key42, _val43);
           }
         }
         struct.setPropertiesIsSet(true);

http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/a2585810/src/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/TableSchema.java
----------------------------------------------------------------------
diff --git a/src/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/TableSchema.java b/src/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/TableSchema.java
index 0646589..0faa76d 100644
--- a/src/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/TableSchema.java
+++ b/src/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/TableSchema.java
@@ -462,14 +462,14 @@ public class TableSchema implements org.apache.thrift.TBase<TableSchema, TableSc
           case 1: // FIELDS
             if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
               {
-                org.apache.thrift.protocol.TList _list10 = iprot.readListBegin();
-                struct.fields = new ArrayList<FieldSchema>(_list10.size);
-                for (int _i11 = 0; _i11 < _list10.size; ++_i11)
+                org.apache.thrift.protocol.TList _list0 = iprot.readListBegin();
+                struct.fields = new ArrayList<FieldSchema>(_list0.size);
+                for (int _i1 = 0; _i1 < _list0.size; ++_i1)
                 {
-                  FieldSchema _elem12; // required
-                  _elem12 = new FieldSchema();
-                  _elem12.read(iprot);
-                  struct.fields.add(_elem12);
+                  FieldSchema _elem2; // required
+                  _elem2 = new FieldSchema();
+                  _elem2.read(iprot);
+                  struct.fields.add(_elem2);
                 }
                 iprot.readListEnd();
               }
@@ -505,9 +505,9 @@ public class TableSchema implements org.apache.thrift.TBase<TableSchema, TableSc
         oprot.writeFieldBegin(FIELDS_FIELD_DESC);
         {
           oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.fields.size()));
-          for (FieldSchema _iter13 : struct.fields)
+          for (FieldSchema _iter3 : struct.fields)
           {
-            _iter13.write(oprot);
+            _iter3.write(oprot);
           }
           oprot.writeListEnd();
         }
@@ -546,9 +546,9 @@ public class TableSchema implements org.apache.thrift.TBase<TableSchema, TableSc
       if (struct.isSetFields()) {
         {
           oprot.writeI32(struct.fields.size());
-          for (FieldSchema _iter14 : struct.fields)
+          for (FieldSchema _iter4 : struct.fields)
           {
-            _iter14.write(oprot);
+            _iter4.write(oprot);
           }
         }
       }
@@ -563,14 +563,14 @@ public class TableSchema implements org.apache.thrift.TBase<TableSchema, TableSc
       BitSet incoming = iprot.readBitSet(2);
       if (incoming.get(0)) {
         {
-          org.apache.thrift.protocol.TList _list15 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
-          struct.fields = new ArrayList<FieldSchema>(_list15.size);
-          for (int _i16 = 0; _i16 < _list15.size; ++_i16)
+          org.apache.thrift.protocol.TList _list5 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+          struct.fields = new ArrayList<FieldSchema>(_list5.size);
+          for (int _i6 = 0; _i6 < _list5.size; ++_i6)
           {
-            FieldSchema _elem17; // required
-            _elem17 = new FieldSchema();
-            _elem17.read(iprot);
-            struct.fields.add(_elem17);
+            FieldSchema _elem7; // required
+            _elem7 = new FieldSchema();
+            _elem7.read(iprot);
+            struct.fields.add(_elem7);
           }
         }
         struct.setFieldsIsSet(true);

http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/a2585810/src/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/TopFieldDocs.java
----------------------------------------------------------------------
diff --git a/src/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/TopFieldDocs.java b/src/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/TopFieldDocs.java
index 9c68b18..bd6d1b0 100644
--- a/src/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/TopFieldDocs.java
+++ b/src/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/TopFieldDocs.java
@@ -694,14 +694,14 @@ public class TopFieldDocs implements org.apache.thrift.TBase<TopFieldDocs, TopFi
           case 3: // SCORE_DOCS
             if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
               {
-                org.apache.thrift.protocol.TList _list78 = iprot.readListBegin();
-                struct.scoreDocs = new ArrayList<ScoreDoc>(_list78.size);
-                for (int _i79 = 0; _i79 < _list78.size; ++_i79)
+                org.apache.thrift.protocol.TList _list68 = iprot.readListBegin();
+                struct.scoreDocs = new ArrayList<ScoreDoc>(_list68.size);
+                for (int _i69 = 0; _i69 < _list68.size; ++_i69)
                 {
-                  ScoreDoc _elem80; // required
-                  _elem80 = new ScoreDoc();
-                  _elem80.read(iprot);
-                  struct.scoreDocs.add(_elem80);
+                  ScoreDoc _elem70; // required
+                  _elem70 = new ScoreDoc();
+                  _elem70.read(iprot);
+                  struct.scoreDocs.add(_elem70);
                 }
                 iprot.readListEnd();
               }
@@ -721,14 +721,14 @@ public class TopFieldDocs implements org.apache.thrift.TBase<TopFieldDocs, TopFi
           case 5: // FIELDS
             if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
               {
-                org.apache.thrift.protocol.TList _list81 = iprot.readListBegin();
-                struct.fields = new ArrayList<SortField>(_list81.size);
-                for (int _i82 = 0; _i82 < _list81.size; ++_i82)
+                org.apache.thrift.protocol.TList _list71 = iprot.readListBegin();
+                struct.fields = new ArrayList<SortField>(_list71.size);
+                for (int _i72 = 0; _i72 < _list71.size; ++_i72)
                 {
-                  SortField _elem83; // required
-                  _elem83 = new SortField();
-                  _elem83.read(iprot);
-                  struct.fields.add(_elem83);
+                  SortField _elem73; // required
+                  _elem73 = new SortField();
+                  _elem73.read(iprot);
+                  struct.fields.add(_elem73);
                 }
                 iprot.readListEnd();
               }
@@ -762,9 +762,9 @@ public class TopFieldDocs implements org.apache.thrift.TBase<TopFieldDocs, TopFi
         oprot.writeFieldBegin(SCORE_DOCS_FIELD_DESC);
         {
           oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.scoreDocs.size()));
-          for (ScoreDoc _iter84 : struct.scoreDocs)
+          for (ScoreDoc _iter74 : struct.scoreDocs)
           {
-            _iter84.write(oprot);
+            _iter74.write(oprot);
           }
           oprot.writeListEnd();
         }
@@ -777,9 +777,9 @@ public class TopFieldDocs implements org.apache.thrift.TBase<TopFieldDocs, TopFi
         oprot.writeFieldBegin(FIELDS_FIELD_DESC);
         {
           oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.fields.size()));
-          for (SortField _iter85 : struct.fields)
+          for (SortField _iter75 : struct.fields)
           {
-            _iter85.write(oprot);
+            _iter75.write(oprot);
           }
           oprot.writeListEnd();
         }
@@ -828,9 +828,9 @@ public class TopFieldDocs implements org.apache.thrift.TBase<TopFieldDocs, TopFi
       if (struct.isSetScoreDocs()) {
         {
           oprot.writeI32(struct.scoreDocs.size());
-          for (ScoreDoc _iter86 : struct.scoreDocs)
+          for (ScoreDoc _iter76 : struct.scoreDocs)
           {
-            _iter86.write(oprot);
+            _iter76.write(oprot);
           }
         }
       }
@@ -840,9 +840,9 @@ public class TopFieldDocs implements org.apache.thrift.TBase<TopFieldDocs, TopFi
       if (struct.isSetFields()) {
         {
           oprot.writeI32(struct.fields.size());
-          for (SortField _iter87 : struct.fields)
+          for (SortField _iter77 : struct.fields)
           {
-            _iter87.write(oprot);
+            _iter77.write(oprot);
           }
         }
       }
@@ -862,14 +862,14 @@ public class TopFieldDocs implements org.apache.thrift.TBase<TopFieldDocs, TopFi
       }
       if (incoming.get(2)) {
         {
-          org.apache.thrift.protocol.TList _list88 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
-          struct.scoreDocs = new ArrayList<ScoreDoc>(_list88.size);
-          for (int _i89 = 0; _i89 < _list88.size; ++_i89)
+          org.apache.thrift.protocol.TList _list78 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+          struct.scoreDocs = new ArrayList<ScoreDoc>(_list78.size);
+          for (int _i79 = 0; _i79 < _list78.size; ++_i79)
           {
-            ScoreDoc _elem90; // required
-            _elem90 = new ScoreDoc();
-            _elem90.read(iprot);
-            struct.scoreDocs.add(_elem90);
+            ScoreDoc _elem80; // required
+            _elem80 = new ScoreDoc();
+            _elem80.read(iprot);
+            struct.scoreDocs.add(_elem80);
           }
         }
         struct.setScoreDocsIsSet(true);
@@ -880,14 +880,14 @@ public class TopFieldDocs implements org.apache.thrift.TBase<TopFieldDocs, TopFi
       }
       if (incoming.get(4)) {
         {
-          org.apache.thrift.protocol.TList _list91 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
-          struct.fields = new ArrayList<SortField>(_list91.size);
-          for (int _i92 = 0; _i92 < _list91.size; ++_i92)
+          org.apache.thrift.protocol.TList _list81 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+          struct.fields = new ArrayList<SortField>(_list81.size);
+          for (int _i82 = 0; _i82 < _list81.size; ++_i82)
           {
-            SortField _elem93; // required
-            _elem93 = new SortField();
-            _elem93.read(iprot);
-            struct.fields.add(_elem93);
+            SortField _elem83; // required
+            _elem83 = new SortField();
+            _elem83.read(iprot);
+            struct.fields.add(_elem83);
           }
         }
         struct.setFieldsIsSet(true);

http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/a2585810/src/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/UpdatePackage.java
----------------------------------------------------------------------
diff --git a/src/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/UpdatePackage.java b/src/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/UpdatePackage.java
index 00e1da7..df8a10b 100644
--- a/src/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/UpdatePackage.java
+++ b/src/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/UpdatePackage.java
@@ -474,14 +474,14 @@ public class UpdatePackage implements org.apache.thrift.TBase<UpdatePackage, Upd
           case 2: // DOCUMENTS
             if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
               {
-                org.apache.thrift.protocol.TList _list102 = iprot.readListBegin();
-                struct.documents = new ArrayList<Document>(_list102.size);
-                for (int _i103 = 0; _i103 < _list102.size; ++_i103)
+                org.apache.thrift.protocol.TList _list92 = iprot.readListBegin();
+                struct.documents = new ArrayList<Document>(_list92.size);
+                for (int _i93 = 0; _i93 < _list92.size; ++_i93)
                 {
-                  Document _elem104; // required
-                  _elem104 = new Document();
-                  _elem104.read(iprot);
-                  struct.documents.add(_elem104);
+                  Document _elem94; // required
+                  _elem94 = new Document();
+                  _elem94.read(iprot);
+                  struct.documents.add(_elem94);
                 }
                 iprot.readListEnd();
               }
@@ -514,9 +514,9 @@ public class UpdatePackage implements org.apache.thrift.TBase<UpdatePackage, Upd
         oprot.writeFieldBegin(DOCUMENTS_FIELD_DESC);
         {
           oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.documents.size()));
-          for (Document _iter105 : struct.documents)
+          for (Document _iter95 : struct.documents)
           {
-            _iter105.write(oprot);
+            _iter95.write(oprot);
           }
           oprot.writeListEnd();
         }
@@ -553,9 +553,9 @@ public class UpdatePackage implements org.apache.thrift.TBase<UpdatePackage, Upd
       if (struct.isSetDocuments()) {
         {
           oprot.writeI32(struct.documents.size());
-          for (Document _iter106 : struct.documents)
+          for (Document _iter96 : struct.documents)
           {
-            _iter106.write(oprot);
+            _iter96.write(oprot);
           }
         }
       }
@@ -572,14 +572,14 @@ public class UpdatePackage implements org.apache.thrift.TBase<UpdatePackage, Upd
       }
       if (incoming.get(1)) {
         {
-          org.apache.thrift.protocol.TList _list107 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
-          struct.documents = new ArrayList<Document>(_list107.size);
-          for (int _i108 = 0; _i108 < _list107.size; ++_i108)
+          org.apache.thrift.protocol.TList _list97 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+          struct.documents = new ArrayList<Document>(_list97.size);
+          for (int _i98 = 0; _i98 < _list97.size; ++_i98)
           {
-            Document _elem109; // required
-            _elem109 = new Document();
-            _elem109.read(iprot);
-            struct.documents.add(_elem109);
+            Document _elem99; // required
+            _elem99 = new Document();
+            _elem99.read(iprot);
+            struct.documents.add(_elem99);
           }
         }
         struct.setDocumentsIsSet(true);

http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/a2585810/src/distribution/src/main/scripts/interface/gen-perl/Blur/Blur.pm
----------------------------------------------------------------------
diff --git a/src/distribution/src/main/scripts/interface/gen-perl/Blur/Blur.pm b/src/distribution/src/main/scripts/interface/gen-perl/Blur/Blur.pm
index 702259b..4be41c8 100644
--- a/src/distribution/src/main/scripts/interface/gen-perl/Blur/Blur.pm
+++ b/src/distribution/src/main/scripts/interface/gen-perl/Blur/Blur.pm
@@ -280,16 +280,16 @@ sub read {
     {
       /^0$/ && do{      if ($ftype == TType::LIST) {
         {
-          my $_size104 = 0;
+          my $_size95 = 0;
           $self->{success} = [];
-          my $_etype107 = 0;
-          $xfer += $input->readListBegin(\$_etype107, \$_size104);
-          for (my $_i108 = 0; $_i108 < $_size104; ++$_i108)
+          my $_etype98 = 0;
+          $xfer += $input->readListBegin(\$_etype98, \$_size95);
+          for (my $_i99 = 0; $_i99 < $_size95; ++$_i99)
           {
-            my $elem109 = undef;
-            $elem109 = new Blur::TopFieldDocs();
-            $xfer += $elem109->read($input);
-            push(@{$self->{success}},$elem109);
+            my $elem100 = undef;
+            $elem100 = new Blur::TopFieldDocs();
+            $xfer += $elem100->read($input);
+            push(@{$self->{success}},$elem100);
           }
           $xfer += $input->readListEnd();
         }
@@ -321,9 +321,9 @@ sub write {
     {
       $xfer += $output->writeListBegin(TType::STRUCT, scalar(@{$self->{success}}));
       {
-        foreach my $iter110 (@{$self->{success}}) 
+        foreach my $iter101 (@{$self->{success}}) 
         {
-          $xfer += ${iter110}->write($output);
+          $xfer += ${iter101}->write($output);
         }
       }
       $xfer += $output->writeListEnd();
@@ -393,15 +393,15 @@ sub read {
       last; };
       /^2$/ && do{      if ($ftype == TType::LIST) {
         {
-          my $_size111 = 0;
+          my $_size102 = 0;
           $self->{docLocations} = [];
-          my $_etype114 = 0;
-          $xfer += $input->readListBegin(\$_etype114, \$_size111);
-          for (my $_i115 = 0; $_i115 < $_size111; ++$_i115)
+          my $_etype105 = 0;
+          $xfer += $input->readListBegin(\$_etype105, \$_size102);
+          for (my $_i106 = 0; $_i106 < $_size102; ++$_i106)
           {
-            my $elem116 = undef;
-            $xfer += $input->readI64(\$elem116);
-            push(@{$self->{docLocations}},$elem116);
+            my $elem107 = undef;
+            $xfer += $input->readI64(\$elem107);
+            push(@{$self->{docLocations}},$elem107);
           }
           $xfer += $input->readListEnd();
         }
@@ -411,15 +411,15 @@ sub read {
       last; };
       /^4$/ && do{      if ($ftype == TType::SET) {
         {
-          my $_size117 = 0;
+          my $_size108 = 0;
           $self->{fields} = {};
-          my $_etype120 = 0;
-          $xfer += $input->readSetBegin(\$_etype120, \$_size117);
-          for (my $_i121 = 0; $_i121 < $_size117; ++$_i121)
+          my $_etype111 = 0;
+          $xfer += $input->readSetBegin(\$_etype111, \$_size108);
+          for (my $_i112 = 0; $_i112 < $_size108; ++$_i112)
           {
-            my $elem122 = undef;
-            $xfer += $input->readString(\$elem122);
-            $self->{fields}->{$elem122} = 1;
+            my $elem113 = undef;
+            $xfer += $input->readString(\$elem113);
+            $self->{fields}->{$elem113} = 1;
           }
           $xfer += $input->readSetEnd();
         }
@@ -449,9 +449,9 @@ sub write {
     {
       $xfer += $output->writeListBegin(TType::I64, scalar(@{$self->{docLocations}}));
       {
-        foreach my $iter123 (@{$self->{docLocations}}) 
+        foreach my $iter114 (@{$self->{docLocations}}) 
         {
-          $xfer += $output->writeI64($iter123);
+          $xfer += $output->writeI64($iter114);
         }
       }
       $xfer += $output->writeListEnd();
@@ -463,9 +463,9 @@ sub write {
     {
       $xfer += $output->writeSetBegin(TType::STRING, scalar(@{$self->{fields}}));
       {
-        foreach my $iter124 (@{$self->{fields}})
+        foreach my $iter115 (@{$self->{fields}})
         {
-          $xfer += $output->writeString($iter124);
+          $xfer += $output->writeString($iter115);
         }
       }
       $xfer += $output->writeSetEnd();
@@ -519,16 +519,16 @@ sub read {
     {
       /^0$/ && do{      if ($ftype == TType::LIST) {
         {
-          my $_size125 = 0;
+          my $_size116 = 0;
           $self->{success} = [];
-          my $_etype128 = 0;
-          $xfer += $input->readListBegin(\$_etype128, \$_size125);
-          for (my $_i129 = 0; $_i129 < $_size125; ++$_i129)
+          my $_etype119 = 0;
+          $xfer += $input->readListBegin(\$_etype119, \$_size116);
+          for (my $_i120 = 0; $_i120 < $_size116; ++$_i120)
           {
-            my $elem130 = undef;
-            $elem130 = new Blur::Document();
-            $xfer += $elem130->read($input);
-            push(@{$self->{success}},$elem130);
+            my $elem121 = undef;
+            $elem121 = new Blur::Document();
+            $xfer += $elem121->read($input);
+            push(@{$self->{success}},$elem121);
           }
           $xfer += $input->readListEnd();
         }
@@ -560,9 +560,9 @@ sub write {
     {
       $xfer += $output->writeListBegin(TType::STRUCT, scalar(@{$self->{success}}));
       {
-        foreach my $iter131 (@{$self->{success}}) 
+        foreach my $iter122 (@{$self->{success}}) 
         {
-          $xfer += ${iter131}->write($output);
+          $xfer += ${iter122}->write($output);
         }
       }
       $xfer += $output->writeListEnd();
@@ -758,16 +758,16 @@ sub read {
       last; };
       /^2$/ && do{      if ($ftype == TType::LIST) {
         {
-          my $_size132 = 0;
+          my $_size123 = 0;
           $self->{documents} = [];
-          my $_etype135 = 0;
-          $xfer += $input->readListBegin(\$_etype135, \$_size132);
-          for (my $_i136 = 0; $_i136 < $_size132; ++$_i136)
+          my $_etype126 = 0;
+          $xfer += $input->readListBegin(\$_etype126, \$_size123);
+          for (my $_i127 = 0; $_i127 < $_size123; ++$_i127)
           {
-            my $elem137 = undef;
-            $elem137 = new Blur::Document();
-            $xfer += $elem137->read($input);
-            push(@{$self->{documents}},$elem137);
+            my $elem128 = undef;
+            $elem128 = new Blur::Document();
+            $xfer += $elem128->read($input);
+            push(@{$self->{documents}},$elem128);
           }
           $xfer += $input->readListEnd();
         }
@@ -797,9 +797,9 @@ sub write {
     {
       $xfer += $output->writeListBegin(TType::STRUCT, scalar(@{$self->{documents}}));
       {
-        foreach my $iter138 (@{$self->{documents}}) 
+        foreach my $iter129 (@{$self->{documents}}) 
         {
-          $xfer += ${iter138}->write($output);
+          $xfer += ${iter129}->write($output);
         }
       }
       $xfer += $output->writeListEnd();
@@ -853,16 +853,16 @@ sub read {
     {
       /^0$/ && do{      if ($ftype == TType::LIST) {
         {
-          my $_size139 = 0;
+          my $_size130 = 0;
           $self->{success} = [];
-          my $_etype142 = 0;
-          $xfer += $input->readListBegin(\$_etype142, \$_size139);
-          for (my $_i143 = 0; $_i143 < $_size139; ++$_i143)
+          my $_etype133 = 0;
+          $xfer += $input->readListBegin(\$_etype133, \$_size130);
+          for (my $_i134 = 0; $_i134 < $_size130; ++$_i134)
           {
-            my $elem144 = undef;
-            $elem144 = new Blur::Generation();
-            $xfer += $elem144->read($input);
-            push(@{$self->{success}},$elem144);
+            my $elem135 = undef;
+            $elem135 = new Blur::Generation();
+            $xfer += $elem135->read($input);
+            push(@{$self->{success}},$elem135);
           }
           $xfer += $input->readListEnd();
         }
@@ -894,9 +894,9 @@ sub write {
     {
       $xfer += $output->writeListBegin(TType::STRUCT, scalar(@{$self->{success}}));
       {
-        foreach my $iter145 (@{$self->{success}}) 
+        foreach my $iter136 (@{$self->{success}}) 
         {
-          $xfer += ${iter145}->write($output);
+          $xfer += ${iter136}->write($output);
         }
       }
       $xfer += $output->writeListEnd();
@@ -962,16 +962,16 @@ sub read {
       last; };
       /^2$/ && do{      if ($ftype == TType::LIST) {
         {
-          my $_size146 = 0;
+          my $_size137 = 0;
           $self->{queries} = [];
-          my $_etype149 = 0;
-          $xfer += $input->readListBegin(\$_etype149, \$_size146);
-          for (my $_i150 = 0; $_i150 < $_size146; ++$_i150)
+          my $_etype140 = 0;
+          $xfer += $input->readListBegin(\$_etype140, \$_size137);
+          for (my $_i141 = 0; $_i141 < $_size137; ++$_i141)
           {
-            my $elem151 = undef;
-            $elem151 = new Blur::Query();
-            $xfer += $elem151->read($input);
-            push(@{$self->{queries}},$elem151);
+            my $elem142 = undef;
+            $elem142 = new Blur::Query();
+            $xfer += $elem142->read($input);
+            push(@{$self->{queries}},$elem142);
           }
           $xfer += $input->readListEnd();
         }
@@ -1001,9 +1001,9 @@ sub write {
     {
       $xfer += $output->writeListBegin(TType::STRUCT, scalar(@{$self->{queries}}));
       {
-        foreach my $iter152 (@{$self->{queries}}) 
+        foreach my $iter143 (@{$self->{queries}}) 
         {
-          $xfer += ${iter152}->write($output);
+          $xfer += ${iter143}->write($output);
         }
       }
       $xfer += $output->writeListEnd();
@@ -1057,16 +1057,16 @@ sub read {
     {
       /^0$/ && do{      if ($ftype == TType::LIST) {
         {
-          my $_size153 = 0;
+          my $_size144 = 0;
           $self->{success} = [];
-          my $_etype156 = 0;
-          $xfer += $input->readListBegin(\$_etype156, \$_size153);
-          for (my $_i157 = 0; $_i157 < $_size153; ++$_i157)
+          my $_etype147 = 0;
+          $xfer += $input->readListBegin(\$_etype147, \$_size144);
+          for (my $_i148 = 0; $_i148 < $_size144; ++$_i148)
           {
-            my $elem158 = undef;
-            $elem158 = new Blur::Generation();
-            $xfer += $elem158->read($input);
-            push(@{$self->{success}},$elem158);
+            my $elem149 = undef;
+            $elem149 = new Blur::Generation();
+            $xfer += $elem149->read($input);
+            push(@{$self->{success}},$elem149);
           }
           $xfer += $input->readListEnd();
         }
@@ -1098,9 +1098,9 @@ sub write {
     {
       $xfer += $output->writeListBegin(TType::STRUCT, scalar(@{$self->{success}}));
       {
-        foreach my $iter159 (@{$self->{success}}) 
+        foreach my $iter150 (@{$self->{success}}) 
         {
-          $xfer += ${iter159}->write($output);
+          $xfer += ${iter150}->write($output);
         }
       }
       $xfer += $output->writeListEnd();
@@ -1166,16 +1166,16 @@ sub read {
       last; };
       /^2$/ && do{      if ($ftype == TType::LIST) {
         {
-          my $_size160 = 0;
+          my $_size151 = 0;
           $self->{terms} = [];
-          my $_etype163 = 0;
-          $xfer += $input->readListBegin(\$_etype163, \$_size160);
-          for (my $_i164 = 0; $_i164 < $_size160; ++$_i164)
+          my $_etype154 = 0;
+          $xfer += $input->readListBegin(\$_etype154, \$_size151);
+          for (my $_i155 = 0; $_i155 < $_size151; ++$_i155)
           {
-            my $elem165 = undef;
-            $elem165 = new Blur::Term();
-            $xfer += $elem165->read($input);
-            push(@{$self->{terms}},$elem165);
+            my $elem156 = undef;
+            $elem156 = new Blur::Term();
+            $xfer += $elem156->read($input);
+            push(@{$self->{terms}},$elem156);
           }
           $xfer += $input->readListEnd();
         }
@@ -1205,9 +1205,9 @@ sub write {
     {
       $xfer += $output->writeListBegin(TType::STRUCT, scalar(@{$self->{terms}}));
       {
-        foreach my $iter166 (@{$self->{terms}}) 
+        foreach my $iter157 (@{$self->{terms}}) 
         {
-          $xfer += ${iter166}->write($output);
+          $xfer += ${iter157}->write($output);
         }
       }
       $xfer += $output->writeListEnd();
@@ -1261,16 +1261,16 @@ sub read {
     {
       /^0$/ && do{      if ($ftype == TType::LIST) {
         {
-          my $_size167 = 0;
+          my $_size158 = 0;
           $self->{success} = [];
-          my $_etype170 = 0;
-          $xfer += $input->readListBegin(\$_etype170, \$_size167);
-          for (my $_i171 = 0; $_i171 < $_size167; ++$_i171)
+          my $_etype161 = 0;
+          $xfer += $input->readListBegin(\$_etype161, \$_size158);
+          for (my $_i162 = 0; $_i162 < $_size158; ++$_i162)
           {
-            my $elem172 = undef;
-            $elem172 = new Blur::Generation();
-            $xfer += $elem172->read($input);
-            push(@{$self->{success}},$elem172);
+            my $elem163 = undef;
+            $elem163 = new Blur::Generation();
+            $xfer += $elem163->read($input);
+            push(@{$self->{success}},$elem163);
           }
           $xfer += $input->readListEnd();
         }
@@ -1302,9 +1302,9 @@ sub write {
     {
       $xfer += $output->writeListBegin(TType::STRUCT, scalar(@{$self->{success}}));
       {
-        foreach my $iter173 (@{$self->{success}}) 
+        foreach my $iter164 (@{$self->{success}}) 
         {
-          $xfer += ${iter173}->write($output);
+          $xfer += ${iter164}->write($output);
         }
       }
       $xfer += $output->writeListEnd();
@@ -1370,16 +1370,16 @@ sub read {
       last; };
       /^2$/ && do{      if ($ftype == TType::LIST) {
         {
-          my $_size174 = 0;
+          my $_size165 = 0;
           $self->{updatePackages} = [];
-          my $_etype177 = 0;
-          $xfer += $input->readListBegin(\$_etype177, \$_size174);
-          for (my $_i178 = 0; $_i178 < $_size174; ++$_i178)
+          my $_etype168 = 0;
+          $xfer += $input->readListBegin(\$_etype168, \$_size165);
+          for (my $_i169 = 0; $_i169 < $_size165; ++$_i169)
           {
-            my $elem179 = undef;
-            $elem179 = new Blur::UpdatePackage();
-            $xfer += $elem179->read($input);
-            push(@{$self->{updatePackages}},$elem179);
+            my $elem170 = undef;
+            $elem170 = new Blur::UpdatePackage();
+            $xfer += $elem170->read($input);
+            push(@{$self->{updatePackages}},$elem170);
           }
           $xfer += $input->readListEnd();
         }
@@ -1409,9 +1409,9 @@ sub write {
     {
       $xfer += $output->writeListBegin(TType::STRUCT, scalar(@{$self->{updatePackages}}));
       {
-        foreach my $iter180 (@{$self->{updatePackages}}) 
+        foreach my $iter171 (@{$self->{updatePackages}}) 
         {
-          $xfer += ${iter180}->write($output);
+          $xfer += ${iter171}->write($output);
         }
       }
       $xfer += $output->writeListEnd();
@@ -1465,16 +1465,16 @@ sub read {
     {
       /^0$/ && do{      if ($ftype == TType::LIST) {
         {
-          my $_size181 = 0;
+          my $_size172 = 0;
           $self->{success} = [];
-          my $_etype184 = 0;
-          $xfer += $input->readListBegin(\$_etype184, \$_size181);
-          for (my $_i185 = 0; $_i185 < $_size181; ++$_i185)
+          my $_etype175 = 0;
+          $xfer += $input->readListBegin(\$_etype175, \$_size172);
+          for (my $_i176 = 0; $_i176 < $_size172; ++$_i176)
           {
-            my $elem186 = undef;
-            $elem186 = new Blur::Generation();
-            $xfer += $elem186->read($input);
-            push(@{$self->{success}},$elem186);
+            my $elem177 = undef;
+            $elem177 = new Blur::Generation();
+            $xfer += $elem177->read($input);
+            push(@{$self->{success}},$elem177);
           }
           $xfer += $input->readListEnd();
         }
@@ -1506,9 +1506,9 @@ sub write {
     {
       $xfer += $output->writeListBegin(TType::STRUCT, scalar(@{$self->{success}}));
       {
-        foreach my $iter187 (@{$self->{success}}) 
+        foreach my $iter178 (@{$self->{success}}) 
         {
-          $xfer += ${iter187}->write($output);
+          $xfer += ${iter178}->write($output);
         }
       }
       $xfer += $output->writeListEnd();
@@ -1567,16 +1567,16 @@ sub read {
     {
       /^1$/ && do{      if ($ftype == TType::LIST) {
         {
-          my $_size188 = 0;
+          my $_size179 = 0;
           $self->{generations} = [];
-          my $_etype191 = 0;
-          $xfer += $input->readListBegin(\$_etype191, \$_size188);
-          for (my $_i192 = 0; $_i192 < $_size188; ++$_i192)
+          my $_etype182 = 0;
+          $xfer += $input->readListBegin(\$_etype182, \$_size179);
+          for (my $_i183 = 0; $_i183 < $_size179; ++$_i183)
           {
-            my $elem193 = undef;
-            $elem193 = new Blur::Generation();
-            $xfer += $elem193->read($input);
-            push(@{$self->{generations}},$elem193);
+            my $elem184 = undef;
+            $elem184 = new Blur::Generation();
+            $xfer += $elem184->read($input);
+            push(@{$self->{generations}},$elem184);
           }
           $xfer += $input->readListEnd();
         }
@@ -1607,9 +1607,9 @@ sub write {
     {
       $xfer += $output->writeListBegin(TType::STRUCT, scalar(@{$self->{generations}}));
       {
-        foreach my $iter194 (@{$self->{generations}}) 
+        foreach my $iter185 (@{$self->{generations}}) 
         {
-          $xfer += ${iter194}->write($output);
+          $xfer += ${iter185}->write($output);
         }
       }
       $xfer += $output->writeListEnd();
@@ -1779,15 +1779,15 @@ sub read {
     {
       /^0$/ && do{      if ($ftype == TType::LIST) {
         {
-          my $_size195 = 0;
+          my $_size186 = 0;
           $self->{success} = [];
-          my $_etype198 = 0;
-          $xfer += $input->readListBegin(\$_etype198, \$_size195);
-          for (my $_i199 = 0; $_i199 < $_size195; ++$_i199)
+          my $_etype189 = 0;
+          $xfer += $input->readListBegin(\$_etype189, \$_size186);
+          for (my $_i190 = 0; $_i190 < $_size186; ++$_i190)
           {
-            my $elem200 = undef;
-            $xfer += $input->readString(\$elem200);
-            push(@{$self->{success}},$elem200);
+            my $elem191 = undef;
+            $xfer += $input->readString(\$elem191);
+            push(@{$self->{success}},$elem191);
           }
           $xfer += $input->readListEnd();
         }
@@ -1819,9 +1819,9 @@ sub write {
     {
       $xfer += $output->writeListBegin(TType::STRING, scalar(@{$self->{success}}));
       {
-        foreach my $iter201 (@{$self->{success}}) 
+        foreach my $iter192 (@{$self->{success}}) 
         {
-          $xfer += $output->writeString($iter201);
+          $xfer += $output->writeString($iter192);
         }
       }
       $xfer += $output->writeListEnd();
@@ -1959,15 +1959,15 @@ sub read {
     {
       /^0$/ && do{      if ($ftype == TType::LIST) {
         {
-          my $_size202 = 0;
+          my $_size193 = 0;
           $self->{success} = [];
-          my $_etype205 = 0;
-          $xfer += $input->readListBegin(\$_etype205, \$_size202);
-          for (my $_i206 = 0; $_i206 < $_size202; ++$_i206)
+          my $_etype196 = 0;
+          $xfer += $input->readListBegin(\$_etype196, \$_size193);
+          for (my $_i197 = 0; $_i197 < $_size193; ++$_i197)
           {
-            my $elem207 = undef;
-            $xfer += $input->readI32(\$elem207);
-            push(@{$self->{success}},$elem207);
+            my $elem198 = undef;
+            $xfer += $input->readI32(\$elem198);
+            push(@{$self->{success}},$elem198);
           }
           $xfer += $input->readListEnd();
         }
@@ -1999,9 +1999,9 @@ sub write {
     {
       $xfer += $output->writeListBegin(TType::I32, scalar(@{$self->{success}}));
       {
-        foreach my $iter208 (@{$self->{success}}) 
+        foreach my $iter199 (@{$self->{success}}) 
         {
-          $xfer += $output->writeI32($iter208);
+          $xfer += $output->writeI32($iter199);
         }
       }
       $xfer += $output->writeListEnd();
@@ -2124,19 +2124,19 @@ sub read {
     {
       /^0$/ && do{      if ($ftype == TType::MAP) {
         {
-          my $_size209 = 0;
+          my $_size200 = 0;
           $self->{success} = {};
-          my $_ktype210 = 0;
-          my $_vtype211 = 0;
-          $xfer += $input->readMapBegin(\$_ktype210, \$_vtype211, \$_size209);
-          for (my $_i213 = 0; $_i213 < $_size209; ++$_i213)
+          my $_ktype201 = 0;
+          my $_vtype202 = 0;
+          $xfer += $input->readMapBegin(\$_ktype201, \$_vtype202, \$_size200);
+          for (my $_i204 = 0; $_i204 < $_size200; ++$_i204)
           {
-            my $key214 = '';
-            my $val215 = new Blur::ShardLayout();
-            $xfer += $input->readString(\$key214);
-            $val215 = new Blur::ShardLayout();
-            $xfer += $val215->read($input);
-            $self->{success}->{$key214} = $val215;
+            my $key205 = '';
+            my $val206 = new Blur::ShardLayout();
+            $xfer += $input->readString(\$key205);
+            $val206 = new Blur::ShardLayout();
+            $xfer += $val206->read($input);
+            $self->{success}->{$key205} = $val206;
           }
           $xfer += $input->readMapEnd();
         }
@@ -2168,10 +2168,10 @@ sub write {
     {
       $xfer += $output->writeMapBegin(TType::STRING, TType::STRUCT, scalar(keys %{$self->{success}}));
       {
-        while( my ($kiter216,$viter217) = each %{$self->{success}}) 
+        while( my ($kiter207,$viter208) = each %{$self->{success}}) 
         {
-          $xfer += $output->writeString($kiter216);
-          $xfer += ${viter217}->write($output);
+          $xfer += $output->writeString($kiter207);
+          $xfer += ${viter208}->write($output);
         }
       }
       $xfer += $output->writeMapEnd();
@@ -2276,15 +2276,15 @@ sub read {
     {
       /^0$/ && do{      if ($ftype == TType::LIST) {
         {
-          my $_size218 = 0;
+          my $_size209 = 0;
           $self->{success} = [];
-          my $_etype221 = 0;
-          $xfer += $input->readListBegin(\$_etype221, \$_size218);
-          for (my $_i222 = 0; $_i222 < $_size218; ++$_i222)
+          my $_etype212 = 0;
+          $xfer += $input->readListBegin(\$_etype212, \$_size209);
+          for (my $_i213 = 0; $_i213 < $_size209; ++$_i213)
           {
-            my $elem223 = undef;
-            $xfer += $input->readString(\$elem223);
-            push(@{$self->{success}},$elem223);
+            my $elem214 = undef;
+            $xfer += $input->readString(\$elem214);
+            push(@{$self->{success}},$elem214);
           }
           $xfer += $input->readListEnd();
         }
@@ -2316,9 +2316,9 @@ sub write {
     {
       $xfer += $output->writeListBegin(TType::STRING, scalar(@{$self->{success}}));
       {
-        foreach my $iter224 (@{$self->{success}}) 
+        foreach my $iter215 (@{$self->{success}}) 
         {
-          $xfer += $output->writeString($iter224);
+          $xfer += $output->writeString($iter215);
         }
       }
       $xfer += $output->writeListEnd();
@@ -3140,18 +3140,22 @@ sub write {
 
 package Blur::Blur_cancelQuery_args;
 use base qw(Class::Accessor);
-Blur::Blur_cancelQuery_args->mk_accessors( qw( session id ) );
+Blur::Blur_cancelQuery_args->mk_accessors( qw( session server id ) );
 
 sub new {
   my $classname = shift;
   my $self      = {};
   my $vals      = shift || {};
   $self->{session} = undef;
+  $self->{server} = undef;
   $self->{id} = undef;
   if (UNIVERSAL::isa($vals,'HASH')) {
     if (defined $vals->{session}) {
       $self->{session} = $vals->{session};
     }
+    if (defined $vals->{server}) {
+      $self->{server} = $vals->{server};
+    }
     if (defined $vals->{id}) {
       $self->{id} = $vals->{id};
     }
@@ -3185,8 +3189,14 @@ sub read {
         $xfer += $input->skip($ftype);
       }
       last; };
-      /^2$/ && do{      if ($ftype == TType::I64) {
-        $xfer += $input->readI64(\$self->{id});
+      /^2$/ && do{      if ($ftype == TType::STRING) {
+        $xfer += $input->readString(\$self->{server});
+      } else {
+        $xfer += $input->skip($ftype);
+      }
+      last; };
+      /^3$/ && do{      if ($ftype == TType::STRING) {
+        $xfer += $input->readString(\$self->{id});
       } else {
         $xfer += $input->skip($ftype);
       }
@@ -3208,9 +3218,14 @@ sub write {
     $xfer += $self->{session}->write($output);
     $xfer += $output->writeFieldEnd();
   }
+  if (defined $self->{server}) {
+    $xfer += $output->writeFieldBegin('server', TType::STRING, 2);
+    $xfer += $output->writeString($self->{server});
+    $xfer += $output->writeFieldEnd();
+  }
   if (defined $self->{id}) {
-    $xfer += $output->writeFieldBegin('id', TType::I64, 2);
-    $xfer += $output->writeI64($self->{id});
+    $xfer += $output->writeFieldBegin('id', TType::STRING, 3);
+    $xfer += $output->writeString($self->{id});
     $xfer += $output->writeFieldEnd();
   }
   $xfer += $output->writeFieldStop();
@@ -3285,17 +3300,21 @@ sub write {
 
 package Blur::Blur_queryStatusIdList_args;
 use base qw(Class::Accessor);
-Blur::Blur_queryStatusIdList_args->mk_accessors( qw( session ) );
+Blur::Blur_queryStatusIdList_args->mk_accessors( qw( session server ) );
 
 sub new {
   my $classname = shift;
   my $self      = {};
   my $vals      = shift || {};
   $self->{session} = undef;
+  $self->{server} = undef;
   if (UNIVERSAL::isa($vals,'HASH')) {
     if (defined $vals->{session}) {
       $self->{session} = $vals->{session};
     }
+    if (defined $vals->{server}) {
+      $self->{server} = $vals->{server};
+    }
   }
   return bless ($self, $classname);
 }
@@ -3326,6 +3345,12 @@ sub read {
         $xfer += $input->skip($ftype);
       }
       last; };
+      /^2$/ && do{      if ($ftype == TType::STRING) {
+        $xfer += $input->readString(\$self->{server});
+      } else {
+        $xfer += $input->skip($ftype);
+      }
+      last; };
         $xfer += $input->skip($ftype);
     }
     $xfer += $input->readFieldEnd();
@@ -3343,6 +3368,11 @@ sub write {
     $xfer += $self->{session}->write($output);
     $xfer += $output->writeFieldEnd();
   }
+  if (defined $self->{server}) {
+    $xfer += $output->writeFieldBegin('server', TType::STRING, 2);
+    $xfer += $output->writeString($self->{server});
+    $xfer += $output->writeFieldEnd();
+  }
   $xfer += $output->writeFieldStop();
   $xfer += $output->writeStructEnd();
   return $xfer;
@@ -3388,19 +3418,34 @@ sub read {
     }
     SWITCH: for($fid)
     {
-      /^0$/ && do{      if ($ftype == TType::LIST) {
+      /^0$/ && do{      if ($ftype == TType::MAP) {
         {
-          my $_size225 = 0;
-          $self->{success} = [];
-          my $_etype228 = 0;
-          $xfer += $input->readListBegin(\$_etype228, \$_size225);
-          for (my $_i229 = 0; $_i229 < $_size225; ++$_i229)
+          my $_size216 = 0;
+          $self->{success} = {};
+          my $_ktype217 = 0;
+          my $_vtype218 = 0;
+          $xfer += $input->readMapBegin(\$_ktype217, \$_vtype218, \$_size216);
+          for (my $_i220 = 0; $_i220 < $_size216; ++$_i220)
           {
-            my $elem230 = undef;
-            $xfer += $input->readI64(\$elem230);
-            push(@{$self->{success}},$elem230);
+            my $key221 = '';
+            my $val222 = [];
+            $xfer += $input->readString(\$key221);
+            {
+              my $_size223 = 0;
+              $val222 = [];
+              my $_etype226 = 0;
+              $xfer += $input->readListBegin(\$_etype226, \$_size223);
+              for (my $_i227 = 0; $_i227 < $_size223; ++$_i227)
+              {
+                my $elem228 = undef;
+                $xfer += $input->readString(\$elem228);
+                push(@{$val222},$elem228);
+              }
+              $xfer += $input->readListEnd();
+            }
+            $self->{success}->{$key221} = $val222;
           }
-          $xfer += $input->readListEnd();
+          $xfer += $input->readMapEnd();
         }
       } else {
         $xfer += $input->skip($ftype);
@@ -3426,16 +3471,26 @@ sub write {
   my $xfer   = 0;
   $xfer += $output->writeStructBegin('Blur_queryStatusIdList_result');
   if (defined $self->{success}) {
-    $xfer += $output->writeFieldBegin('success', TType::LIST, 0);
+    $xfer += $output->writeFieldBegin('success', TType::MAP, 0);
     {
-      $xfer += $output->writeListBegin(TType::I64, scalar(@{$self->{success}}));
+      $xfer += $output->writeMapBegin(TType::STRING, TType::LIST, scalar(keys %{$self->{success}}));
       {
-        foreach my $iter231 (@{$self->{success}}) 
+        while( my ($kiter229,$viter230) = each %{$self->{success}}) 
         {
-          $xfer += $output->writeI64($iter231);
+          $xfer += $output->writeString($kiter229);
+          {
+            $xfer += $output->writeListBegin(TType::STRING, scalar(@{${viter230}}));
+            {
+              foreach my $iter231 (@{${viter230}}) 
+              {
+                $xfer += $output->writeString($iter231);
+              }
+            }
+            $xfer += $output->writeListEnd();
+          }
         }
       }
-      $xfer += $output->writeListEnd();
+      $xfer += $output->writeMapEnd();
     }
     $xfer += $output->writeFieldEnd();
   }
@@ -3451,18 +3506,22 @@ sub write {
 
 package Blur::Blur_queryStatus_args;
 use base qw(Class::Accessor);
-Blur::Blur_queryStatus_args->mk_accessors( qw( session id ) );
+Blur::Blur_queryStatus_args->mk_accessors( qw( session server id ) );
 
 sub new {
   my $classname = shift;
   my $self      = {};
   my $vals      = shift || {};
   $self->{session} = undef;
+  $self->{server} = undef;
   $self->{id} = undef;
   if (UNIVERSAL::isa($vals,'HASH')) {
     if (defined $vals->{session}) {
       $self->{session} = $vals->{session};
     }
+    if (defined $vals->{server}) {
+      $self->{server} = $vals->{server};
+    }
     if (defined $vals->{id}) {
       $self->{id} = $vals->{id};
     }
@@ -3496,8 +3555,14 @@ sub read {
         $xfer += $input->skip($ftype);
       }
       last; };
-      /^2$/ && do{      if ($ftype == TType::I64) {
-        $xfer += $input->readI64(\$self->{id});
+      /^2$/ && do{      if ($ftype == TType::STRING) {
+        $xfer += $input->readString(\$self->{server});
+      } else {
+        $xfer += $input->skip($ftype);
+      }
+      last; };
+      /^3$/ && do{      if ($ftype == TType::STRING) {
+        $xfer += $input->readString(\$self->{id});
       } else {
         $xfer += $input->skip($ftype);
       }
@@ -3519,9 +3584,14 @@ sub write {
     $xfer += $self->{session}->write($output);
     $xfer += $output->writeFieldEnd();
   }
+  if (defined $self->{server}) {
+    $xfer += $output->writeFieldBegin('server', TType::STRING, 2);
+    $xfer += $output->writeString($self->{server});
+    $xfer += $output->writeFieldEnd();
+  }
   if (defined $self->{id}) {
-    $xfer += $output->writeFieldBegin('id', TType::I64, 2);
-    $xfer += $output->writeI64($self->{id});
+    $xfer += $output->writeFieldBegin('id', TType::STRING, 3);
+    $xfer += $output->writeString($self->{id});
     $xfer += $output->writeFieldEnd();
   }
   $xfer += $output->writeFieldStop();
@@ -3569,9 +3639,24 @@ sub read {
     }
     SWITCH: for($fid)
     {
-      /^0$/ && do{      if ($ftype == TType::STRUCT) {
-        $self->{success} = new Blur::QueryStatus();
-        $xfer += $self->{success}->read($input);
+      /^0$/ && do{      if ($ftype == TType::MAP) {
+        {
+          my $_size232 = 0;
+          $self->{success} = {};
+          my $_ktype233 = 0;
+          my $_vtype234 = 0;
+          $xfer += $input->readMapBegin(\$_ktype233, \$_vtype234, \$_size232);
+          for (my $_i236 = 0; $_i236 < $_size232; ++$_i236)
+          {
+            my $key237 = '';
+            my $val238 = new Blur::QueryStatus();
+            $xfer += $input->readString(\$key237);
+            $val238 = new Blur::QueryStatus();
+            $xfer += $val238->read($input);
+            $self->{success}->{$key237} = $val238;
+          }
+          $xfer += $input->readMapEnd();
+        }
       } else {
         $xfer += $input->skip($ftype);
       }
@@ -3596,8 +3681,18 @@ sub write {
   my $xfer   = 0;
   $xfer += $output->writeStructBegin('Blur_queryStatus_result');
   if (defined $self->{success}) {
-    $xfer += $output->writeFieldBegin('success', TType::STRUCT, 0);
-    $xfer += $self->{success}->write($output);
+    $xfer += $output->writeFieldBegin('success', TType::MAP, 0);
+    {
+      $xfer += $output->writeMapBegin(TType::STRING, TType::STRUCT, scalar(keys %{$self->{success}}));
+      {
+        while( my ($kiter239,$viter240) = each %{$self->{success}}) 
+        {
+          $xfer += $output->writeString($kiter239);
+          $xfer += ${viter240}->write($output);
+        }
+      }
+      $xfer += $output->writeMapEnd();
+    }
     $xfer += $output->writeFieldEnd();
   }
   if (defined $self->{ex}) {
@@ -4049,6 +4144,7 @@ sub describe{
 sub cancelQuery{
   my $self = shift;
   my $session = shift;
+  my $server = shift;
   my $id = shift;
 
   die 'implement interface';
@@ -4057,6 +4153,7 @@ sub cancelQuery{
 sub queryStatusIdList{
   my $self = shift;
   my $session = shift;
+  my $server = shift;
 
   die 'implement interface';
 }
@@ -4064,6 +4161,7 @@ sub queryStatusIdList{
 sub queryStatus{
   my $self = shift;
   my $session = shift;
+  my $server = shift;
   my $id = shift;
 
   die 'implement interface';
@@ -4239,23 +4337,26 @@ sub cancelQuery{
   my ($self, $request) = @_;
 
   my $session = ($request->{'session'}) ? $request->{'session'} : undef;
+  my $server = ($request->{'server'}) ? $request->{'server'} : undef;
   my $id = ($request->{'id'}) ? $request->{'id'} : undef;
-  return $self->{impl}->cancelQuery($session, $id);
+  return $self->{impl}->cancelQuery($session, $server, $id);
 }
 
 sub queryStatusIdList{
   my ($self, $request) = @_;
 
   my $session = ($request->{'session'}) ? $request->{'session'} : undef;
-  return $self->{impl}->queryStatusIdList($session);
+  my $server = ($request->{'server'}) ? $request->{'server'} : undef;
+  return $self->{impl}->queryStatusIdList($session, $server);
 }
 
 sub queryStatus{
   my ($self, $request) = @_;
 
   my $session = ($request->{'session'}) ? $request->{'session'} : undef;
+  my $server = ($request->{'server'}) ? $request->{'server'} : undef;
   my $id = ($request->{'id'}) ? $request->{'id'} : undef;
-  return $self->{impl}->queryStatus($session, $id);
+  return $self->{impl}->queryStatus($session, $server, $id);
 }
 
 sub schema{
@@ -5165,20 +5266,23 @@ sub recv_describe{
 sub cancelQuery{
   my $self = shift;
   my $session = shift;
+  my $server = shift;
   my $id = shift;
 
-    $self->send_cancelQuery($session, $id);
+    $self->send_cancelQuery($session, $server, $id);
   $self->recv_cancelQuery();
 }
 
 sub send_cancelQuery{
   my $self = shift;
   my $session = shift;
+  my $server = shift;
   my $id = shift;
 
   $self->{output}->writeMessageBegin('cancelQuery', TMessageType::CALL, $self->{seqid});
   my $args = new Blur::Blur_cancelQuery_args();
   $args->{session} = $session;
+  $args->{server} = $server;
   $args->{id} = $id;
   $args->write($self->{output});
   $self->{output}->writeMessageEnd();
@@ -5211,18 +5315,21 @@ sub recv_cancelQuery{
 sub queryStatusIdList{
   my $self = shift;
   my $session = shift;
+  my $server = shift;
 
-    $self->send_queryStatusIdList($session);
+    $self->send_queryStatusIdList($session, $server);
   return $self->recv_queryStatusIdList();
 }
 
 sub send_queryStatusIdList{
   my $self = shift;
   my $session = shift;
+  my $server = shift;
 
   $self->{output}->writeMessageBegin('queryStatusIdList', TMessageType::CALL, $self->{seqid});
   my $args = new Blur::Blur_queryStatusIdList_args();
   $args->{session} = $session;
+  $args->{server} = $server;
   $args->write($self->{output});
   $self->{output}->writeMessageEnd();
   $self->{output}->getTransport()->flush();
@@ -5257,20 +5364,23 @@ sub recv_queryStatusIdList{
 sub queryStatus{
   my $self = shift;
   my $session = shift;
+  my $server = shift;
   my $id = shift;
 
-    $self->send_queryStatus($session, $id);
+    $self->send_queryStatus($session, $server, $id);
   return $self->recv_queryStatus();
 }
 
 sub send_queryStatus{
   my $self = shift;
   my $session = shift;
+  my $server = shift;
   my $id = shift;
 
   $self->{output}->writeMessageBegin('queryStatus', TMessageType::CALL, $self->{seqid});
   my $args = new Blur::Blur_queryStatus_args();
   $args->{session} = $session;
+  $args->{server} = $server;
   $args->{id} = $id;
   $args->write($self->{output});
   $self->{output}->writeMessageEnd();
@@ -5759,7 +5869,7 @@ sub process_cancelQuery {
     $input->readMessageEnd();
     my $result = new Blur::Blur_cancelQuery_result();
     eval {
-      $self->{handler}->cancelQuery($args->session, $args->id);
+      $self->{handler}->cancelQuery($args->session, $args->server, $args->id);
     }; if( UNIVERSAL::isa($@,'Blur::BlurException') ){ 
       $result->{ex} = $@;
     }
@@ -5776,7 +5886,7 @@ sub process_queryStatusIdList {
     $input->readMessageEnd();
     my $result = new Blur::Blur_queryStatusIdList_result();
     eval {
-      $result->{success} = $self->{handler}->queryStatusIdList($args->session);
+      $result->{success} = $self->{handler}->queryStatusIdList($args->session, $args->server);
     }; if( UNIVERSAL::isa($@,'Blur::BlurException') ){ 
       $result->{ex} = $@;
     }
@@ -5793,7 +5903,7 @@ sub process_queryStatus {
     $input->readMessageEnd();
     my $result = new Blur::Blur_queryStatus_result();
     eval {
-      $result->{success} = $self->{handler}->queryStatus($args->session, $args->id);
+      $result->{success} = $self->{handler}->queryStatus($args->session, $args->server, $args->id);
     }; if( UNIVERSAL::isa($@,'Blur::BlurException') ){ 
       $result->{ex} = $@;
     }

http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/a2585810/src/distribution/src/main/scripts/interface/gen-perl/Blur/Types.pm
----------------------------------------------------------------------
diff --git a/src/distribution/src/main/scripts/interface/gen-perl/Blur/Types.pm b/src/distribution/src/main/scripts/interface/gen-perl/Blur/Types.pm
index 7474d7c..bb63f19 100644
--- a/src/distribution/src/main/scripts/interface/gen-perl/Blur/Types.pm
+++ b/src/distribution/src/main/scripts/interface/gen-perl/Blur/Types.pm
@@ -116,220 +116,6 @@ sub write {
   return $xfer;
 }
 
-package Blur::CpuTime;
-use base qw(Class::Accessor);
-Blur::CpuTime->mk_accessors( qw( cpuTime realTime ) );
-
-sub new {
-  my $classname = shift;
-  my $self      = {};
-  my $vals      = shift || {};
-  $self->{cpuTime} = undef;
-  $self->{realTime} = undef;
-  if (UNIVERSAL::isa($vals,'HASH')) {
-    if (defined $vals->{cpuTime}) {
-      $self->{cpuTime} = $vals->{cpuTime};
-    }
-    if (defined $vals->{realTime}) {
-      $self->{realTime} = $vals->{realTime};
-    }
-  }
-  return bless ($self, $classname);
-}
-
-sub getName {
-  return 'CpuTime';
-}
-
-sub read {
-  my ($self, $input) = @_;
-  my $xfer  = 0;
-  my $fname;
-  my $ftype = 0;
-  my $fid   = 0;
-  $xfer += $input->readStructBegin(\$fname);
-  while (1) 
-  {
-    $xfer += $input->readFieldBegin(\$fname, \$ftype, \$fid);
-    if ($ftype == TType::STOP) {
-      last;
-    }
-    SWITCH: for($fid)
-    {
-      /^1$/ && do{      if ($ftype == TType::I64) {
-        $xfer += $input->readI64(\$self->{cpuTime});
-      } else {
-        $xfer += $input->skip($ftype);
-      }
-      last; };
-      /^2$/ && do{      if ($ftype == TType::I64) {
-        $xfer += $input->readI64(\$self->{realTime});
-      } else {
-        $xfer += $input->skip($ftype);
-      }
-      last; };
-        $xfer += $input->skip($ftype);
-    }
-    $xfer += $input->readFieldEnd();
-  }
-  $xfer += $input->readStructEnd();
-  return $xfer;
-}
-
-sub write {
-  my ($self, $output) = @_;
-  my $xfer   = 0;
-  $xfer += $output->writeStructBegin('CpuTime');
-  if (defined $self->{cpuTime}) {
-    $xfer += $output->writeFieldBegin('cpuTime', TType::I64, 1);
-    $xfer += $output->writeI64($self->{cpuTime});
-    $xfer += $output->writeFieldEnd();
-  }
-  if (defined $self->{realTime}) {
-    $xfer += $output->writeFieldBegin('realTime', TType::I64, 2);
-    $xfer += $output->writeI64($self->{realTime});
-    $xfer += $output->writeFieldEnd();
-  }
-  $xfer += $output->writeFieldStop();
-  $xfer += $output->writeStructEnd();
-  return $xfer;
-}
-
-package Blur::QueryStatus;
-use base qw(Class::Accessor);
-Blur::QueryStatus->mk_accessors( qw( cpuTimes completeShards totalShards state ) );
-
-sub new {
-  my $classname = shift;
-  my $self      = {};
-  my $vals      = shift || {};
-  $self->{cpuTimes} = undef;
-  $self->{completeShards} = undef;
-  $self->{totalShards} = undef;
-  $self->{state} = undef;
-  if (UNIVERSAL::isa($vals,'HASH')) {
-    if (defined $vals->{cpuTimes}) {
-      $self->{cpuTimes} = $vals->{cpuTimes};
-    }
-    if (defined $vals->{completeShards}) {
-      $self->{completeShards} = $vals->{completeShards};
-    }
-    if (defined $vals->{totalShards}) {
-      $self->{totalShards} = $vals->{totalShards};
-    }
-    if (defined $vals->{state}) {
-      $self->{state} = $vals->{state};
-    }
-  }
-  return bless ($self, $classname);
-}
-
-sub getName {
-  return 'QueryStatus';
-}
-
-sub read {
-  my ($self, $input) = @_;
-  my $xfer  = 0;
-  my $fname;
-  my $ftype = 0;
-  my $fid   = 0;
-  $xfer += $input->readStructBegin(\$fname);
-  while (1) 
-  {
-    $xfer += $input->readFieldBegin(\$fname, \$ftype, \$fid);
-    if ($ftype == TType::STOP) {
-      last;
-    }
-    SWITCH: for($fid)
-    {
-      /^1$/ && do{      if ($ftype == TType::MAP) {
-        {
-          my $_size0 = 0;
-          $self->{cpuTimes} = {};
-          my $_ktype1 = 0;
-          my $_vtype2 = 0;
-          $xfer += $input->readMapBegin(\$_ktype1, \$_vtype2, \$_size0);
-          for (my $_i4 = 0; $_i4 < $_size0; ++$_i4)
-          {
-            my $key5 = '';
-            my $val6 = new Blur::CpuTime();
-            $xfer += $input->readString(\$key5);
-            $val6 = new Blur::CpuTime();
-            $xfer += $val6->read($input);
-            $self->{cpuTimes}->{$key5} = $val6;
-          }
-          $xfer += $input->readMapEnd();
-        }
-      } else {
-        $xfer += $input->skip($ftype);
-      }
-      last; };
-      /^2$/ && do{      if ($ftype == TType::I32) {
-        $xfer += $input->readI32(\$self->{completeShards});
-      } else {
-        $xfer += $input->skip($ftype);
-      }
-      last; };
-      /^3$/ && do{      if ($ftype == TType::I32) {
-        $xfer += $input->readI32(\$self->{totalShards});
-      } else {
-        $xfer += $input->skip($ftype);
-      }
-      last; };
-      /^4$/ && do{      if ($ftype == TType::I32) {
-        $xfer += $input->readI32(\$self->{state});
-      } else {
-        $xfer += $input->skip($ftype);
-      }
-      last; };
-        $xfer += $input->skip($ftype);
-    }
-    $xfer += $input->readFieldEnd();
-  }
-  $xfer += $input->readStructEnd();
-  return $xfer;
-}
-
-sub write {
-  my ($self, $output) = @_;
-  my $xfer   = 0;
-  $xfer += $output->writeStructBegin('QueryStatus');
-  if (defined $self->{cpuTimes}) {
-    $xfer += $output->writeFieldBegin('cpuTimes', TType::MAP, 1);
-    {
-      $xfer += $output->writeMapBegin(TType::STRING, TType::STRUCT, scalar(keys %{$self->{cpuTimes}}));
-      {
-        while( my ($kiter7,$viter8) = each %{$self->{cpuTimes}}) 
-        {
-          $xfer += $output->writeString($kiter7);
-          $xfer += ${viter8}->write($output);
-        }
-      }
-      $xfer += $output->writeMapEnd();
-    }
-    $xfer += $output->writeFieldEnd();
-  }
-  if (defined $self->{completeShards}) {
-    $xfer += $output->writeFieldBegin('completeShards', TType::I32, 2);
-    $xfer += $output->writeI32($self->{completeShards});
-    $xfer += $output->writeFieldEnd();
-  }
-  if (defined $self->{totalShards}) {
-    $xfer += $output->writeFieldBegin('totalShards', TType::I32, 3);
-    $xfer += $output->writeI32($self->{totalShards});
-    $xfer += $output->writeFieldEnd();
-  }
-  if (defined $self->{state}) {
-    $xfer += $output->writeFieldBegin('state', TType::I32, 4);
-    $xfer += $output->writeI32($self->{state});
-    $xfer += $output->writeFieldEnd();
-  }
-  $xfer += $output->writeFieldStop();
-  $xfer += $output->writeStructEnd();
-  return $xfer;
-}
-
 package Blur::TableStats;
 use base qw(Class::Accessor);
 Blur::TableStats->mk_accessors( qw( bytes documentCount queries ) );
@@ -545,16 +331,16 @@ sub read {
     {
       /^1$/ && do{      if ($ftype == TType::LIST) {
         {
-          my $_size9 = 0;
+          my $_size0 = 0;
           $self->{fields} = [];
-          my $_etype12 = 0;
-          $xfer += $input->readListBegin(\$_etype12, \$_size9);
-          for (my $_i13 = 0; $_i13 < $_size9; ++$_i13)
+          my $_etype3 = 0;
+          $xfer += $input->readListBegin(\$_etype3, \$_size0);
+          for (my $_i4 = 0; $_i4 < $_size0; ++$_i4)
           {
-            my $elem14 = undef;
-            $elem14 = new Blur::FieldSchema();
-            $xfer += $elem14->read($input);
-            push(@{$self->{fields}},$elem14);
+            my $elem5 = undef;
+            $elem5 = new Blur::FieldSchema();
+            $xfer += $elem5->read($input);
+            push(@{$self->{fields}},$elem5);
           }
           $xfer += $input->readListEnd();
         }
@@ -585,9 +371,9 @@ sub write {
     {
       $xfer += $output->writeListBegin(TType::STRUCT, scalar(@{$self->{fields}}));
       {
-        foreach my $iter15 (@{$self->{fields}}) 
+        foreach my $iter6 (@{$self->{fields}}) 
         {
-          $xfer += ${iter15}->write($output);
+          $xfer += ${iter6}->write($output);
         }
       }
       $xfer += $output->writeListEnd();
@@ -652,18 +438,18 @@ sub read {
       last; };
       /^2$/ && do{      if ($ftype == TType::MAP) {
         {
-          my $_size16 = 0;
+          my $_size7 = 0;
           $self->{arguments} = {};
-          my $_ktype17 = 0;
-          my $_vtype18 = 0;
-          $xfer += $input->readMapBegin(\$_ktype17, \$_vtype18, \$_size16);
-          for (my $_i20 = 0; $_i20 < $_size16; ++$_i20)
+          my $_ktype8 = 0;
+          my $_vtype9 = 0;
+          $xfer += $input->readMapBegin(\$_ktype8, \$_vtype9, \$_size7);
+          for (my $_i11 = 0; $_i11 < $_size7; ++$_i11)
           {
-            my $key21 = '';
-            my $val22 = '';
-            $xfer += $input->readString(\$key21);
-            $xfer += $input->readString(\$val22);
-            $self->{arguments}->{$key21} = $val22;
+            my $key12 = '';
+            my $val13 = '';
+            $xfer += $input->readString(\$key12);
+            $xfer += $input->readString(\$val13);
+            $self->{arguments}->{$key12} = $val13;
           }
           $xfer += $input->readMapEnd();
         }
@@ -693,10 +479,10 @@ sub write {
     {
       $xfer += $output->writeMapBegin(TType::STRING, TType::STRING, scalar(keys %{$self->{arguments}}));
       {
-        while( my ($kiter23,$viter24) = each %{$self->{arguments}}) 
+        while( my ($kiter14,$viter15) = each %{$self->{arguments}}) 
         {
-          $xfer += $output->writeString($kiter23);
-          $xfer += $output->writeString($viter24);
+          $xfer += $output->writeString($kiter14);
+          $xfer += $output->writeString($viter15);
         }
       }
       $xfer += $output->writeMapEnd();
@@ -847,16 +633,16 @@ sub read {
       last; };
       /^3$/ && do{      if ($ftype == TType::LIST) {
         {
-          my $_size25 = 0;
+          my $_size16 = 0;
           $self->{analyzerSubTypes} = [];
-          my $_etype28 = 0;
-          $xfer += $input->readListBegin(\$_etype28, \$_size25);
-          for (my $_i29 = 0; $_i29 < $_size25; ++$_i29)
+          my $_etype19 = 0;
+          $xfer += $input->readListBegin(\$_etype19, \$_size16);
+          for (my $_i20 = 0; $_i20 < $_size16; ++$_i20)
           {
-            my $elem30 = undef;
-            $elem30 = new Blur::AnalyzerSubType();
-            $xfer += $elem30->read($input);
-            push(@{$self->{analyzerSubTypes}},$elem30);
+            my $elem21 = undef;
+            $elem21 = new Blur::AnalyzerSubType();
+            $xfer += $elem21->read($input);
+            push(@{$self->{analyzerSubTypes}},$elem21);
           }
           $xfer += $input->readListEnd();
         }
@@ -891,9 +677,9 @@ sub write {
     {
       $xfer += $output->writeListBegin(TType::STRUCT, scalar(@{$self->{analyzerSubTypes}}));
       {
-        foreach my $iter31 (@{$self->{analyzerSubTypes}}) 
+        foreach my $iter22 (@{$self->{analyzerSubTypes}}) 
         {
-          $xfer += ${iter31}->write($output);
+          $xfer += ${iter22}->write($output);
         }
       }
       $xfer += $output->writeListEnd();
@@ -943,16 +729,16 @@ sub read {
     {
       /^1$/ && do{      if ($ftype == TType::LIST) {
         {
-          my $_size32 = 0;
+          my $_size23 = 0;
           $self->{analyzerTypes} = [];
-          my $_etype35 = 0;
-          $xfer += $input->readListBegin(\$_etype35, \$_size32);
-          for (my $_i36 = 0; $_i36 < $_size32; ++$_i36)
+          my $_etype26 = 0;
+          $xfer += $input->readListBegin(\$_etype26, \$_size23);
+          for (my $_i27 = 0; $_i27 < $_size23; ++$_i27)
           {
-            my $elem37 = undef;
-            $elem37 = new Blur::AnalyzerType();
-            $xfer += $elem37->read($input);
-            push(@{$self->{analyzerTypes}},$elem37);
+            my $elem28 = undef;
+            $elem28 = new Blur::AnalyzerType();
+            $xfer += $elem28->read($input);
+            push(@{$self->{analyzerTypes}},$elem28);
           }
           $xfer += $input->readListEnd();
         }
@@ -977,9 +763,9 @@ sub write {
     {
       $xfer += $output->writeListBegin(TType::STRUCT, scalar(@{$self->{analyzerTypes}}));
       {
-        foreach my $iter38 (@{$self->{analyzerTypes}}) 
+        foreach my $iter29 (@{$self->{analyzerTypes}}) 
         {
-          $xfer += ${iter38}->write($output);
+          $xfer += ${iter29}->write($output);
         }
       }
       $xfer += $output->writeListEnd();
@@ -1100,18 +886,18 @@ sub read {
       last; };
       /^8$/ && do{      if ($ftype == TType::MAP) {
         {
-          my $_size39 = 0;
+          my $_size30 = 0;
           $self->{properties} = {};
-          my $_ktype40 = 0;
-          my $_vtype41 = 0;
-          $xfer += $input->readMapBegin(\$_ktype40, \$_vtype41, \$_size39);
-          for (my $_i43 = 0; $_i43 < $_size39; ++$_i43)
+          my $_ktype31 = 0;
+          my $_vtype32 = 0;
+          $xfer += $input->readMapBegin(\$_ktype31, \$_vtype32, \$_size30);
+          for (my $_i34 = 0; $_i34 < $_size30; ++$_i34)
           {
-            my $key44 = '';
-            my $val45 = '';
-            $xfer += $input->readString(\$key44);
-            $xfer += $input->readString(\$val45);
-            $self->{properties}->{$key44} = $val45;
+            my $key35 = '';
+            my $val36 = '';
+            $xfer += $input->readString(\$key35);
+            $xfer += $input->readString(\$val36);
+            $self->{properties}->{$key35} = $val36;
           }
           $xfer += $input->readMapEnd();
         }
@@ -1171,10 +957,10 @@ sub write {
     {
       $xfer += $output->writeMapBegin(TType::STRING, TType::STRING, scalar(keys %{$self->{properties}}));
       {
-        while( my ($kiter46,$viter47) = each %{$self->{properties}}) 
+        while( my ($kiter37,$viter38) = each %{$self->{properties}}) 
         {
-          $xfer += $output->writeString($kiter46);
-          $xfer += $output->writeString($viter47);
+          $xfer += $output->writeString($kiter37);
+          $xfer += $output->writeString($viter38);
         }
       }
       $xfer += $output->writeMapEnd();
@@ -1397,16 +1183,16 @@ sub read {
     {
       /^1$/ && do{      if ($ftype == TType::LIST) {
         {
-          my $_size48 = 0;
+          my $_size39 = 0;
           $self->{fields} = [];
-          my $_etype51 = 0;
-          $xfer += $input->readListBegin(\$_etype51, \$_size48);
-          for (my $_i52 = 0; $_i52 < $_size48; ++$_i52)
+          my $_etype42 = 0;
+          $xfer += $input->readListBegin(\$_etype42, \$_size39);
+          for (my $_i43 = 0; $_i43 < $_size39; ++$_i43)
           {
-            my $elem53 = undef;
-            $elem53 = new Blur::SortField();
-            $xfer += $elem53->read($input);
-            push(@{$self->{fields}},$elem53);
+            my $elem44 = undef;
+            $elem44 = new Blur::SortField();
+            $xfer += $elem44->read($input);
+            push(@{$self->{fields}},$elem44);
           }
           $xfer += $input->readListEnd();
         }
@@ -1431,9 +1217,9 @@ sub write {
     {
       $xfer += $output->writeListBegin(TType::STRUCT, scalar(@{$self->{fields}}));
       {
-        foreach my $iter54 (@{$self->{fields}}) 
+        foreach my $iter45 (@{$self->{fields}}) 
         {
-          $xfer += ${iter54}->write($output);
+          $xfer += ${iter45}->write($output);
         }
       }
       $xfer += $output->writeListEnd();
@@ -1503,15 +1289,15 @@ sub read {
       last; };
       /^4$/ && do{      if ($ftype == TType::LIST) {
         {
-          my $_size55 = 0;
+          my $_size46 = 0;
           $self->{fields} = [];
-          my $_etype58 = 0;
-          $xfer += $input->readListBegin(\$_etype58, \$_size55);
-          for (my $_i59 = 0; $_i59 < $_size55; ++$_i59)
+          my $_etype49 = 0;
+          $xfer += $input->readListBegin(\$_etype49, \$_size46);
+          for (my $_i50 = 0; $_i50 < $_size46; ++$_i50)
           {
-            my $elem60 = undef;
-            $xfer += $input->readString(\$elem60);
-            push(@{$self->{fields}},$elem60);
+            my $elem51 = undef;
+            $xfer += $input->readString(\$elem51);
+            push(@{$self->{fields}},$elem51);
           }
           $xfer += $input->readListEnd();
         }
@@ -1546,9 +1332,9 @@ sub write {
     {
       $xfer += $output->writeListBegin(TType::STRING, scalar(@{$self->{fields}}));
       {
-        foreach my $iter61 (@{$self->{fields}}) 
+        foreach my $iter52 (@{$self->{fields}}) 
         {
-          $xfer += $output->writeString($iter61);
+          $xfer += $output->writeString($iter52);
         }
       }
       $xfer += $output->writeListEnd();
@@ -1726,8 +1512,8 @@ sub read {
     }
     SWITCH: for($fid)
     {
-      /^1$/ && do{      if ($ftype == TType::I64) {
-        $xfer += $input->readI64(\$self->{id});
+      /^1$/ && do{      if ($ftype == TType::STRING) {
+        $xfer += $input->readString(\$self->{id});
       } else {
         $xfer += $input->skip($ftype);
       }
@@ -1785,15 +1571,15 @@ sub read {
       last; };
       /^10$/ && do{      if ($ftype == TType::LIST) {
         {
-          my $_size62 = 0;
+          my $_size53 = 0;
           $self->{shardIndexes} = [];
-          my $_etype65 = 0;
-          $xfer += $input->readListBegin(\$_etype65, \$_size62);
-          for (my $_i66 = 0; $_i66 < $_size62; ++$_i66)
+          my $_etype56 = 0;
+          $xfer += $input->readListBegin(\$_etype56, \$_size53);
+          for (my $_i57 = 0; $_i57 < $_size53; ++$_i57)
           {
-            my $elem67 = undef;
-            $xfer += $input->readI32(\$elem67);
-            push(@{$self->{shardIndexes}},$elem67);
+            my $elem58 = undef;
+            $xfer += $input->readI32(\$elem58);
+            push(@{$self->{shardIndexes}},$elem58);
           }
           $xfer += $input->readListEnd();
         }
@@ -1814,8 +1600,8 @@ sub write {
   my $xfer   = 0;
   $xfer += $output->writeStructBegin('QueryArgs');
   if (defined $self->{id}) {
-    $xfer += $output->writeFieldBegin('id', TType::I64, 1);
-    $xfer += $output->writeI64($self->{id});
+    $xfer += $output->writeFieldBegin('id', TType::STRING, 1);
+    $xfer += $output->writeString($self->{id});
     $xfer += $output->writeFieldEnd();
   }
   if (defined $self->{after}) {
@@ -1863,9 +1649,9 @@ sub write {
     {
       $xfer += $output->writeListBegin(TType::I32, scalar(@{$self->{shardIndexes}}));
       {
-        foreach my $iter68 (@{$self->{shardIndexes}}) 
+        foreach my $iter59 (@{$self->{shardIndexes}}) 
         {
-          $xfer += $output->writeI32($iter68);
+          $xfer += $output->writeI32($iter59);
         }
       }
       $xfer += $output->writeListEnd();
@@ -1877,6 +1663,176 @@ sub write {
   return $xfer;
 }
 
+package Blur::QueryStatus;
+use base qw(Class::Accessor);
+Blur::QueryStatus->mk_accessors( qw( startTime endTime cpuTime userTime completeShards totalShards state queryArgs ) );
+
+sub new {
+  my $classname = shift;
+  my $self      = {};
+  my $vals      = shift || {};
+  $self->{startTime} = undef;
+  $self->{endTime} = undef;
+  $self->{cpuTime} = undef;
+  $self->{userTime} = undef;
+  $self->{completeShards} = undef;
+  $self->{totalShards} = undef;
+  $self->{state} = undef;
+  $self->{queryArgs} = undef;
+  if (UNIVERSAL::isa($vals,'HASH')) {
+    if (defined $vals->{startTime}) {
+      $self->{startTime} = $vals->{startTime};
+    }
+    if (defined $vals->{endTime}) {
+      $self->{endTime} = $vals->{endTime};
+    }
+    if (defined $vals->{cpuTime}) {
+      $self->{cpuTime} = $vals->{cpuTime};
+    }
+    if (defined $vals->{userTime}) {
+      $self->{userTime} = $vals->{userTime};
+    }
+    if (defined $vals->{completeShards}) {
+      $self->{completeShards} = $vals->{completeShards};
+    }
+    if (defined $vals->{totalShards}) {
+      $self->{totalShards} = $vals->{totalShards};
+    }
+    if (defined $vals->{state}) {
+      $self->{state} = $vals->{state};
+    }
+    if (defined $vals->{queryArgs}) {
+      $self->{queryArgs} = $vals->{queryArgs};
+    }
+  }
+  return bless ($self, $classname);
+}
+
+sub getName {
+  return 'QueryStatus';
+}
+
+sub read {
+  my ($self, $input) = @_;
+  my $xfer  = 0;
+  my $fname;
+  my $ftype = 0;
+  my $fid   = 0;
+  $xfer += $input->readStructBegin(\$fname);
+  while (1) 
+  {
+    $xfer += $input->readFieldBegin(\$fname, \$ftype, \$fid);
+    if ($ftype == TType::STOP) {
+      last;
+    }
+    SWITCH: for($fid)
+    {
+      /^1$/ && do{      if ($ftype == TType::I64) {
+        $xfer += $input->readI64(\$self->{startTime});
+      } else {
+        $xfer += $input->skip($ftype);
+      }
+      last; };
+      /^2$/ && do{      if ($ftype == TType::I64) {
+        $xfer += $input->readI64(\$self->{endTime});
+      } else {
+        $xfer += $input->skip($ftype);
+      }
+      last; };
+      /^3$/ && do{      if ($ftype == TType::I64) {
+        $xfer += $input->readI64(\$self->{cpuTime});
+      } else {
+        $xfer += $input->skip($ftype);
+      }
+      last; };
+      /^4$/ && do{      if ($ftype == TType::I64) {
+        $xfer += $input->readI64(\$self->{userTime});
+      } else {
+        $xfer += $input->skip($ftype);
+      }
+      last; };
+      /^5$/ && do{      if ($ftype == TType::I32) {
+        $xfer += $input->readI32(\$self->{completeShards});
+      } else {
+        $xfer += $input->skip($ftype);
+      }
+      last; };
+      /^6$/ && do{      if ($ftype == TType::I32) {
+        $xfer += $input->readI32(\$self->{totalShards});
+      } else {
+        $xfer += $input->skip($ftype);
+      }
+      last; };
+      /^7$/ && do{      if ($ftype == TType::I32) {
+        $xfer += $input->readI32(\$self->{state});
+      } else {
+        $xfer += $input->skip($ftype);
+      }
+      last; };
+      /^8$/ && do{      if ($ftype == TType::STRUCT) {
+        $self->{queryArgs} = new Blur::QueryArgs();
+        $xfer += $self->{queryArgs}->read($input);
+      } else {
+        $xfer += $input->skip($ftype);
+      }
+      last; };
+        $xfer += $input->skip($ftype);
+    }
+    $xfer += $input->readFieldEnd();
+  }
+  $xfer += $input->readStructEnd();
+  return $xfer;
+}
+
+sub write {
+  my ($self, $output) = @_;
+  my $xfer   = 0;
+  $xfer += $output->writeStructBegin('QueryStatus');
+  if (defined $self->{startTime}) {
+    $xfer += $output->writeFieldBegin('startTime', TType::I64, 1);
+    $xfer += $output->writeI64($self->{startTime});
+    $xfer += $output->writeFieldEnd();
+  }
+  if (defined $self->{endTime}) {
+    $xfer += $output->writeFieldBegin('endTime', TType::I64, 2);
+    $xfer += $output->writeI64($self->{endTime});
+    $xfer += $output->writeFieldEnd();
+  }
+  if (defined $self->{cpuTime}) {
+    $xfer += $output->writeFieldBegin('cpuTime', TType::I64, 3);
+    $xfer += $output->writeI64($self->{cpuTime});
+    $xfer += $output->writeFieldEnd();
+  }
+  if (defined $self->{userTime}) {
+    $xfer += $output->writeFieldBegin('userTime', TType::I64, 4);
+    $xfer += $output->writeI64($self->{userTime});
+    $xfer += $output->writeFieldEnd();
+  }
+  if (defined $self->{completeShards}) {
+    $xfer += $output->writeFieldBegin('completeShards', TType::I32, 5);
+    $xfer += $output->writeI32($self->{completeShards});
+    $xfer += $output->writeFieldEnd();
+  }
+  if (defined $self->{totalShards}) {
+    $xfer += $output->writeFieldBegin('totalShards', TType::I32, 6);
+    $xfer += $output->writeI32($self->{totalShards});
+    $xfer += $output->writeFieldEnd();
+  }
+  if (defined $self->{state}) {
+    $xfer += $output->writeFieldBegin('state', TType::I32, 7);
+    $xfer += $output->writeI32($self->{state});
+    $xfer += $output->writeFieldEnd();
+  }
+  if (defined $self->{queryArgs}) {
+    $xfer += $output->writeFieldBegin('queryArgs', TType::STRUCT, 8);
+    $xfer += $self->{queryArgs}->write($output);
+    $xfer += $output->writeFieldEnd();
+  }
+  $xfer += $output->writeFieldStop();
+  $xfer += $output->writeStructEnd();
+  return $xfer;
+}
+
 package Blur::TopFieldDocs;
 use base qw(Class::Accessor);
 Blur::TopFieldDocs->mk_accessors( qw( shardIndex totalHits scoreDocs maxScore fields ) );
@@ -1943,16 +1899,16 @@ sub read {
       last; };
       /^3$/ && do{      if ($ftype == TType::LIST) {
         {
-          my $_size69 = 0;
+          my $_size60 = 0;
           $self->{scoreDocs} = [];
-          my $_etype72 = 0;
-          $xfer += $input->readListBegin(\$_etype72, \$_size69);
-          for (my $_i73 = 0; $_i73 < $_size69; ++$_i73)
+          my $_etype63 = 0;
+          $xfer += $input->readListBegin(\$_etype63, \$_size60);
+          for (my $_i64 = 0; $_i64 < $_size60; ++$_i64)
           {
-            my $elem74 = undef;
-            $elem74 = new Blur::ScoreDoc();
-            $xfer += $elem74->read($input);
-            push(@{$self->{scoreDocs}},$elem74);
+            my $elem65 = undef;
+            $elem65 = new Blur::ScoreDoc();
+            $xfer += $elem65->read($input);
+            push(@{$self->{scoreDocs}},$elem65);
           }
           $xfer += $input->readListEnd();
         }
@@ -1968,16 +1924,16 @@ sub read {
       last; };
       /^5$/ && do{      if ($ftype == TType::LIST) {
         {
-          my $_size75 = 0;
+          my $_size66 = 0;
           $self->{fields} = [];
-          my $_etype78 = 0;
-          $xfer += $input->readListBegin(\$_etype78, \$_size75);
-          for (my $_i79 = 0; $_i79 < $_size75; ++$_i79)
+          my $_etype69 = 0;
+          $xfer += $input->readListBegin(\$_etype69, \$_size66);
+          for (my $_i70 = 0; $_i70 < $_size66; ++$_i70)
           {
-            my $elem80 = undef;
-            $elem80 = new Blur::SortField();
-            $xfer += $elem80->read($input);
-            push(@{$self->{fields}},$elem80);
+            my $elem71 = undef;
+            $elem71 = new Blur::SortField();
+            $xfer += $elem71->read($input);
+            push(@{$self->{fields}},$elem71);
           }
           $xfer += $input->readListEnd();
         }
@@ -2012,9 +1968,9 @@ sub write {
     {
       $xfer += $output->writeListBegin(TType::STRUCT, scalar(@{$self->{scoreDocs}}));
       {
-        foreach my $iter81 (@{$self->{scoreDocs}}) 
+        foreach my $iter72 (@{$self->{scoreDocs}}) 
         {
-          $xfer += ${iter81}->write($output);
+          $xfer += ${iter72}->write($output);
         }
       }
       $xfer += $output->writeListEnd();
@@ -2031,9 +1987,9 @@ sub write {
     {
       $xfer += $output->writeListBegin(TType::STRUCT, scalar(@{$self->{fields}}));
       {
-        foreach my $iter82 (@{$self->{fields}}) 
+        foreach my $iter73 (@{$self->{fields}}) 
         {
-          $xfer += ${iter82}->write($output);
+          $xfer += ${iter73}->write($output);
         }
       }
       $xfer += $output->writeListEnd();
@@ -2192,16 +2148,16 @@ sub read {
     {
       /^1$/ && do{      if ($ftype == TType::LIST) {
         {
-          my $_size83 = 0;
+          my $_size74 = 0;
           $self->{fields} = [];
-          my $_etype86 = 0;
-          $xfer += $input->readListBegin(\$_etype86, \$_size83);
-          for (my $_i87 = 0; $_i87 < $_size83; ++$_i87)
+          my $_etype77 = 0;
+          $xfer += $input->readListBegin(\$_etype77, \$_size74);
+          for (my $_i78 = 0; $_i78 < $_size74; ++$_i78)
           {
-            my $elem88 = undef;
-            $elem88 = new Blur::Field();
-            $xfer += $elem88->read($input);
-            push(@{$self->{fields}},$elem88);
+            my $elem79 = undef;
+            $elem79 = new Blur::Field();
+            $xfer += $elem79->read($input);
+            push(@{$self->{fields}},$elem79);
           }
           $xfer += $input->readListEnd();
         }
@@ -2226,9 +2182,9 @@ sub write {
     {
       $xfer += $output->writeListBegin(TType::STRUCT, scalar(@{$self->{fields}}));
       {
-        foreach my $iter89 (@{$self->{fields}}) 
+        foreach my $iter80 (@{$self->{fields}}) 
         {
-          $xfer += ${iter89}->write($output);
+          $xfer += ${iter80}->write($output);
         }
       }
       $xfer += $output->writeListEnd();
@@ -2477,16 +2433,16 @@ sub read {
       last; };
       /^2$/ && do{      if ($ftype == TType::LIST) {
         {
-          my $_size90 = 0;
+          my $_size81 = 0;
           $self->{documents} = [];
-          my $_etype93 = 0;
-          $xfer += $input->readListBegin(\$_etype93, \$_size90);
-          for (my $_i94 = 0; $_i94 < $_size90; ++$_i94)
+          my $_etype84 = 0;
+          $xfer += $input->readListBegin(\$_etype84, \$_size81);
+          for (my $_i85 = 0; $_i85 < $_size81; ++$_i85)
           {
-            my $elem95 = undef;
-            $elem95 = new Blur::Document();
-            $xfer += $elem95->read($input);
-            push(@{$self->{documents}},$elem95);
+            my $elem86 = undef;
+            $elem86 = new Blur::Document();
+            $xfer += $elem86->read($input);
+            push(@{$self->{documents}},$elem86);
           }
           $xfer += $input->readListEnd();
         }
@@ -2516,9 +2472,9 @@ sub write {
     {
       $xfer += $output->writeListBegin(TType::STRUCT, scalar(@{$self->{documents}}));
       {
-        foreach my $iter96 (@{$self->{documents}}) 
+        foreach my $iter87 (@{$self->{documents}}) 
         {
-          $xfer += ${iter96}->write($output);
+          $xfer += ${iter87}->write($output);
         }
       }
       $xfer += $output->writeListEnd();
@@ -2672,15 +2628,15 @@ sub read {
       last; };
       /^2$/ && do{      if ($ftype == TType::LIST) {
         {
-          my $_size97 = 0;
+          my $_size88 = 0;
           $self->{shards} = [];
-          my $_etype100 = 0;
-          $xfer += $input->readListBegin(\$_etype100, \$_size97);
-          for (my $_i101 = 0; $_i101 < $_size97; ++$_i101)
+          my $_etype91 = 0;
+          $xfer += $input->readListBegin(\$_etype91, \$_size88);
+          for (my $_i92 = 0; $_i92 < $_size88; ++$_i92)
           {
-            my $elem102 = undef;
-            $xfer += $input->readI32(\$elem102);
-            push(@{$self->{shards}},$elem102);
+            my $elem93 = undef;
+            $xfer += $input->readI32(\$elem93);
+            push(@{$self->{shards}},$elem93);
           }
           $xfer += $input->readListEnd();
         }
@@ -2710,9 +2666,9 @@ sub write {
     {
       $xfer += $output->writeListBegin(TType::I32, scalar(@{$self->{shards}}));
       {
-        foreach my $iter103 (@{$self->{shards}}) 
+        foreach my $iter94 (@{$self->{shards}}) 
         {
-          $xfer += $output->writeI32($iter103);
+          $xfer += $output->writeI32($iter94);
         }
       }
       $xfer += $output->writeListEnd();


Mime
View raw message