incubator-blur-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From amccu...@apache.org
Subject [7/14] More API changes, and update and delete documents are noew implemented.
Date Sun, 04 Nov 2012 02:17:15 GMT
http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/4e18a556/src/blur-core/src/main/java/org/apache/blur/utils/BlurUtil.java
----------------------------------------------------------------------
diff --git a/src/blur-core/src/main/java/org/apache/blur/utils/BlurUtil.java b/src/blur-core/src/main/java/org/apache/blur/utils/BlurUtil.java
index 69b6c5e..22cf6c4 100644
--- a/src/blur-core/src/main/java/org/apache/blur/utils/BlurUtil.java
+++ b/src/blur-core/src/main/java/org/apache/blur/utils/BlurUtil.java
@@ -25,12 +25,10 @@ import java.io.InputStream;
 import java.io.ObjectInputStream;
 import java.io.ObjectOutputStream;
 import java.io.Serializable;
-import java.io.UnsupportedEncodingException;
 import java.lang.reflect.InvocationHandler;
 import java.lang.reflect.InvocationTargetException;
 import java.lang.reflect.Method;
 import java.lang.reflect.Proxy;
-import java.nio.ByteBuffer;
 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.Collections;
@@ -46,7 +44,6 @@ import java.util.concurrent.atomic.AtomicLongArray;
 
 import org.apache.blur.log.Log;
 import org.apache.blur.log.LogFactory;
-import org.apache.blur.lucene.serializer.QueryWritable;
 import org.apache.blur.manager.clusterstatus.ZookeeperPathConstants;
 import org.apache.blur.manager.results.BlurResultIterable;
 import org.apache.blur.metrics.BlurMetrics;
@@ -56,52 +53,28 @@ import org.apache.blur.thrift.generated.BlurQuery;
 import org.apache.blur.thrift.generated.BlurResult;
 import org.apache.blur.thrift.generated.BlurResults;
 import org.apache.blur.thrift.generated.Column;
-import org.apache.blur.thrift.generated.DocLocation;
 import org.apache.blur.thrift.generated.FetchResult;
-import org.apache.blur.thrift.generated.Field;
-import org.apache.blur.thrift.generated.QueryArgs;
 import org.apache.blur.thrift.generated.Record;
 import org.apache.blur.thrift.generated.RecordMutation;
 import org.apache.blur.thrift.generated.RecordMutationType;
 import org.apache.blur.thrift.generated.Row;
 import org.apache.blur.thrift.generated.RowMutation;
 import org.apache.blur.thrift.generated.RowMutationType;
-import org.apache.blur.thrift.generated.ScoreDoc;
 import org.apache.blur.thrift.generated.Selector;
 import org.apache.blur.thrift.generated.SimpleQuery;
-import org.apache.blur.thrift.generated.SortField;
-import org.apache.blur.thrift.generated.SortType;
-import org.apache.blur.thrift.generated.TYPE;
-import org.apache.blur.thrift.generated.TopFieldDocs;
 import org.apache.hadoop.conf.Configurable;
 import org.apache.hadoop.conf.Configuration;
 import org.apache.hadoop.fs.FileStatus;
 import org.apache.hadoop.fs.FileSystem;
 import org.apache.hadoop.fs.Path;
-import org.apache.hadoop.io.DataInputBuffer;
 import org.apache.lucene.document.Document;
-import org.apache.lucene.document.DoubleField;
-import org.apache.lucene.document.FieldType;
-import org.apache.lucene.document.FloatField;
-import org.apache.lucene.document.IntField;
-import org.apache.lucene.document.LongField;
-import org.apache.lucene.document.StoredField;
-import org.apache.lucene.document.StringField;
-import org.apache.lucene.document.Field.Store;
-import org.apache.lucene.document.TextField;
 import org.apache.lucene.index.AtomicReader;
 import org.apache.lucene.index.IndexReader;
-import org.apache.lucene.index.IndexableField;
 import org.apache.lucene.index.SlowCompositeReaderWrapper;
 import org.apache.lucene.index.Term;
-import org.apache.lucene.search.Filter;
 import org.apache.lucene.search.IndexSearcher;
-import org.apache.lucene.search.Query;
-import org.apache.lucene.search.Sort;
-import org.apache.lucene.search.SortField.Type;
 import org.apache.lucene.search.TermQuery;
 import org.apache.lucene.search.TopDocs;
-import org.apache.lucene.util.BytesRef;
 import org.apache.lucene.util.RamUsageEstimator;
 import org.apache.thrift.TBase;
 import org.apache.thrift.TException;
@@ -696,358 +669,4 @@ public class BlurUtil {
     return Integer.parseInt(shard.substring(index + 1));
   }
 
