commit c125fa0ba32a7364f08661d64ffdc527716dbfe8
author Jarek Jarcec Cecho <jarcec@apache.org> Wed Oct 23 11:43:44 2013 -0700
committer Jarek Jarcec Cecho <jarcec@apache.org> Wed Oct 23 11:43:44 2013 -0700
tree 2496e9921c069b533c76d23194467b4a93f72d15
parent 5683f07c4cf140b0c464c6ce19720ef030272f85

WilsonBinConfTests are failing when running against Pig 0.12.0

src/java/datafu/pig/stats/WilsonBinConf.java

diff --git a/src/java/datafu/pig/stats/WilsonBinConf.java b/src/java/datafu/pig/stats/WilsonBinConf.java
index a1448ad..a4a4ad3 100644
--- a/src/java/datafu/pig/stats/WilsonBinConf.java
+++ b/src/java/datafu/pig/stats/WilsonBinConf.java
@@ -24,7 +24,9 @@
 import org.apache.pig.data.DataType;
 import org.apache.pig.data.Tuple;
 import org.apache.pig.data.TupleFactory;
+import org.apache.pig.impl.logicalLayer.FrontendException;
 import org.apache.pig.impl.logicalLayer.schema.Schema;
+import org.apache.pig.impl.logicalLayer.schema.Schema.FieldSchema;
 
 import com.google.common.collect.ImmutableList;
 
@@ -125,8 +127,14 @@
   @Override
   public Schema outputSchema(Schema input)
   {
-    return new Schema(ImmutableList.of(
-            new Schema.FieldSchema("lower", DataType.DOUBLE),
-            new Schema.FieldSchema("upper", DataType.DOUBLE)));
+    try {
+      Schema innerSchema =  new  Schema(ImmutableList.of(
+              new Schema.FieldSchema("lower", DataType.DOUBLE),
+              new Schema.FieldSchema("upper", DataType.DOUBLE)));
+
+      return new Schema(new FieldSchema(null, innerSchema, DataType.TUPLE));
+    } catch(FrontendException e) {
+      throw new RuntimeException(e);
+    }
   }
 }