Enhanced the tests

Author: xerial

silk/src/main/scala/xerial/silk/index/ColumnarEncoder.scala

@@ -23,12 +23,12 @@ case object JavassistEncoder extends EncoderType
  */
 class ColumnarEncoder(encoderType:EncoderType = ReflectionEncoder) extends Logger {
 
-  private var writer = Seq.newBuilder[CompressedFieldWriter]
+  private var writer = List.empty[CompressedFieldWriter]
 
   private val encoder = new StructureEncoder(new FieldWriterFactory {
     def newWriter(name: String, tpe: ObjectType) = {
       val w = new CompressedFieldWriter(name, tpe)
-      writer += w
+      writer = w :: writer
       w
     }},
     encoder = encoderType match {
@@ -44,11 +44,13 @@ class ColumnarEncoder(encoderType:EncoderType = ReflectionEncoder) extends Logge
 
   def compress : GenSeq[ColumnBlock] = {
     trace("apply compression")
-    for(w <- writer.result) yield {
+    for(w <- writer) yield {
       w.columnBlock
     }
   }
 
 
 
+
+
 }

silk/src/test/scala/xerial/silk/index/CompressedFieldWriterTest.scala

@@ -96,41 +96,43 @@ class CompressedFieldWriterTest extends SilkSpec {
     }
 
     "test performances" taggedAs("perf") in {
-      val N = 10000
-      val R = 10
-      val emps = randomEmpDataSet(N)
+      val R = 5
+
       debug("start bench")
       time("encode", repeat = R) {
-
-        block("reflection") {
-          val e = new ColumnarEncoder(ReflectionEncoder)
-          e.encode(emps)
-          e.compress
-        }
-
-        block("javassist") {
-          val e = new ColumnarEncoder(JavassistEncoder)
-          e.encode(emps)
-          e.compress
-        }
-
-        block("jserializer") {
-          val b = new ByteArrayOutputStream
-          val s = new ObjectOutputStream(b)
-          emps.foreach { e => s.writeObject(e) }
-          s.close
-          val out = b.toByteArray
-          Snappy.compress(out)
-        }
-
-        block("kryo") {
-          val b = new ByteArrayOutputStream
-          val o = new Output(b)
-          val k = new Kryo()
-          emps.foreach { e => k.writeObject(o, e) }
-          o.close
-          val out = b.toByteArray
-          Snappy.compress(out)
+        for(n <- Seq(100, 1000, 10000))  {
+          val N = n
+          val emps = randomEmpDataSet(N)
+          block(s"reflection$N") {
+            val e = new ColumnarEncoder(ReflectionEncoder)
+            e.encode(emps)
+            //e.compress
+          }
+
+          block(s"javassist$N") {
+            val e = new ColumnarEncoder(JavassistEncoder)
+            e.encode(emps)
+            // e.compress
+          }
+
+          block(s"jserializer$N") {
+            val b = new ByteArrayOutputStream
+            val s = new ObjectOutputStream(b)
+            emps.foreach { e => s.writeObject(e) }
+            s.close
+            val out = b.toByteArray
+            //Snappy.compress(out)
+          }
+
+          block(s"kryo$N") {
+            val b = new ByteArrayOutputStream
+            val o = new Output(b)
+            val k = new Kryo()
+            emps.foreach { e => k.writeObject(o, e) }
+            o.close
+            val out = b.toByteArray
+            //Snappy.compress(out)
+          }
         }
 
       }