-  public static TopFieldDocs convert(org.apache.lucene.search.TopFieldDocs topFieldDocs) {
-    TopFieldDocs result = new TopFieldDocs();
-    result.setFields(convert(topFieldDocs.fields));
-    result.setMaxScore(topFieldDocs.getMaxScore());
-    result.setScoreDocs(convert(topFieldDocs.scoreDocs));
-    result.setTotalHits(topFieldDocs.totalHits);
-    return result;
-  }
-
-  public static List<ScoreDoc> convert(org.apache.lucene.search.ScoreDoc[] scoreDocs) {
-    List<ScoreDoc> result = new ArrayList<ScoreDoc>(scoreDocs.length);
-    for (int i = 0; i < scoreDocs.length; i++) {
-      org.apache.lucene.search.ScoreDoc scoreDoc = scoreDocs[i];
-      if (scoreDoc instanceof org.apache.lucene.search.FieldDoc) {
-        result.add(convert((org.apache.lucene.search.FieldDoc) scoreDoc));
-      } else {
-        result.add(convert(scoreDoc));
-      }
-    }
-    return result;
-  }
-
-  public List<ScoreDoc> convert(org.apache.lucene.search.FieldDoc[] fieldDocs) {
-    List<ScoreDoc> result = new ArrayList<ScoreDoc>(fieldDocs.length);
-    for (int i = 0; i < fieldDocs.length; i++) {
-      result.add(convert(fieldDocs[i]));
-    }
-    return result;
-  }
-
-  public static List<SortField> convert(org.apache.lucene.search.SortField[] fields) {
-    if (fields == null) {
-      return null;
-    }
-    List<SortField> result = new ArrayList<SortField>(fields.length);
-    for (int i = 0; i < fields.length; i++) {
-      result.add(convert(fields[i]));
-    }
-    return result;
-  }
-
-  public static SortField convert(org.apache.lucene.search.SortField sortField) {
-    if (sortField == null) {
-      return null;
-    }
-    SortField result = new SortField();
-    result.setField(sortField.getField());
-    result.setReverse(sortField.getReverse());
-    result.setType(convert(sortField.getType()));
-    return result;
-  }
-
-  public static ScoreDoc convert(org.apache.lucene.search.ScoreDoc scoreDoc) {
-    if (scoreDoc == null) {
-      return null;
-    }
-    ScoreDoc result = new ScoreDoc();
-    result.setDocLocation(new DocLocation(scoreDoc.doc, scoreDoc.shardIndex));
-    result.setScore(scoreDoc.score);
-    return result;
-  }
-
-  public static ScoreDoc convert(org.apache.lucene.search.FieldDoc fieldDoc) {
-    if (fieldDoc == null) {
-      return null;
-    }
-    ScoreDoc result = new ScoreDoc();
-    result.setDocLocation(new DocLocation(fieldDoc.doc, fieldDoc.shardIndex));
-    result.setFields(convert(fieldDoc.fields));
-    result.setScore(fieldDoc.score);
-    return result;
-  }
-
-  public static SortType convert(Type type) {
-    if (type == null) {
-      return null;
-    }
-    switch (type) {
-    case BYTE:
-      return SortType.BYTE;
-    case BYTES:
-      return SortType.BYTES;
-    case SCORE:
-      return SortType.SCORE;
-    case DOC:
-      return SortType.DOC;
-    case STRING:
-      return SortType.STRING;
-    case INT:
-      return SortType.INT;
-    case FLOAT:
-      return SortType.FLOAT;
-    case LONG:
-      return SortType.LONG;
-    case DOUBLE:
-      return SortType.DOUBLE;
-    case SHORT:
-      return SortType.SHORT;
-    case STRING_VAL:
-      return SortType.STRING_VAL;
-    default:
-      throw new RuntimeException("Not supported");
-    }
-  }
-
-  public static List<ByteBuffer> convert(Object[] fields) {
-    // throw new RuntimeException("Not supported YET!");
-    LOG.error("Not supported YET!");
-    return null;
-  }
-
-  public static Query getQuery(QueryArgs queryArgs) throws IOException {
-    byte[] query = queryArgs.getQuery();
-    DataInputBuffer in = new DataInputBuffer();
-    in.reset(query, 0, query.length);
-    QueryWritable qw = new QueryWritable();
-    qw.readFields(in);
-    return qw.getQuery();
-  }
-
-  public static Filter getFilter(QueryArgs queryArgs) {
-    byte[] filter = queryArgs.getFilter();
-    return null;
-  }
-
-  public static Sort getSort(QueryArgs queryArgs) {
-    return null;
-  }
-
-  public static TopFieldDocs convert(TopDocs topDocs) {
-    return convert(new org.apache.lucene.search.TopFieldDocs(topDocs.totalHits, topDocs.scoreDocs, null, Float.NaN));
-  }
-
-  public static org.apache.lucene.search.ScoreDoc convert(org.apache.blur.thrift.generated.ScoreDoc scoreDoc) {
-    if (scoreDoc == null) {
-      return null;
-    }
-    return new org.apache.lucene.search.ScoreDoc(scoreDoc.docLocation.doc, (float) scoreDoc.score, scoreDoc.docLocation.shardIndex);
-  }
-
-  public static org.apache.blur.thrift.generated.Document convert(org.apache.lucene.document.Document document) {
-    org.apache.blur.thrift.generated.Document result = new org.apache.blur.thrift.generated.Document();
-    List<IndexableField> fields = document.getFields();
-    for (IndexableField field : fields) {
-      result.addToFields(convert(field));
-    }
-    return result;
-  }
-
-  public static Field convert(IndexableField field) {
-    Field result = new Field();
-    result.setBoost(field.boost());
-    result.setName(field.name());
-    Number number = field.numericValue();
-    if (number != null) {
-      if (number instanceof Byte || number instanceof Short || number instanceof Integer) {
-        result.setType(TYPE.INT);
-        result.setValue(convert((Integer) number));
-      } else if (number instanceof Long) {
-        result.setType(TYPE.LONG);
-        result.setValue(convert((Long) number));
-      } else if (number instanceof Float) {
-        result.setType(TYPE.FLOAT);
-        result.setValue(convert((Float) number));
-      } else if (number instanceof Double) {
-        result.setType(TYPE.DOUBLE);
-        result.setValue(convert((Double) number));
-      } else {
-        throw new IllegalArgumentException("cannot store numeric type " + number.getClass());
-      }
-    } else {
-      BytesRef bytes = field.binaryValue();
-      if (bytes != null) {
-        result.setType(TYPE.BINARY);
-        result.setValue(convert(bytes));
-      } else {
-        result.setType(TYPE.STRING);
-        result.setValue(convert(field.stringValue()));
-      }
-    }
-    return result;
-  }
-
-  public static ByteBuffer convert(String val) {
-    if (val == null) {
-      return null;
-    }
-    return convert(new BytesRef(val));
-  }
-
-  public static ByteBuffer convert(BytesRef val) {
-    if (val == null) {
-      return null;
-    }
-    return flip(ByteBuffer.allocate(val.length).put(val.bytes, val.offset, val.length));
-  }
-
-  private static ByteBuffer flip(ByteBuffer buffer) {
-    buffer.flip();
-    return buffer;
-  }
-
-  public static ByteBuffer convert(Double val) {
-    if (val == null) {
-      return null;
-    }
-    return flip(ByteBuffer.allocate(8).putDouble(val));
-  }
-
-  public static ByteBuffer convert(Long val) {
-    if (val == null) {
-      return null;
-    }
-    return flip(ByteBuffer.allocate(8).putLong(val));
-  }
-
-  public static ByteBuffer convert(Float val) {
-    if (val == null) {
-      return null;
-    }
-    return flip(ByteBuffer.allocate(4).putFloat(val));
-  }
-
-  public static ByteBuffer convert(Integer val) {
-    if (val == null) {
-      return null;
-    }
-    return flip(ByteBuffer.allocate(4).putInt(val));
-  }
-
-  public static List<DocLocation> getDocLocations(List<ScoreDoc> scoreDocs) {
-    List<DocLocation> result = new ArrayList<DocLocation>(scoreDocs.size());
-    for (ScoreDoc scoreDoc : scoreDocs) {
-      result.add(scoreDoc.getDocLocation());
-    }
-    return result;
-  }
-
-  public static String toString(org.apache.blur.thrift.generated.Document document) {
-    StringBuilder builder = new StringBuilder();
-    builder.append('{');
-    for (Field f : document.getFields()) {
-      if (builder.length() != 0) {
-        builder.append(',');
-      }
-      builder.append(toString(f));
-    }
-    builder.append('}');
-    return builder.toString();
-  }
-
-  public static String toString(Field f) {
-    StringBuilder builder = new StringBuilder();
-    builder.append('{');
-    String name = f.getName();
-    builder.append(name);
-    builder.append(',');
-
-    TYPE type = f.getType();
-    builder.append(type.name());
-    builder.append(',');
-
-    byte[] value = f.getValue();
-    builder.append(toString(type, value));
-    builder.append(',');
-
-    double boost = f.getBoost();
-    builder.append(boost);
-    builder.append('}');
-    return builder.toString();
-  }
-
-  public static String toString(TYPE type, byte[] value) {
-    switch (type) {
-    case STRING:
-      return new BytesRef(value).utf8ToString();
-    case INT:
-      return Integer.toString(ByteBuffer.wrap(value).getInt());
-    case LONG:
-      return Long.toString(ByteBuffer.wrap(value).getLong());
-    case FLOAT:
-      return Float.toString(ByteBuffer.wrap(value).getFloat());
-    case DOUBLE:
-      return Double.toString(ByteBuffer.wrap(value).getDouble());
-    case BINARY:
-      return ByteBuffer.wrap(value).toString();
-    default:
-      throw new RuntimeException("Type unknown.");
-    }
-  }
-
-  public static Document convert(org.apache.blur.thrift.generated.Document document) throws IOException {
-    Document result = new Document();
-    List<Field> fields = document.getFields();
-    for (Field field : fields) {
-      result.add(convert(field));
-    }
-    return result;
-  }
-
-  public static IndexableField convert(Field field) throws IOException {
-    TYPE type = field.getType();
-    org.apache.lucene.document.Field result;
-    switch (type) {
-    case STRING:
-      result = new StringField(field.getName(), toString(field.getValue()), Store.YES);
-      break;
-    case TEXT:
-      result = new TextField(field.getName(), toString(field.getValue()), Store.YES);
-      break;
-    case INT:
-      result = new IntField(field.getName(), toInteger(field.getValue()), Store.YES);
-      break;
-    case FLOAT:
-      result = new FloatField(field.getName(), toFloat(field.getValue()), Store.YES);
-      break;
-    case LONG:
-      result = new LongField(field.getName(), toLong(field.getValue()), Store.YES);
-      break;
-    case DOUBLE:
-      result = new DoubleField(field.getName(), toDouble(field.getValue()), Store.YES);
-      break;
-    case BINARY:
-      result = new StoredField(field.getName(), field.getValue());
-      break;
-    default:
-      throw new RuntimeException("Not supported");
-    }
-    FieldType fieldType = result.fieldType();
-    if (fieldType.indexed() && !fieldType.omitNorms()) {
-      result.setBoost((float) field.getBoost());
-    }
-    return result;
-  }
-
-  public static double toDouble(byte[] value) {
-    throw new RuntimeException("Not implemented");
-  }
-
-  public static long toLong(byte[] value) {
-    throw new RuntimeException("Not implemented");
-  }
-
-  public static float toFloat(byte[] value) {
-    throw new RuntimeException("Not implemented");
-  }
-
-  public static int toInteger(byte[] value) {
-    throw new RuntimeException("Not implemented");
-  }
-
-  public static String toString(byte[] value) throws IOException {
-    return new String(value, "UTF-8");
-  }
 }

http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/4e18a556/src/blur-testsuite/src/main/java/org/apache/blur/testsuite/AddDocumentsLuceneApiTable.java
----------------------------------------------------------------------
diff --git a/src/blur-testsuite/src/main/java/org/apache/blur/testsuite/AddDocumentsLuceneApiTable.java b/src/blur-testsuite/src/main/java/org/apache/blur/testsuite/AddDocumentsLuceneApiTable.java
new file mode 100644
index 0000000..9e5c716
--- /dev/null
+++ b/src/blur-testsuite/src/main/java/org/apache/blur/testsuite/AddDocumentsLuceneApiTable.java
@@ -0,0 +1,83 @@
+package org.apache.blur.testsuite;
+
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+import java.io.IOException;
+import java.net.InetSocketAddress;
+import java.net.Socket;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.UUID;
+
+import org.apache.blur.thrift.generated.BlurException;
+import org.apache.blur.thrift.generated.Document;
+import org.apache.blur.thrift.generated.Field;
+import org.apache.blur.thrift.generated.Lucene.Client;
+import org.apache.blur.thrift.generated.MutateOptions;
+import org.apache.blur.thrift.generated.TYPE;
+import org.apache.lucene.queryparser.classic.ParseException;
+import org.apache.thrift.TException;
+import org.apache.thrift.protocol.TBinaryProtocol;
+import org.apache.thrift.protocol.TProtocol;
+import org.apache.thrift.transport.TFramedTransport;
+import org.apache.thrift.transport.TSocket;
+
+public class AddDocumentsLuceneApiTable {
+
+  public static void main(String[] args) throws BlurException, TException, IOException, ParseException {
+    TSocket trans;
+    Socket socket = new Socket();
+    socket.setTcpNoDelay(true);
+    socket.connect(new InetSocketAddress("127.0.0.1", 40020));
+    trans = new TSocket(socket);
+
+    TProtocol proto = new TBinaryProtocol(new TFramedTransport(trans));
+    Client client = new Client(proto);
+    int batch = 100;
+    List<Document> docs = new ArrayList<Document>();
+    long start = System.nanoTime();
+    int total = 0;
+    MutateOptions options = new MutateOptions();
+    options.setTable("test_table");
+    options.setShardIndex(0);
+    while (true) {
+      long now = System.nanoTime();
+      if (start + 5000000000l < now) {
+        System.out.println(total);
+        start = System.nanoTime();
+      }
+      Document doc = genDoc();
+      docs.add(doc);
+      if (docs.size() >= batch) {
+        client.addDocuments(options, docs);
+        docs.clear();
+      }
+      total++;
+    }
+
+  }
+
+  private static Document genDoc() {
+    Document document = new Document();
+    Field field = new Field();
+    field.setName("test");
+    field.setType(TYPE.STRING);
+    field.setValue(new String(UUID.randomUUID().toString()).getBytes());
+    document.addToFields(field);
+    return document;
+  }
+}

http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/4e18a556/src/blur-testsuite/src/main/java/org/apache/blur/testsuite/SearchLuceneApiTable.java
----------------------------------------------------------------------
diff --git a/src/blur-testsuite/src/main/java/org/apache/blur/testsuite/SearchLuceneApiTable.java b/src/blur-testsuite/src/main/java/org/apache/blur/testsuite/SearchLuceneApiTable.java
new file mode 100644
index 0000000..42164b9
--- /dev/null
+++ b/src/blur-testsuite/src/main/java/org/apache/blur/testsuite/SearchLuceneApiTable.java
@@ -0,0 +1,107 @@
+package org.apache.blur.testsuite;
+
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+import java.io.IOException;
+import java.net.InetSocketAddress;
+import java.net.Socket;
+import java.util.List;
+
+import org.apache.blur.lucene.serializer.QueryWritable;
+import org.apache.blur.thrift.generated.BlurException;
+import org.apache.blur.thrift.generated.DocLocation;
+import org.apache.blur.thrift.generated.Document;
+import org.apache.blur.thrift.generated.Lucene.Client;
+import org.apache.blur.thrift.generated.QueryArgs;
+import org.apache.blur.thrift.generated.ScoreDoc;
+import org.apache.blur.thrift.generated.Session;
+import org.apache.blur.thrift.generated.TopFieldDocs;
+import org.apache.blur.utils.BlurUtil;
+import org.apache.hadoop.io.DataOutputBuffer;
+import org.apache.lucene.analysis.standard.StandardAnalyzer;
+import org.apache.lucene.queryparser.classic.ParseException;
+import org.apache.lucene.queryparser.classic.QueryParser;
+import org.apache.lucene.search.Query;
+import org.apache.lucene.util.Version;
+import org.apache.thrift.TException;
+import org.apache.thrift.protocol.TBinaryProtocol;
+import org.apache.thrift.protocol.TProtocol;
+import org.apache.thrift.transport.TFramedTransport;
+import org.apache.thrift.transport.TSocket;
+
+public class SearchLuceneApiTable {
+
+  public static void main(String[] args) throws BlurException, TException, IOException, ParseException {
+    TSocket trans;
+    Socket socket = new Socket();
+    socket.setTcpNoDelay(true);
+    socket.connect(new InetSocketAddress("127.0.0.1", 40020));
+    trans = new TSocket(socket);
+
+    TProtocol proto = new TBinaryProtocol(new TFramedTransport(trans));
+    Client client = new Client(proto);
+
+    // List<String> terms = client.terms("test_table", "fam0", "col0", "",
+    // (short) 10);
+    // System.out.println(terms);
+
+    QueryParser parser = new QueryParser(Version.LUCENE_40, "", new StandardAnalyzer(Version.LUCENE_40));
+
+    Query query = parser.parse("fam0.col0:abdomen");
+
+    QueryWritable queryWritable = new QueryWritable(query);
+    DataOutputBuffer buffer = new DataOutputBuffer();
+    queryWritable.write(buffer);
+    buffer.close();
+
+    Session session = client.openReadSession("test_table");
+    int total = 1000;
+    long totalTime = 0;
+    long totalTimeM = 0;
+    for (int i = 0; i < total; i++) {
+      QueryArgs queryArgs = new QueryArgs();
+      queryArgs.setNumberToFetch(10);
+      queryArgs.setQuery(trim(buffer));
+
+      long sm = System.currentTimeMillis();
+      long s = System.nanoTime();
+      List<TopFieldDocs> topDocs = client.search(session, queryArgs);
+      long e = System.nanoTime();
+      long em = System.currentTimeMillis();
+      totalTime += (e - s);
+      totalTimeM += (em - sm);
+      System.out.println("================");
+      for (TopFieldDocs topFieldDocs : topDocs) {
+        System.out.println(topFieldDocs);
+        List<Document> docs = client.doc(session, BlurUtil.getDocLocations(topFieldDocs.getScoreDocs()), null);
+        for (Document document : docs) {
+          System.out.println(BlurUtil.toString(document));
+        }
+      }
+
+    }
+    System.out.println(totalTime / total / 1000000.0);
+    System.out.println(totalTimeM / total);
+    client.closeReadSession(session);
+  }
+
+  private static byte[] trim(DataOutputBuffer buffer) {
+    byte[] buf = new byte[buffer.getLength()];
+    System.arraycopy(buffer.getData(), 0, buf, 0, buf.length);
+    return buf;
+  }
+}

http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/4e18a556/src/blur-thrift/src/main/java/org/apache/blur/thrift/generated/Blur.java
----------------------------------------------------------------------
diff --git a/src/blur-thrift/src/main/java/org/apache/blur/thrift/generated/Blur.java b/src/blur-thrift/src/main/java/org/apache/blur/thrift/generated/Blur.java
index 4ea4c5f..d8e51a7 100644
--- a/src/blur-thrift/src/main/java/org/apache/blur/thrift/generated/Blur.java
+++ b/src/blur-thrift/src/main/java/org/apache/blur/thrift/generated/Blur.java
@@ -3182,13 +3182,13 @@ public class Blur {
             case 0: // SUCCESS
               if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
                 {
-                  org.apache.thrift.protocol.TList _list224 = iprot.readListBegin();
-                  struct.success = new ArrayList<String>(_list224.size);
-                  for (int _i225 = 0; _i225 < _list224.size; ++_i225)
+                  org.apache.thrift.protocol.TList _list232 = iprot.readListBegin();
+                  struct.success = new ArrayList<String>(_list232.size);
+                  for (int _i233 = 0; _i233 < _list232.size; ++_i233)
                   {
-                    String _elem226; // required
-                    _elem226 = iprot.readString();
-                    struct.success.add(_elem226);
+                    String _elem234; // required
+                    _elem234 = iprot.readString();
+                    struct.success.add(_elem234);
                   }
                   iprot.readListEnd();
                 }
@@ -3225,9 +3225,9 @@ public class Blur {
           oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
           {
             oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.success.size()));
-            for (String _iter227 : struct.success)
+            for (String _iter235 : struct.success)
             {
-              oprot.writeString(_iter227);
+              oprot.writeString(_iter235);
             }
             oprot.writeListEnd();
           }
@@ -3266,9 +3266,9 @@ public class Blur {
         if (struct.isSetSuccess()) {
           {
             oprot.writeI32(struct.success.size());
-            for (String _iter228 : struct.success)
+            for (String _iter236 : struct.success)
             {
-              oprot.writeString(_iter228);
+              oprot.writeString(_iter236);
             }
           }
         }
@@ -3283,13 +3283,13 @@ public class Blur {
         BitSet incoming = iprot.readBitSet(2);
         if (incoming.get(0)) {
           {
-            org.apache.thrift.protocol.TList _list229 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
-            struct.success = new ArrayList<String>(_list229.size);
-            for (int _i230 = 0; _i230 < _list229.size; ++_i230)
+            org.apache.thrift.protocol.TList _list237 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+            struct.success = new ArrayList<String>(_list237.size);
+            for (int _i238 = 0; _i238 < _list237.size; ++_i238)
             {
-              String _elem231; // required
-              _elem231 = iprot.readString();
-              struct.success.add(_elem231);
+              String _elem239; // required
+              _elem239 = iprot.readString();
+              struct.success.add(_elem239);
             }
           }
           struct.setSuccessIsSet(true);
@@ -4044,13 +4044,13 @@ public class Blur {
             case 0: // SUCCESS
               if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
                 {
-                  org.apache.thrift.protocol.TList _list232 = iprot.readListBegin();
-                  struct.success = new ArrayList<String>(_list232.size);
-                  for (int _i233 = 0; _i233 < _list232.size; ++_i233)
+                  org.apache.thrift.protocol.TList _list240 = iprot.readListBegin();
+                  struct.success = new ArrayList<String>(_list240.size);
+                  for (int _i241 = 0; _i241 < _list240.size; ++_i241)
                   {
-                    String _elem234; // required
-                    _elem234 = iprot.readString();
-                    struct.success.add(_elem234);
+                    String _elem242; // required
+                    _elem242 = iprot.readString();
+                    struct.success.add(_elem242);
                   }
                   iprot.readListEnd();
                 }
@@ -4087,9 +4087,9 @@ public class Blur {
           oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
           {
             oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.success.size()));
-            for (String _iter235 : struct.success)
+            for (String _iter243 : struct.success)
             {
-              oprot.writeString(_iter235);
+              oprot.writeString(_iter243);
             }
             oprot.writeListEnd();
           }
@@ -4128,9 +4128,9 @@ public class Blur {
         if (struct.isSetSuccess()) {
           {
             oprot.writeI32(struct.success.size());
-            for (String _iter236 : struct.success)
+            for (String _iter244 : struct.success)
             {
-              oprot.writeString(_iter236);
+              oprot.writeString(_iter244);
             }
           }
         }
@@ -4145,13 +4145,13 @@ public class Blur {
         BitSet incoming = iprot.readBitSet(2);
         if (incoming.get(0)) {
           {
-            org.apache.thrift.protocol.TList _list237 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
-            struct.success = new ArrayList<String>(_list237.size);
-            for (int _i238 = 0; _i238 < _list237.size; ++_i238)
+            org.apache.thrift.protocol.TList _list245 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+            struct.success = new ArrayList<String>(_list245.size);
+            for (int _i246 = 0; _i246 < _list245.size; ++_i246)
             {
-              String _elem239; // required
-              _elem239 = iprot.readString();
-              struct.success.add(_elem239);
+              String _elem247; // required
+              _elem247 = iprot.readString();
+              struct.success.add(_elem247);
             }
           }
           struct.setSuccessIsSet(true);
@@ -4798,13 +4798,13 @@ public class Blur {
             case 0: // SUCCESS
               if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
                 {
-                  org.apache.thrift.protocol.TList _list240 = iprot.readListBegin();
-                  struct.success = new ArrayList<String>(_list240.size);
-                  for (int _i241 = 0; _i241 < _list240.size; ++_i241)
+                  org.apache.thrift.protocol.TList _list248 = iprot.readListBegin();
+                  struct.success = new ArrayList<String>(_list248.size);
+                  for (int _i249 = 0; _i249 < _list248.size; ++_i249)
                   {
-                    String _elem242; // required
-                    _elem242 = iprot.readString();
-                    struct.success.add(_elem242);
+                    String _elem250; // required
+                    _elem250 = iprot.readString();
+                    struct.success.add(_elem250);
                   }
                   iprot.readListEnd();
                 }
@@ -4841,9 +4841,9 @@ public class Blur {
           oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
           {
             oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.success.size()));
-            for (String _iter243 : struct.success)
+            for (String _iter251 : struct.success)
             {
-              oprot.writeString(_iter243);
+              oprot.writeString(_iter251);
             }
             oprot.writeListEnd();
           }
@@ -4882,9 +4882,9 @@ public class Blur {
         if (struct.isSetSuccess()) {
           {
             oprot.writeI32(struct.success.size());
-            for (String _iter244 : struct.success)
+            for (String _iter252 : struct.success)
             {
-              oprot.writeString(_iter244);
+              oprot.writeString(_iter252);
             }
           }
         }
@@ -4899,13 +4899,13 @@ public class Blur {
         BitSet incoming = iprot.readBitSet(2);
         if (incoming.get(0)) {
           {
-            org.apache.thrift.protocol.TList _list245 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
-            struct.success = new ArrayList<String>(_list245.size);
-            for (int _i246 = 0; _i246 < _list245.size; ++_i246)
+            org.apache.thrift.protocol.TList _list253 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+            struct.success = new ArrayList<String>(_list253.size);
+            for (int _i254 = 0; _i254 < _list253.size; ++_i254)
             {
-              String _elem247; // required
-              _elem247 = iprot.readString();
-              struct.success.add(_elem247);
+              String _elem255; // required
+              _elem255 = iprot.readString();
+              struct.success.add(_elem255);
             }
           }
           struct.setSuccessIsSet(true);
@@ -5665,15 +5665,15 @@ public class Blur {
             case 0: // SUCCESS
               if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
                 {
-                  org.apache.thrift.protocol.TMap _map248 = iprot.readMapBegin();
-                  struct.success = new HashMap<String,String>(2*_map248.size);
-                  for (int _i249 = 0; _i249 < _map248.size; ++_i249)
+                  org.apache.thrift.protocol.TMap _map256 = iprot.readMapBegin();
+                  struct.success = new HashMap<String,String>(2*_map256.size);
+                  for (int _i257 = 0; _i257 < _map256.size; ++_i257)
                   {
-                    String _key250; // required
-                    String _val251; // optional
-                    _key250 = iprot.readString();
-                    _val251 = iprot.readString();
-                    struct.success.put(_key250, _val251);
+                    String _key258; // required
+                    String _val259; // optional
+                    _key258 = iprot.readString();
+                    _val259 = iprot.readString();
+                    struct.success.put(_key258, _val259);
                   }
                   iprot.readMapEnd();
                 }
@@ -5710,10 +5710,10 @@ public class Blur {
           oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
           {
             oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, struct.success.size()));
-            for (Map.Entry<String, String> _iter252 : struct.success.entrySet())
+            for (Map.Entry<String, String> _iter260 : struct.success.entrySet())
             {
-              oprot.writeString(_iter252.getKey());
-              oprot.writeString(_iter252.getValue());
+              oprot.writeString(_iter260.getKey());
+              oprot.writeString(_iter260.getValue());
             }
             oprot.writeMapEnd();
           }
@@ -5752,10 +5752,10 @@ public class Blur {
         if (struct.isSetSuccess()) {
           {
             oprot.writeI32(struct.success.size());
-            for (Map.Entry<String, String> _iter253 : struct.success.entrySet())
+            for (Map.Entry<String, String> _iter261 : struct.success.entrySet())
             {
-              oprot.writeString(_iter253.getKey());
-              oprot.writeString(_iter253.getValue());
+              oprot.writeString(_iter261.getKey());
+              oprot.writeString(_iter261.getValue());
             }
           }
         }
@@ -5770,15 +5770,15 @@ public class Blur {
         BitSet incoming = iprot.readBitSet(2);
         if (incoming.get(0)) {
           {
-            org.apache.thrift.protocol.TMap _map254 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, iprot.readI32());
-            struct.success = new HashMap<String,String>(2*_map254.size);
-            for (int _i255 = 0; _i255 < _map254.size; ++_i255)
+            org.apache.thrift.protocol.TMap _map262 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+            struct.success = new HashMap<String,String>(2*_map262.size);
+            for (int _i263 = 0; _i263 < _map262.size; ++_i263)
             {
-              String _key256; // required
-              String _val257; // optional
-              _key256 = iprot.readString();
-              _val257 = iprot.readString();
-              struct.success.put(_key256, _val257);
+              String _key264; // required
+              String _val265; // optional
+              _key264 = iprot.readString();
+              _val265 = iprot.readString();
+              struct.success.put(_key264, _val265);
             }
           }
           struct.setSuccessIsSet(true);
@@ -6425,13 +6425,13 @@ public class Blur {
             case 0: // SUCCESS
               if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
                 {
-                  org.apache.thrift.protocol.TList _list258 = iprot.readListBegin();
-                  struct.success = new ArrayList<String>(_list258.size);
-                  for (int _i259 = 0; _i259 < _list258.size; ++_i259)
+                  org.apache.thrift.protocol.TList _list266 = iprot.readListBegin();
+                  struct.success = new ArrayList<String>(_list266.size);
+                  for (int _i267 = 0; _i267 < _list266.size; ++_i267)
                   {
-                    String _elem260; // required
-                    _elem260 = iprot.readString();
-                    struct.success.add(_elem260);
+                    String _elem268; // required
+                    _elem268 = iprot.readString();
+                    struct.success.add(_elem268);
                   }
                   iprot.readListEnd();
                 }
@@ -6468,9 +6468,9 @@ public class Blur {
           oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
           {
             oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.success.size()));
-            for (String _iter261 : struct.success)
+            for (String _iter269 : struct.success)
             {
-              oprot.writeString(_iter261);
+              oprot.writeString(_iter269);
             }
             oprot.writeListEnd();
           }
@@ -6509,9 +6509,9 @@ public class Blur {
         if (struct.isSetSuccess()) {
           {
             oprot.writeI32(struct.success.size());
-            for (String _iter262 : struct.success)
+            for (String _iter270 : struct.success)
             {
-              oprot.writeString(_iter262);
+              oprot.writeString(_iter270);
             }
           }
         }
@@ -6526,13 +6526,13 @@ public class Blur {
         BitSet incoming = iprot.readBitSet(2);
         if (incoming.get(0)) {
           {
-            org.apache.thrift.protocol.TList _list263 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
-            struct.success = new ArrayList<String>(_list263.size);
-            for (int _i264 = 0; _i264 < _list263.size; ++_i264)
+            org.apache.thrift.protocol.TList _list271 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+            struct.success = new ArrayList<String>(_list271.size);
+            for (int _i272 = 0; _i272 < _list271.size; ++_i272)
             {
-              String _elem265; // required
-              _elem265 = iprot.readString();
-              struct.success.add(_elem265);
+              String _elem273; // required
+              _elem273 = iprot.readString();
+              struct.success.add(_elem273);
             }
           }
           struct.setSuccessIsSet(true);
@@ -7287,13 +7287,13 @@ public class Blur {
             case 0: // SUCCESS
               if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
                 {
-                  org.apache.thrift.protocol.TList _list266 = iprot.readListBegin();
-                  struct.success = new ArrayList<String>(_list266.size);
-                  for (int _i267 = 0; _i267 < _list266.size; ++_i267)
+                  org.apache.thrift.protocol.TList _list274 = iprot.readListBegin();
+                  struct.success = new ArrayList<String>(_list274.size);
+                  for (int _i275 = 0; _i275 < _list274.size; ++_i275)
                   {
-                    String _elem268; // required
-                    _elem268 = iprot.readString();
-                    struct.success.add(_elem268);
+                    String _elem276; // required
+                    _elem276 = iprot.readString();
+                    struct.success.add(_elem276);
                   }
                   iprot.readListEnd();
                 }
@@ -7330,9 +7330,9 @@ public class Blur {
           oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
           {
             oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.success.size()));
-            for (String _iter269 : struct.success)
+            for (String _iter277 : struct.success)
             {
-              oprot.writeString(_iter269);
+              oprot.writeString(_iter277);
             }
             oprot.writeListEnd();
           }
@@ -7371,9 +7371,9 @@ public class Blur {
         if (struct.isSetSuccess()) {
           {
             oprot.writeI32(struct.success.size());
-            for (String _iter270 : struct.success)
+            for (String _iter278 : struct.success)
             {
-              oprot.writeString(_iter270);
+              oprot.writeString(_iter278);
             }
           }
         }
@@ -7388,13 +7388,13 @@ public class Blur {
         BitSet incoming = iprot.readBitSet(2);
         if (incoming.get(0)) {
           {
-            org.apache.thrift.protocol.TList _list271 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
-            struct.success = new ArrayList<String>(_list271.size);
-            for (int _i272 = 0; _i272 < _list271.size; ++_i272)
+            org.apache.thrift.protocol.TList _list279 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+            struct.success = new ArrayList<String>(_list279.size);
+            for (int _i280 = 0; _i280 < _list279.size; ++_i280)
             {
-              String _elem273; // required
-              _elem273 = iprot.readString();
-              struct.success.add(_elem273);
+              String _elem281; // required
+              _elem281 = iprot.readString();
+              struct.success.add(_elem281);
             }
           }
           struct.setSuccessIsSet(true);
@@ -10692,14 +10692,14 @@ public class Blur {
             case 0: // SUCCESS
               if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
                 {
-                  org.apache.thrift.protocol.TList _list274 = iprot.readListBegin();
-                  struct.success = new ArrayList<BlurQueryStatus>(_list274.size);
-                  for (int _i275 = 0; _i275 < _list274.size; ++_i275)
+                  org.apache.thrift.protocol.TList _list282 = iprot.readListBegin();
+                  struct.success = new ArrayList<BlurQueryStatus>(_list282.size);
+                  for (int _i283 = 0; _i283 < _list282.size; ++_i283)
                   {
-                    BlurQueryStatus _elem276; // required
-                    _elem276 = new BlurQueryStatus();
-                    _elem276.read(iprot);
-                    struct.success.add(_elem276);
+                    BlurQueryStatus _elem284; // required
+                    _elem284 = new BlurQueryStatus();
+                    _elem284.read(iprot);
+                    struct.success.add(_elem284);
                   }
                   iprot.readListEnd();
                 }
@@ -10736,9 +10736,9 @@ public class Blur {
           oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
           {
             oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.success.size()));
-            for (BlurQueryStatus _iter277 : struct.success)
+            for (BlurQueryStatus _iter285 : struct.success)
             {
-              _iter277.write(oprot);
+              _iter285.write(oprot);
             }
             oprot.writeListEnd();
           }
@@ -10777,9 +10777,9 @@ public class Blur {
         if (struct.isSetSuccess()) {
           {
             oprot.writeI32(struct.success.size());
-            for (BlurQueryStatus _iter278 : struct.success)
+            for (BlurQueryStatus _iter286 : struct.success)
             {
-              _iter278.write(oprot);
+              _iter286.write(oprot);
             }
           }
         }
@@ -10794,14 +10794,14 @@ public class Blur {
         BitSet incoming = iprot.readBitSet(2);
         if (incoming.get(0)) {
           {
-            org.apache.thrift.protocol.TList _list279 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
-            struct.success = new ArrayList<BlurQueryStatus>(_list279.size);
-            for (int _i280 = 0; _i280 < _list279.size; ++_i280)
+            org.apache.thrift.protocol.TList _list287 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+            struct.success = new ArrayList<BlurQueryStatus>(_list287.size);
+            for (int _i288 = 0; _i288 < _list287.size; ++_i288)
             {
-              BlurQueryStatus _elem281; // required
-              _elem281 = new BlurQueryStatus();
-              _elem281.read(iprot);
-              struct.success.add(_elem281);
+              BlurQueryStatus _elem289; // required
+              _elem289 = new BlurQueryStatus();
+              _elem289.read(iprot);
+              struct.success.add(_elem289);
             }
           }
           struct.setSuccessIsSet(true);
@@ -11556,13 +11556,13 @@ public class Blur {
             case 0: // SUCCESS
               if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
                 {
-                  org.apache.thrift.protocol.TList _list282 = iprot.readListBegin();
-                  struct.success = new ArrayList<Long>(_list282.size);
-                  for (int _i283 = 0; _i283 < _list282.size; ++_i283)
+                  org.apache.thrift.protocol.TList _list290 = iprot.readListBegin();
+                  struct.success = new ArrayList<Long>(_list290.size);
+                  for (int _i291 = 0; _i291 < _list290.size; ++_i291)
                   {
-                    long _elem284; // required
-                    _elem284 = iprot.readI64();
-                    struct.success.add(_elem284);
+                    long _elem292; // required
+                    _elem292 = iprot.readI64();
+                    struct.success.add(_elem292);
                   }
                   iprot.readListEnd();
                 }
@@ -11599,9 +11599,9 @@ public class Blur {
           oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
           {
             oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, struct.success.size()));
-            for (long _iter285 : struct.success)
+            for (long _iter293 : struct.success)
             {
-              oprot.writeI64(_iter285);
+              oprot.writeI64(_iter293);
             }
             oprot.writeListEnd();
           }
@@ -11640,9 +11640,9 @@ public class Blur {
         if (struct.isSetSuccess()) {
           {
             oprot.writeI32(struct.success.size());
-            for (long _iter286 : struct.success)
+            for (long _iter294 : struct.success)
             {
-              oprot.writeI64(_iter286);
+              oprot.writeI64(_iter294);
             }
           }
         }
@@ -11657,13 +11657,13 @@ public class Blur {
         BitSet incoming = iprot.readBitSet(2);
         if (incoming.get(0)) {
           {
-            org.apache.thrift.protocol.TList _list287 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
-            struct.success = new ArrayList<Long>(_list287.size);
-            for (int _i288 = 0; _i288 < _list287.size; ++_i288)
+            org.apache.thrift.protocol.TList _list295 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
+            struct.success = new ArrayList<Long>(_list295.size);
+            for (int _i296 = 0; _i296 < _list295.size; ++_i296)
             {
-              long _elem289; // required
-              _elem289 = iprot.readI64();
-              struct.success.add(_elem289);
+              long _elem297; // required
+              _elem297 = iprot.readI64();
+              struct.success.add(_elem297);
             }
           }
           struct.setSuccessIsSet(true);
@@ -16174,13 +16174,13 @@ public class Blur {
             case 0: // SUCCESS
               if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
                 {
-                  org.apache.thrift.protocol.TList _list290 = iprot.readListBegin();
-                  struct.success = new ArrayList<String>(_list290.size);
-                  for (int _i291 = 0; _i291 < _list290.size; ++_i291)
+                  org.apache.thrift.protocol.TList _list298 = iprot.readListBegin();
+                  struct.success = new ArrayList<String>(_list298.size);
+                  for (int _i299 = 0; _i299 < _list298.size; ++_i299)
                   {
-                    String _elem292; // required
-                    _elem292 = iprot.readString();
-                    struct.success.add(_elem292);
+                    String _elem300; // required
+                    _elem300 = iprot.readString();
+                    struct.success.add(_elem300);
                   }
                   iprot.readListEnd();
                 }
@@ -16217,9 +16217,9 @@ public class Blur {
           oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
           {
             oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.success.size()));
-            for (String _iter293 : struct.success)
+            for (String _iter301 : struct.success)
             {
-              oprot.writeString(_iter293);
+              oprot.writeString(_iter301);
             }
             oprot.writeListEnd();
           }
@@ -16258,9 +16258,9 @@ public class Blur {
         if (struct.isSetSuccess()) {
           {
             oprot.writeI32(struct.success.size());
-            for (String _iter294 : struct.success)
+            for (String _iter302 : struct.success)
             {
-              oprot.writeString(_iter294);
+              oprot.writeString(_iter302);
             }
           }
         }
@@ -16275,13 +16275,13 @@ public class Blur {
         BitSet incoming = iprot.readBitSet(2);
         if (incoming.get(0)) {
           {
-            org.apache.thrift.protocol.TList _list295 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
-            struct.success = new ArrayList<String>(_list295.size);
-            for (int _i296 = 0; _i296 < _list295.size; ++_i296)
+            org.apache.thrift.protocol.TList _list303 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+            struct.success = new ArrayList<String>(_list303.size);
+            for (int _i304 = 0; _i304 < _list303.size; ++_i304)
             {
-              String _elem297; // required
-              _elem297 = iprot.readString();
-              struct.success.add(_elem297);
+              String _elem305; // required
+              _elem305 = iprot.readString();
+              struct.success.add(_elem305);
             }
           }
           struct.setSuccessIsSet(true);
@@ -19350,14 +19350,14 @@ public class Blur {
             case 1: // MUTATIONS
               if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
                 {
-                  org.apache.thrift.protocol.TList _list298 = iprot.readListBegin();
-                  struct.mutations = new ArrayList<RowMutation>(_list298.size);
-                  for (int _i299 = 0; _i299 < _list298.size; ++_i299)
+                  org.apache.thrift.protocol.TList _list306 = iprot.readListBegin();
+                  struct.mutations = new ArrayList<RowMutation>(_list306.size);
+                  for (int _i307 = 0; _i307 < _list306.size; ++_i307)
                   {
-                    RowMutation _elem300; // required
-                    _elem300 = new RowMutation();
-                    _elem300.read(iprot);
-                    struct.mutations.add(_elem300);
+                    RowMutation _elem308; // required
+                    _elem308 = new RowMutation();
+                    _elem308.read(iprot);
+                    struct.mutations.add(_elem308);
                   }
                   iprot.readListEnd();
                 }
@@ -19385,9 +19385,9 @@ public class Blur {
           oprot.writeFieldBegin(MUTATIONS_FIELD_DESC);
           {
             oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.mutations.size()));
-            for (RowMutation _iter301 : struct.mutations)
+            for (RowMutation _iter309 : struct.mutations)
             {
-              _iter301.write(oprot);
+              _iter309.write(oprot);
             }
             oprot.writeListEnd();
           }
@@ -19418,9 +19418,9 @@ public class Blur {
         if (struct.isSetMutations()) {
           {
             oprot.writeI32(struct.mutations.size());
-            for (RowMutation _iter302 : struct.mutations)
+            for (RowMutation _iter310 : struct.mutations)
             {
-              _iter302.write(oprot);
+              _iter310.write(oprot);
             }
           }
         }
@@ -19432,14 +19432,14 @@ public class Blur {
         BitSet incoming = iprot.readBitSet(1);
         if (incoming.get(0)) {
           {
-            org.apache.thrift.protocol.TList _list303 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
-            struct.mutations = new ArrayList<RowMutation>(_list303.size);
-            for (int _i304 = 0; _i304 < _list303.size; ++_i304)
+            org.apache.thrift.protocol.TList _list311 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+            struct.mutations = new ArrayList<RowMutation>(_list311.size);
+            for (int _i312 = 0; _i312 < _list311.size; ++_i312)
             {
-              RowMutation _elem305; // required
-              _elem305 = new RowMutation();
-              _elem305.read(iprot);
-              struct.mutations.add(_elem305);
+              RowMutation _elem313; // required
+              _elem313 = new RowMutation();
+              _elem313.read(iprot);
+              struct.mutations.add(_elem313);
             }
           }
           struct.setMutationsIsSet(true);
@@ -25003,15 +25003,15 @@ public class Blur {
             case 0: // SUCCESS
               if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
                 {
-                  org.apache.thrift.protocol.TMap _map306 = iprot.readMapBegin();
-                  struct.success = new HashMap<String,String>(2*_map306.size);
-                  for (int _i307 = 0; _i307 < _map306.size; ++_i307)
+                  org.apache.thrift.protocol.TMap _map314 = iprot.readMapBegin();
+                  struct.success = new HashMap<String,String>(2*_map314.size);
+                  for (int _i315 = 0; _i315 < _map314.size; ++_i315)
                   {
-                    String _key308; // required
-                    String _val309; // optional
-                    _key308 = iprot.readString();
-                    _val309 = iprot.readString();
-                    struct.success.put(_key308, _val309);
+                    String _key316; // required
+                    String _val317; // optional
+                    _key316 = iprot.readString();
+                    _val317 = iprot.readString();
+                    struct.success.put(_key316, _val317);
                   }
                   iprot.readMapEnd();
                 }
@@ -25048,10 +25048,10 @@ public class Blur {
           oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
           {
             oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, struct.success.size()));
-            for (Map.Entry<String, String> _iter310 : struct.success.entrySet())
+            for (Map.Entry<String, String> _iter318 : struct.success.entrySet())
             {
-              oprot.writeString(_iter310.getKey());
-              oprot.writeString(_iter310.getValue());
+              oprot.writeString(_iter318.getKey());
+              oprot.writeString(_iter318.getValue());
             }
             oprot.writeMapEnd();
           }
@@ -25090,10 +25090,10 @@ public class Blur {
         if (struct.isSetSuccess()) {
           {
             oprot.writeI32(struct.success.size());
-            for (Map.Entry<String, String> _iter311 : struct.success.entrySet())
+            for (Map.Entry<String, String> _iter319 : struct.success.entrySet())
             {
-              oprot.writeString(_iter311.getKey());
-              oprot.writeString(_iter311.getValue());
+              oprot.writeString(_iter319.getKey());
+              oprot.writeString(_iter319.getValue());
             }
           }
         }
@@ -25108,15 +25108,15 @@ public class Blur {
         BitSet incoming = iprot.readBitSet(2);
         if (incoming.get(0)) {
           {
-            org.apache.thrift.protocol.TMap _map312 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, iprot.readI32());
-            struct.success = new HashMap<String,String>(2*_map312.size);
-            for (int _i313 = 0; _i313 < _map312.size; ++_i313)
+            org.apache.thrift.protocol.TMap _map320 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+            struct.success = new HashMap<String,String>(2*_map320.size);
+            for (int _i321 = 0; _i321 < _map320.size; ++_i321)
             {
-              String _key314; // required
-              String _val315; // optional
-              _key314 = iprot.readString();
-              _val315 = iprot.readString();
-              struct.success.put(_key314, _val315);
+              String _key322; // required
+              String _val323; // optional
+              _key322 = iprot.readString();
+              _val323 = iprot.readString();
+              struct.success.put(_key322, _val323);
             }
           }
           struct.setSuccessIsSet(true);


Mime
View raw message