hive-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From hashut...@apache.org
Subject svn commit: r1517888 [2/6] - in /hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions: ./ aggregates/ aggregates/gen/ gen/ templates/
Date Tue, 27 Aug 2013 17:10:01 GMT
Modified: hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/VectorUDFTimestampFieldLong.java
URL: http://svn.apache.org/viewvc/hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/VectorUDFTimestampFieldLong.java?rev=1517888&r1=1517887&r2=1517888&view=diff
==============================================================================
--- hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/VectorUDFTimestampFieldLong.java (original)
+++ hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/VectorUDFTimestampFieldLong.java Tue Aug 27 17:09:56 2013
@@ -29,19 +29,25 @@ import org.apache.hadoop.hive.ql.exec.ve
  */
 public abstract class VectorUDFTimestampFieldLong extends VectorExpression {
 
-  protected final int colNum;
-  protected final int outputColumn;
-  protected final int field;
-  protected final Calendar calendar = Calendar.getInstance();
-  protected final Timestamp ts = new Timestamp(0);
+  private static final long serialVersionUID = 1L;
+
+  protected int colNum;
+  protected int outputColumn;
+  protected int field;
+  protected transient final Calendar calendar = Calendar.getInstance();
+  protected transient final Timestamp ts = new Timestamp(0);
 
   public VectorUDFTimestampFieldLong(int field, int colNum, int outputColumn) {
-    super();
+    this();
     this.colNum = colNum;
     this.outputColumn = outputColumn;
     this.field = field;
   }
 
+  public VectorUDFTimestampFieldLong() {
+    super();
+  }
+
   protected final Timestamp getTimestamp(long nanos) {
     /*
      * new Timestamp() stores the millisecond precision values in the nanos field.
@@ -134,4 +140,24 @@ public abstract class VectorUDFTimestamp
     return "long";
   }
 
+  public int getColNum() {
+    return colNum;
+  }
+
+  public void setColNum(int colNum) {
+    this.colNum = colNum;
+  }
+
+  public int getField() {
+    return field;
+  }
+
+  public void setField(int field) {
+    this.field = field;
+  }
+
+  public void setOutputColumn(int outputColumn) {
+    this.outputColumn = outputColumn;
+  }
+
 }

Modified: hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/VectorUDFUnixTimeStampLong.java
URL: http://svn.apache.org/viewvc/hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/VectorUDFUnixTimeStampLong.java?rev=1517888&r1=1517887&r2=1517888&view=diff
==============================================================================
--- hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/VectorUDFUnixTimeStampLong.java (original)
+++ hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/VectorUDFUnixTimeStampLong.java Tue Aug 27 17:09:56 2013
@@ -24,6 +24,8 @@ package org.apache.hadoop.hive.ql.exec.v
  */
 public final class VectorUDFUnixTimeStampLong extends VectorUDFTimestampFieldLong {
 
+  private static final long serialVersionUID = 1L;
+
   @Override
   protected long getField(long time) {
     long ms = (time / (1000*1000*1000)) * 1000;
@@ -40,4 +42,8 @@ public final class VectorUDFUnixTimeStam
     super(-1, colNum, outputColumn);
   }
 
+  public VectorUDFUnixTimeStampLong() {
+    super();
+  }
+
 }

Modified: hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/VectorUDFWeekOfYearLong.java
URL: http://svn.apache.org/viewvc/hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/VectorUDFWeekOfYearLong.java?rev=1517888&r1=1517887&r2=1517888&view=diff
==============================================================================
--- hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/VectorUDFWeekOfYearLong.java (original)
+++ hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/VectorUDFWeekOfYearLong.java Tue Aug 27 17:09:56 2013
@@ -26,11 +26,21 @@ import java.util.Calendar;
  */
 public final class VectorUDFWeekOfYearLong extends VectorUDFTimestampFieldLong {
 
+  private static final long serialVersionUID = 1L;
+
   public VectorUDFWeekOfYearLong(int colNum, int outputColumn) {
     super(Calendar.WEEK_OF_YEAR, colNum, outputColumn);
+    initCalendar();
+  }
+
+  public VectorUDFWeekOfYearLong() {
+    super();
+    initCalendar();
+  }
+
+  private void initCalendar() {
     /* code copied over from UDFWeekOfYear implementation */
     calendar.setFirstDayOfWeek(Calendar.MONDAY);
     calendar.setMinimalDaysInFirstWeek(4);
   }
-
 }

Modified: hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/VectorUDFYearLong.java
URL: http://svn.apache.org/viewvc/hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/VectorUDFYearLong.java?rev=1517888&r1=1517887&r2=1517888&view=diff
==============================================================================
--- hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/VectorUDFYearLong.java (original)
+++ hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/VectorUDFYearLong.java Tue Aug 27 17:09:56 2013
@@ -27,10 +27,11 @@ import java.util.Calendar;
  */
 public final class VectorUDFYearLong extends VectorUDFTimestampFieldLong {
 
+  private static final long serialVersionUID = 1L;
   /* year boundaries in nanoseconds */
-  static final long[] YEAR_BOUNDARIES;
-  static final int MIN_YEAR = 1901;
-  static final int MAX_YEAR = 2038;
+  static transient final long[] YEAR_BOUNDARIES;
+  static transient final int MIN_YEAR = 1901;
+  static transient final int MAX_YEAR = 2038;
 
   static {
     YEAR_BOUNDARIES = new long[MAX_YEAR-MIN_YEAR];
@@ -60,4 +61,7 @@ public final class VectorUDFYearLong ext
     super(Calendar.YEAR, colNum, outputColumn);
   }
 
+  public VectorUDFYearLong() {
+    super();
+  }
 }

Modified: hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/VectorAggregateExpression.java
URL: http://svn.apache.org/viewvc/hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/VectorAggregateExpression.java?rev=1517888&r1=1517887&r2=1517888&view=diff
==============================================================================
--- hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/VectorAggregateExpression.java (original)
+++ hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/VectorAggregateExpression.java Tue Aug 27 17:09:56 2013
@@ -18,6 +18,8 @@
 
 package org.apache.hadoop.hive.ql.exec.vector.expressions.aggregates;
 
+import java.io.Serializable;
+
 import org.apache.hadoop.hive.ql.exec.vector.VectorAggregationBufferRow;
 import org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch;
 import org.apache.hadoop.hive.ql.metadata.HiveException;
@@ -27,12 +29,14 @@ import org.apache.hadoop.hive.serde2.obj
 /**
  * Base class for aggregation expressions.
  */
-public abstract class VectorAggregateExpression  {
+public abstract class VectorAggregateExpression  implements Serializable {
+
+  private static final long serialVersionUID = 1L;
 
   /**
    * Buffer interface to store aggregates.
    */
-  public static interface AggregationBuffer {
+  public static interface AggregationBuffer extends Serializable {
     int getVariableSize();
   };
 

Modified: hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/VectorUDAFCount.java
URL: http://svn.apache.org/viewvc/hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/VectorUDAFCount.java?rev=1517888&r1=1517887&r2=1517888&view=diff
==============================================================================
--- hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/VectorUDAFCount.java (original)
+++ hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/VectorUDAFCount.java Tue Aug 27 17:09:56 2013
@@ -37,12 +37,17 @@ import org.apache.hadoop.io.LongWritable
 @Description(name = "count", value = "_FUNC_(expr) - Returns the count (vectorized)")
 public class VectorUDAFCount extends VectorAggregateExpression {
 
+  private static final long serialVersionUID = 1L;
+
     /**
      * class for storing the current aggregate value.
      */
     static class Aggregation implements AggregationBuffer {
-      private long value;
-      private boolean isNull;
+
+      private static final long serialVersionUID = 1L;
+
+      transient private long value;
+      transient private boolean isNull;
 
       public void initIfNull() {
         if (isNull) {
@@ -57,12 +62,16 @@ public class VectorUDAFCount extends Vec
       }
     }
 
-    private final VectorExpression inputExpression;
-  private final LongWritable result;
+    private VectorExpression inputExpression = null;
+    transient private final LongWritable result;
 
     public VectorUDAFCount(VectorExpression inputExpression) {
-      super();
+      this();
       this.inputExpression = inputExpression;
+    }
+
+    public VectorUDAFCount() {
+      super();
       result = new LongWritable(0);
     }
 
@@ -265,5 +274,13 @@ public class VectorUDAFCount extends Vec
     public void init(AggregationDesc desc) throws HiveException {
       // No-op
     }
+
+    public VectorExpression getInputExpression() {
+      return inputExpression;
+    }
+
+    public void setInputExpression(VectorExpression inputExpression) {
+      this.inputExpression = inputExpression;
+    }
 }
 

Modified: hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/VectorUDAFCountStar.java
URL: http://svn.apache.org/viewvc/hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/VectorUDAFCountStar.java?rev=1517888&r1=1517887&r2=1517888&view=diff
==============================================================================
--- hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/VectorUDAFCountStar.java (original)
+++ hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/VectorUDAFCountStar.java Tue Aug 27 17:09:56 2013
@@ -35,12 +35,17 @@ import org.apache.hadoop.io.LongWritable
 @Description(name = "count", value = "_FUNC_(expr) - Returns count(*) (vectorized)")
 public class VectorUDAFCountStar extends VectorAggregateExpression {
 
+  private static final long serialVersionUID = 1L;
+
     /**
      * class for storing the current aggregate value.
      */
     static class Aggregation implements AggregationBuffer {
-      private long value;
-      private boolean isNull;
+
+      private static final long serialVersionUID = 1L;
+
+      transient private long value;
+      transient private boolean isNull;
 
       @Override
       public int getVariableSize() {
@@ -48,9 +53,13 @@ public class VectorUDAFCountStar extends
       }
     }
 
-    private final LongWritable result;
+    transient private final LongWritable result;
 
     public VectorUDAFCountStar(VectorExpression inputExpression) {
+      this();
+    }
+
+    public VectorUDAFCountStar() {
       super();
       result = new LongWritable(0);
     }

Modified: hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFAvgDouble.java
URL: http://svn.apache.org/viewvc/hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFAvgDouble.java?rev=1517888&r1=1517887&r2=1517888&view=diff
==============================================================================
--- hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFAvgDouble.java (original)
+++ hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFAvgDouble.java Tue Aug 27 17:09:56 2013
@@ -44,12 +44,17 @@ import org.apache.hadoop.hive.serde2.obj
 @Description(name = "avg",
     value = "_FUNC_(expr) - Returns the average value of expr (vectorized, type: double)")
 public class VectorUDAFAvgDouble extends VectorAggregateExpression {
+
+    private static final long serialVersionUID = 1L;
     
     /** class for storing the current aggregate value. */
     static class Aggregation implements AggregationBuffer {
-      private double sum;
-      private long count;
-      private boolean isNull;
+
+      private static final long serialVersionUID = 1L;
+
+      transient private double sum;
+      transient private long count;
+      transient private boolean isNull;
       
       public void sumValue(double value) {
         if (isNull) {
@@ -69,20 +74,23 @@ public class VectorUDAFAvgDouble extends
     }
     
     private VectorExpression inputExpression;
-    private Object[] partialResult;
-    private LongWritable resultCount;
-    private DoubleWritable resultSum;
-    private StructObjectInspector soi;
+    transient private Object[] partialResult;
+    transient private LongWritable resultCount;
+    transient private DoubleWritable resultSum;
+    transient private StructObjectInspector soi;
         
     public VectorUDAFAvgDouble(VectorExpression inputExpression) {
-      super();
+      this();
       this.inputExpression = inputExpression;
+    }
+
+    public VectorUDAFAvgDouble() {
+      super();
       partialResult = new Object[2];
       resultCount = new LongWritable();
       resultSum = new DoubleWritable();
       partialResult[0] = resultCount;
       partialResult[1] = resultSum;
-      
       initPartialResultInspector();
     }
 
@@ -454,5 +462,13 @@ public class VectorUDAFAvgDouble extends
   public void init(AggregationDesc desc) throws HiveException {
     // No-op
   }
+  
+  public VectorExpression getInputExpression() {
+    return inputExpression;
+  }
+
+  public void setInputExpression(VectorExpression inputExpression) {
+    this.inputExpression = inputExpression;
+  }
 }
 

Modified: hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFAvgLong.java
URL: http://svn.apache.org/viewvc/hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFAvgLong.java?rev=1517888&r1=1517887&r2=1517888&view=diff
==============================================================================
--- hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFAvgLong.java (original)
+++ hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFAvgLong.java Tue Aug 27 17:09:56 2013
@@ -22,21 +22,20 @@ import java.util.ArrayList;
 import java.util.List;
 
 import org.apache.hadoop.hive.ql.exec.Description;
-import org.apache.hadoop.hive.ql.exec.vector.expressions.VectorExpression;
-import org.apache.hadoop.hive.ql.exec.vector.expressions.aggregates.VectorAggregateExpression;
+import org.apache.hadoop.hive.ql.exec.vector.LongColumnVector;
 import org.apache.hadoop.hive.ql.exec.vector.VectorAggregationBufferRow;
 import org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch;
-import org.apache.hadoop.hive.ql.exec.vector.LongColumnVector;
-import org.apache.hadoop.hive.ql.exec.vector.DoubleColumnVector;
+import org.apache.hadoop.hive.ql.exec.vector.expressions.VectorExpression;
+import org.apache.hadoop.hive.ql.exec.vector.expressions.aggregates.VectorAggregateExpression;
 import org.apache.hadoop.hive.ql.metadata.HiveException;
 import org.apache.hadoop.hive.ql.plan.AggregationDesc;
 import org.apache.hadoop.hive.ql.util.JavaDataModel;
-import org.apache.hadoop.io.LongWritable;
 import org.apache.hadoop.hive.serde2.io.DoubleWritable;
 import org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector;
 import org.apache.hadoop.hive.serde2.objectinspector.ObjectInspectorFactory;
 import org.apache.hadoop.hive.serde2.objectinspector.StructObjectInspector;
 import org.apache.hadoop.hive.serde2.objectinspector.primitive.PrimitiveObjectInspectorFactory;
+import org.apache.hadoop.io.LongWritable;
 
 /**
  * Generated from template VectorUDAFAvg.txt.
@@ -44,16 +43,21 @@ import org.apache.hadoop.hive.serde2.obj
 @Description(name = "avg",
     value = "_FUNC_(expr) - Returns the average value of expr (vectorized, type: long)")
 public class VectorUDAFAvgLong extends VectorAggregateExpression {
-    
+
+    private static final long serialVersionUID = 1L;
+
     /** class for storing the current aggregate value. */
     static class Aggregation implements AggregationBuffer {
-      private double sum;
-      private long count;
-      private boolean isNull;
-      
+
+      private static final long serialVersionUID = 1L;
+
+      transient private double sum = 0;
+      transient private long count = 0;
+      transient private boolean isNull;
+
       public void sumValue(long value) {
         if (isNull) {
-          sum = value; 
+          sum = value;
           count = 1;
           isNull = false;
         } else {
@@ -67,22 +71,25 @@ public class VectorUDAFAvgLong extends V
         throw new UnsupportedOperationException();
       }
     }
-    
+
     private VectorExpression inputExpression;
-    private Object[] partialResult;
-    private LongWritable resultCount;
-    private DoubleWritable resultSum;
-    private StructObjectInspector soi;
-        
+    transient private Object[] partialResult;
+    transient private LongWritable resultCount;
+    transient private DoubleWritable resultSum;
+    transient private StructObjectInspector soi;
+
     public VectorUDAFAvgLong(VectorExpression inputExpression) {
-      super();
+      this();
       this.inputExpression = inputExpression;
+    }
+
+    public VectorUDAFAvgLong() {
+      super();
       partialResult = new Object[2];
       resultCount = new LongWritable();
       resultSum = new DoubleWritable();
       partialResult[0] = resultCount;
       partialResult[1] = resultSum;
-      
       initPartialResultInspector();
     }
 
@@ -95,7 +102,7 @@ public class VectorUDAFAvgLong extends V
         fname.add("sum");
         soi = ObjectInspectorFactory.getStandardStructObjectInspector(fname, foi);
     }
-    
+
     private Aggregation getCurrentAggregationBuffer(
         VectorAggregationBufferRow[] aggregationBufferSets,
         int bufferIndex,
@@ -104,21 +111,21 @@ public class VectorUDAFAvgLong extends V
       Aggregation myagg = (Aggregation) mySet.getAggregationBuffer(bufferIndex);
       return myagg;
     }
-    
+
     @Override
     public void aggregateInputSelection(
       VectorAggregationBufferRow[] aggregationBufferSets,
-      int bufferIndex, 
+      int bufferIndex,
       VectorizedRowBatch batch) throws HiveException {
-      
+
       int batchSize = batch.size;
-      
+
       if (batchSize == 0) {
         return;
       }
-      
+
       inputExpression.evaluate(batch);
-      
+
        LongColumnVector inputVector = ( LongColumnVector)batch.
         cols[this.inputExpression.getOutputColumn()];
       long[] vector = inputVector.vector;
@@ -172,12 +179,12 @@ public class VectorUDAFAvgLong extends V
 
       for (int i=0; i < batchSize; ++i) {
         Aggregation myagg = getCurrentAggregationBuffer(
-          aggregationBufferSets, 
+          aggregationBufferSets,
           bufferIndex,
           i);
         myagg.sumValue(value);
       }
-    } 
+    }
 
     private void iterateNoNullsSelectionWithAggregationSelection(
       VectorAggregationBufferRow[] aggregationBufferSets,
@@ -185,10 +192,10 @@ public class VectorUDAFAvgLong extends V
       long[] values,
       int[] selection,
       int batchSize) {
-      
+
       for (int i=0; i < batchSize; ++i) {
         Aggregation myagg = getCurrentAggregationBuffer(
-          aggregationBufferSets, 
+          aggregationBufferSets,
           bufferIndex,
           i);
         myagg.sumValue(values[selection[i]]);
@@ -202,7 +209,7 @@ public class VectorUDAFAvgLong extends V
       int batchSize) {
       for (int i=0; i < batchSize; ++i) {
         Aggregation myagg = getCurrentAggregationBuffer(
-          aggregationBufferSets, 
+          aggregationBufferSets,
           bufferIndex,
           i);
         myagg.sumValue(values[i]);
@@ -216,17 +223,17 @@ public class VectorUDAFAvgLong extends V
       int batchSize,
       int[] selection,
       boolean[] isNull) {
-      
+
       for (int i=0; i < batchSize; ++i) {
         if (!isNull[selection[i]]) {
           Aggregation myagg = getCurrentAggregationBuffer(
-            aggregationBufferSets, 
+            aggregationBufferSets,
             bufferIndex,
             i);
           myagg.sumValue(value);
         }
       }
-      
+
     }
 
     private void iterateHasNullsRepeatingWithAggregationSelection(
@@ -239,7 +246,7 @@ public class VectorUDAFAvgLong extends V
       for (int i=0; i < batchSize; ++i) {
         if (!isNull[i]) {
           Aggregation myagg = getCurrentAggregationBuffer(
-            aggregationBufferSets, 
+            aggregationBufferSets,
             bufferIndex,
             i);
           myagg.sumValue(value);
@@ -259,7 +266,7 @@ public class VectorUDAFAvgLong extends V
         int i = selection[j];
         if (!isNull[i]) {
           Aggregation myagg = getCurrentAggregationBuffer(
-            aggregationBufferSets, 
+            aggregationBufferSets,
             bufferIndex,
             j);
           myagg.sumValue(values[i]);
@@ -277,7 +284,7 @@ public class VectorUDAFAvgLong extends V
       for (int i=0; i < batchSize; ++i) {
         if (!isNull[i]) {
           Aggregation myagg = getCurrentAggregationBuffer(
-            aggregationBufferSets, 
+            aggregationBufferSets,
             bufferIndex,
             i);
           myagg.sumValue(values[i]);
@@ -285,26 +292,26 @@ public class VectorUDAFAvgLong extends V
       }
    }
 
-    
+
     @Override
-    public void aggregateInput(AggregationBuffer agg, VectorizedRowBatch batch) 
+    public void aggregateInput(AggregationBuffer agg, VectorizedRowBatch batch)
         throws HiveException {
-        
+
         inputExpression.evaluate(batch);
-        
-        LongColumnVector inputVector = 
+
+        LongColumnVector inputVector =
             (LongColumnVector)batch.cols[this.inputExpression.getOutputColumn()];
-        
+
         int batchSize = batch.size;
-        
+
         if (batchSize == 0) {
           return;
         }
-        
+
         Aggregation myagg = (Aggregation)agg;
-  
+
         long[] vector = inputVector.vector;
-        
+
         if (inputVector.isRepeating) {
           if (inputVector.noNulls) {
             if (myagg.isNull) {
@@ -317,7 +324,7 @@ public class VectorUDAFAvgLong extends V
           }
           return;
         }
-        
+
         if (!batch.selectedInUse && inputVector.noNulls) {
           iterateNoSelectionNoNulls(myagg, vector, batchSize);
         }
@@ -331,14 +338,14 @@ public class VectorUDAFAvgLong extends V
           iterateSelectionHasNulls(myagg, vector, batchSize, inputVector.isNull, batch.selected);
         }
     }
-  
+
     private void iterateSelectionHasNulls(
-        Aggregation myagg, 
-        long[] vector, 
+        Aggregation myagg,
+        long[] vector,
         int batchSize,
-        boolean[] isNull, 
+        boolean[] isNull,
         int[] selected) {
-      
+
       for (int j=0; j< batchSize; ++j) {
         int i = selected[j];
         if (!isNull[i]) {
@@ -355,17 +362,17 @@ public class VectorUDAFAvgLong extends V
     }
 
     private void iterateSelectionNoNulls(
-        Aggregation myagg, 
-        long[] vector, 
-        int batchSize, 
+        Aggregation myagg,
+        long[] vector,
+        int batchSize,
         int[] selected) {
-      
+
       if (myagg.isNull) {
         myagg.isNull = false;
         myagg.sum = 0;
         myagg.count = 0;
       }
-      
+
       for (int i=0; i< batchSize; ++i) {
         long value = vector[selected[i]];
         myagg.sum += value;
@@ -374,15 +381,15 @@ public class VectorUDAFAvgLong extends V
     }
 
     private void iterateNoSelectionHasNulls(
-        Aggregation myagg, 
-        long[] vector, 
+        Aggregation myagg,
+        long[] vector,
         int batchSize,
         boolean[] isNull) {
-      
+
       for(int i=0;i<batchSize;++i) {
         if (!isNull[i]) {
           long value = vector[i];
-          if (myagg.isNull) { 
+          if (myagg.isNull) {
             myagg.isNull = false;
             myagg.sum = 0;
             myagg.count = 0;
@@ -394,15 +401,15 @@ public class VectorUDAFAvgLong extends V
     }
 
     private void iterateNoSelectionNoNulls(
-        Aggregation myagg, 
-        long[] vector, 
+        Aggregation myagg,
+        long[] vector,
         int batchSize) {
       if (myagg.isNull) {
         myagg.isNull = false;
         myagg.sum = 0;
         myagg.count = 0;
       }
-      
+
       for (int i=0;i<batchSize;++i) {
         long value = vector[i];
         myagg.sum += value;
@@ -435,11 +442,11 @@ public class VectorUDAFAvgLong extends V
         return partialResult;
       }
     }
-    
+
   @Override
     public ObjectInspector getOutputObjectInspector() {
     return soi;
-  }     
+  }
 
   @Override
   public int getAggregationBufferFixedSize() {
@@ -454,5 +461,13 @@ public class VectorUDAFAvgLong extends V
   public void init(AggregationDesc desc) throws HiveException {
     // No-op
   }
+
+  public VectorExpression getInputExpression() {
+    return inputExpression;
+  }
+
+  public void setInputExpression(VectorExpression inputExpression) {
+    this.inputExpression = inputExpression;
+  }
 }
 

Modified: hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFMaxDouble.java
URL: http://svn.apache.org/viewvc/hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFMaxDouble.java?rev=1517888&r1=1517887&r2=1517888&view=diff
==============================================================================
--- hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFMaxDouble.java (original)
+++ hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFMaxDouble.java Tue Aug 27 17:09:56 2013
@@ -38,13 +38,18 @@ import org.apache.hadoop.hive.serde2.obj
 @Description(name = "max", 
     value = "_FUNC_(expr) - Returns the maximum value of expr (vectorized, type: double)")
 public class VectorUDAFMaxDouble extends VectorAggregateExpression {
+   
+    private static final long serialVersionUID = 1L;
     
     /** 
      * class for storing the current aggregate value.
      */
     static private final class Aggregation implements AggregationBuffer {
-      private double value;
-      private boolean isNull;
+
+      private static final long serialVersionUID = 1L;
+
+      transient private double value;
+      transient private boolean isNull;
 
       public void checkValue(double value) {
         if (isNull) {
@@ -62,12 +67,16 @@ public class VectorUDAFMaxDouble extends
     }
     
     private VectorExpression inputExpression;
-    private VectorExpressionWriter resultWriter;
+    private transient VectorExpressionWriter resultWriter;
     
     public VectorUDAFMaxDouble(VectorExpression inputExpression) {
-      super();
+      this();
       this.inputExpression = inputExpression;
     }
+
+    public VectorUDAFMaxDouble() {
+      super();
+    }
     
     @Override
     public void init(AggregationDesc desc) throws HiveException {
@@ -421,5 +430,12 @@ public class VectorUDAFMaxDouble extends
       model.memoryAlign());
   }
 
+  public VectorExpression getInputExpression() {
+    return inputExpression;
+  }
+
+  public void setInputExpression(VectorExpression inputExpression) {
+    this.inputExpression = inputExpression;
+  }
 }
 

Modified: hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFMaxLong.java
URL: http://svn.apache.org/viewvc/hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFMaxLong.java?rev=1517888&r1=1517887&r2=1517888&view=diff
==============================================================================
--- hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFMaxLong.java (original)
+++ hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFMaxLong.java Tue Aug 27 17:09:56 2013
@@ -38,13 +38,18 @@ import org.apache.hadoop.hive.serde2.obj
 @Description(name = "max", 
     value = "_FUNC_(expr) - Returns the maximum value of expr (vectorized, type: long)")
 public class VectorUDAFMaxLong extends VectorAggregateExpression {
+   
+    private static final long serialVersionUID = 1L;
     
     /** 
      * class for storing the current aggregate value.
      */
     static private final class Aggregation implements AggregationBuffer {
-      private long value;
-      private boolean isNull;
+
+      private static final long serialVersionUID = 1L;
+
+      transient private long value;
+      transient private boolean isNull;
 
       public void checkValue(long value) {
         if (isNull) {
@@ -62,12 +67,16 @@ public class VectorUDAFMaxLong extends V
     }
     
     private VectorExpression inputExpression;
-    private VectorExpressionWriter resultWriter;
+    private transient VectorExpressionWriter resultWriter;
     
     public VectorUDAFMaxLong(VectorExpression inputExpression) {
-      super();
+      this();
       this.inputExpression = inputExpression;
     }
+
+    public VectorUDAFMaxLong() {
+      super();
+    }
     
     @Override
     public void init(AggregationDesc desc) throws HiveException {
@@ -421,5 +430,12 @@ public class VectorUDAFMaxLong extends V
       model.memoryAlign());
   }
 
+  public VectorExpression getInputExpression() {
+    return inputExpression;
+  }
+
+  public void setInputExpression(VectorExpression inputExpression) {
+    this.inputExpression = inputExpression;
+  }
 }
 

Modified: hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFMaxString.java
URL: http://svn.apache.org/viewvc/hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFMaxString.java?rev=1517888&r1=1517887&r2=1517888&view=diff
==============================================================================
--- hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFMaxString.java (original)
+++ hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFMaxString.java Tue Aug 27 17:09:56 2013
@@ -41,15 +41,19 @@ import org.apache.hadoop.io.Text;
     value = "_FUNC_(expr) - Returns the minimum value of expr (vectorized, type: string)")
 public class VectorUDAFMaxString extends VectorAggregateExpression {
 
+    private static final long serialVersionUID = 1L;
+
     /** 
      * class for storing the current aggregate value.
      */
     static private final class Aggregation implements AggregationBuffer {
 
-      private final static int MIN_BUFFER_SIZE = 16;
-      private byte[] bytes = new byte[MIN_BUFFER_SIZE];
-      private int length;
-      private boolean isNull;
+      private static final long serialVersionUID = 1L;
+
+      transient private final static int MIN_BUFFER_SIZE = 16;
+      transient private byte[] bytes = new byte[MIN_BUFFER_SIZE];
+      transient private int length;
+      transient private boolean isNull;
 
       public void checkValue(byte[] bytes, int start, int length) {
         if (isNull) {
@@ -75,15 +79,18 @@ public class VectorUDAFMaxString extends
         JavaDataModel model = JavaDataModel.get();
         return model.lengthForByteArrayOfSize(bytes.length);
       }
-
     }
     
     private VectorExpression inputExpression;
-    private Text result;
+    transient private Text result;
     
     public VectorUDAFMaxString(VectorExpression inputExpression) {
-      super();
+      this();
       this.inputExpression = inputExpression;
+    }
+
+    public VectorUDAFMaxString() {
+      super();
       result = new Text();
     }
     
@@ -381,5 +388,13 @@ public class VectorUDAFMaxString extends
     public void init(AggregationDesc desc) throws HiveException {
       // No-op
     }
+
+    public VectorExpression getInputExpression() {
+      return inputExpression;
+    }
+
+    public void setInputExpression(VectorExpression inputExpression) {
+      this.inputExpression = inputExpression;
+    }
 }
 

Modified: hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFMinDouble.java
URL: http://svn.apache.org/viewvc/hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFMinDouble.java?rev=1517888&r1=1517887&r2=1517888&view=diff
==============================================================================
--- hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFMinDouble.java (original)
+++ hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFMinDouble.java Tue Aug 27 17:09:56 2013
@@ -38,13 +38,18 @@ import org.apache.hadoop.hive.serde2.obj
 @Description(name = "min", 
     value = "_FUNC_(expr) - Returns the minimum value of expr (vectorized, type: double)")
 public class VectorUDAFMinDouble extends VectorAggregateExpression {
+   
+    private static final long serialVersionUID = 1L;
     
     /** 
      * class for storing the current aggregate value.
      */
     static private final class Aggregation implements AggregationBuffer {
-      private double value;
-      private boolean isNull;
+
+      private static final long serialVersionUID = 1L;
+
+      transient private double value;
+      transient private boolean isNull;
 
       public void checkValue(double value) {
         if (isNull) {
@@ -62,12 +67,16 @@ public class VectorUDAFMinDouble extends
     }
     
     private VectorExpression inputExpression;
-    private VectorExpressionWriter resultWriter;
+    private transient VectorExpressionWriter resultWriter;
     
     public VectorUDAFMinDouble(VectorExpression inputExpression) {
-      super();
+      this();
       this.inputExpression = inputExpression;
     }
+
+    public VectorUDAFMinDouble() {
+      super();
+    }
     
     @Override
     public void init(AggregationDesc desc) throws HiveException {
@@ -421,5 +430,12 @@ public class VectorUDAFMinDouble extends
       model.memoryAlign());
   }
 
+  public VectorExpression getInputExpression() {
+    return inputExpression;
+  }
+
+  public void setInputExpression(VectorExpression inputExpression) {
+    this.inputExpression = inputExpression;
+  }
 }
 

Modified: hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFMinLong.java
URL: http://svn.apache.org/viewvc/hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFMinLong.java?rev=1517888&r1=1517887&r2=1517888&view=diff
==============================================================================
--- hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFMinLong.java (original)
+++ hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFMinLong.java Tue Aug 27 17:09:56 2013
@@ -38,13 +38,18 @@ import org.apache.hadoop.hive.serde2.obj
 @Description(name = "min", 
     value = "_FUNC_(expr) - Returns the minimum value of expr (vectorized, type: long)")
 public class VectorUDAFMinLong extends VectorAggregateExpression {
+   
+    private static final long serialVersionUID = 1L;
     
     /** 
      * class for storing the current aggregate value.
      */
     static private final class Aggregation implements AggregationBuffer {
-      private long value;
-      private boolean isNull;
+
+      private static final long serialVersionUID = 1L;
+
+      transient private long value;
+      transient private boolean isNull;
 
       public void checkValue(long value) {
         if (isNull) {
@@ -62,12 +67,16 @@ public class VectorUDAFMinLong extends V
     }
     
     private VectorExpression inputExpression;
-    private VectorExpressionWriter resultWriter;
+    private transient VectorExpressionWriter resultWriter;
     
     public VectorUDAFMinLong(VectorExpression inputExpression) {
-      super();
+      this();
       this.inputExpression = inputExpression;
     }
+
+    public VectorUDAFMinLong() {
+      super();
+    }
     
     @Override
     public void init(AggregationDesc desc) throws HiveException {
@@ -421,5 +430,12 @@ public class VectorUDAFMinLong extends V
       model.memoryAlign());
   }
 
+  public VectorExpression getInputExpression() {
+    return inputExpression;
+  }
+
+  public void setInputExpression(VectorExpression inputExpression) {
+    this.inputExpression = inputExpression;
+  }
 }
 

Modified: hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFMinString.java
URL: http://svn.apache.org/viewvc/hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFMinString.java?rev=1517888&r1=1517887&r2=1517888&view=diff
==============================================================================
--- hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFMinString.java (original)
+++ hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFMinString.java Tue Aug 27 17:09:56 2013
@@ -41,15 +41,19 @@ import org.apache.hadoop.io.Text;
     value = "_FUNC_(expr) - Returns the minimum value of expr (vectorized, type: string)")
 public class VectorUDAFMinString extends VectorAggregateExpression {
 
+    private static final long serialVersionUID = 1L;
+
     /** 
      * class for storing the current aggregate value.
      */
     static private final class Aggregation implements AggregationBuffer {
 
-      private final static int MIN_BUFFER_SIZE = 16;
-      private byte[] bytes = new byte[MIN_BUFFER_SIZE];
-      private int length;
-      private boolean isNull;
+      private static final long serialVersionUID = 1L;
+
+      transient private final static int MIN_BUFFER_SIZE = 16;
+      transient private byte[] bytes = new byte[MIN_BUFFER_SIZE];
+      transient private int length;
+      transient private boolean isNull;
 
       public void checkValue(byte[] bytes, int start, int length) {
         if (isNull) {
@@ -75,15 +79,18 @@ public class VectorUDAFMinString extends
         JavaDataModel model = JavaDataModel.get();
         return model.lengthForByteArrayOfSize(bytes.length);
       }
-
     }
     
     private VectorExpression inputExpression;
-    private Text result;
+    transient private Text result;
     
     public VectorUDAFMinString(VectorExpression inputExpression) {
-      super();
+      this();
       this.inputExpression = inputExpression;
+    }
+
+    public VectorUDAFMinString() {
+      super();
       result = new Text();
     }
     
@@ -381,5 +388,13 @@ public class VectorUDAFMinString extends
     public void init(AggregationDesc desc) throws HiveException {
       // No-op
     }
+
+    public VectorExpression getInputExpression() {
+      return inputExpression;
+    }
+
+    public void setInputExpression(VectorExpression inputExpression) {
+      this.inputExpression = inputExpression;
+    }
 }
 

Modified: hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFStdPopDouble.java
URL: http://svn.apache.org/viewvc/hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFStdPopDouble.java?rev=1517888&r1=1517887&r2=1517888&view=diff
==============================================================================
--- hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFStdPopDouble.java (original)
+++ hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFStdPopDouble.java Tue Aug 27 17:09:56 2013
@@ -43,15 +43,20 @@ import org.apache.hadoop.hive.serde2.obj
 @Description(name = "std,stddev,stddev_pop",
     value = "_FUNC_(x) - Returns the standard deviation of a set of numbers (vectorized, double)")
 public class VectorUDAFStdPopDouble extends VectorAggregateExpression {
+
+    private static final long serialVersionUID = 1L;
     
     /** 
     /* class for storing the current aggregate value. 
     */
     private static final class Aggregation implements AggregationBuffer {
-      private double sum;
-      private long count;
-      private double variance;
-      private boolean isNull;
+
+      private static final long serialVersionUID = 1L;
+
+      transient private double sum;
+      transient private long count;
+      transient private double variance;
+      transient private boolean isNull;
       
       public void init() {
         isNull = false;
@@ -67,17 +72,21 @@ public class VectorUDAFStdPopDouble exte
     }
     
     private VectorExpression inputExpression;
-    private LongWritable resultCount;
-    private DoubleWritable resultSum;
-    private DoubleWritable resultVariance;
-    private Object[] partialResult;
+    transient private LongWritable resultCount;
+    transient private DoubleWritable resultSum;
+    transient private DoubleWritable resultVariance;
+    transient private Object[] partialResult;
     
-    private ObjectInspector soi;
+    transient private ObjectInspector soi;
     
     
     public VectorUDAFStdPopDouble(VectorExpression inputExpression) {
-      super();
+      this();
       this.inputExpression = inputExpression;
+    }
+
+    public VectorUDAFStdPopDouble() {
+      super();
       partialResult = new Object[3];
       resultCount = new LongWritable();
       resultSum = new DoubleWritable();
@@ -500,6 +509,12 @@ public class VectorUDAFStdPopDouble exte
     // No-op
   }
 
+  public VectorExpression getInputExpression() {
+    return inputExpression;
+  }
 
+  public void setInputExpression(VectorExpression inputExpression) {
+    this.inputExpression = inputExpression;
+  } 
 }
 

Modified: hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFStdPopLong.java
URL: http://svn.apache.org/viewvc/hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFStdPopLong.java?rev=1517888&r1=1517887&r2=1517888&view=diff
==============================================================================
--- hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFStdPopLong.java (original)
+++ hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFStdPopLong.java Tue Aug 27 17:09:56 2013
@@ -43,15 +43,20 @@ import org.apache.hadoop.hive.serde2.obj
 @Description(name = "std,stddev,stddev_pop",
     value = "_FUNC_(x) - Returns the standard deviation of a set of numbers (vectorized, long)")
 public class VectorUDAFStdPopLong extends VectorAggregateExpression {
+
+    private static final long serialVersionUID = 1L;
     
     /** 
     /* class for storing the current aggregate value. 
     */
     private static final class Aggregation implements AggregationBuffer {
-      private double sum;
-      private long count;
-      private double variance;
-      private boolean isNull;
+
+      private static final long serialVersionUID = 1L;
+
+      transient private double sum;
+      transient private long count;
+      transient private double variance;
+      transient private boolean isNull;
       
       public void init() {
         isNull = false;
@@ -67,17 +72,21 @@ public class VectorUDAFStdPopLong extend
     }
     
     private VectorExpression inputExpression;
-    private LongWritable resultCount;
-    private DoubleWritable resultSum;
-    private DoubleWritable resultVariance;
-    private Object[] partialResult;
+    transient private LongWritable resultCount;
+    transient private DoubleWritable resultSum;
+    transient private DoubleWritable resultVariance;
+    transient private Object[] partialResult;
     
-    private ObjectInspector soi;
+    transient private ObjectInspector soi;
     
     
     public VectorUDAFStdPopLong(VectorExpression inputExpression) {
-      super();
+      this();
       this.inputExpression = inputExpression;
+    }
+
+    public VectorUDAFStdPopLong() {
+      super();
       partialResult = new Object[3];
       resultCount = new LongWritable();
       resultSum = new DoubleWritable();
@@ -500,6 +509,12 @@ public class VectorUDAFStdPopLong extend
     // No-op
   }
 
+  public VectorExpression getInputExpression() {
+    return inputExpression;
+  }
 
+  public void setInputExpression(VectorExpression inputExpression) {
+    this.inputExpression = inputExpression;
+  } 
 }
 

Modified: hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFStdSampDouble.java
URL: http://svn.apache.org/viewvc/hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFStdSampDouble.java?rev=1517888&r1=1517887&r2=1517888&view=diff
==============================================================================
--- hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFStdSampDouble.java (original)
+++ hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFStdSampDouble.java Tue Aug 27 17:09:56 2013
@@ -43,15 +43,20 @@ import org.apache.hadoop.hive.serde2.obj
 @Description(name = "stddev_samp",
     value = "_FUNC_(x) - Returns the sample standard deviation of a set of numbers (vectorized, double)")
 public class VectorUDAFStdSampDouble extends VectorAggregateExpression {
+
+    private static final long serialVersionUID = 1L;
     
     /** 
     /* class for storing the current aggregate value. 
     */
     private static final class Aggregation implements AggregationBuffer {
-      private double sum;
-      private long count;
-      private double variance;
-      private boolean isNull;
+
+      private static final long serialVersionUID = 1L;
+
+      transient private double sum;
+      transient private long count;
+      transient private double variance;
+      transient private boolean isNull;
       
       public void init() {
         isNull = false;
@@ -67,17 +72,21 @@ public class VectorUDAFStdSampDouble ext
     }
     
     private VectorExpression inputExpression;
-    private LongWritable resultCount;
-    private DoubleWritable resultSum;
-    private DoubleWritable resultVariance;
-    private Object[] partialResult;
+    transient private LongWritable resultCount;
+    transient private DoubleWritable resultSum;
+    transient private DoubleWritable resultVariance;
+    transient private Object[] partialResult;
     
-    private ObjectInspector soi;
+    transient private ObjectInspector soi;
     
     
     public VectorUDAFStdSampDouble(VectorExpression inputExpression) {
-      super();
+      this();
       this.inputExpression = inputExpression;
+    }
+
+    public VectorUDAFStdSampDouble() {
+      super();
       partialResult = new Object[3];
       resultCount = new LongWritable();
       resultSum = new DoubleWritable();
@@ -500,6 +509,12 @@ public class VectorUDAFStdSampDouble ext
     // No-op
   }
 
+  public VectorExpression getInputExpression() {
+    return inputExpression;
+  }
 
+  public void setInputExpression(VectorExpression inputExpression) {
+    this.inputExpression = inputExpression;
+  } 
 }
 

Modified: hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFStdSampLong.java
URL: http://svn.apache.org/viewvc/hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFStdSampLong.java?rev=1517888&r1=1517887&r2=1517888&view=diff
==============================================================================
--- hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFStdSampLong.java (original)
+++ hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFStdSampLong.java Tue Aug 27 17:09:56 2013
@@ -43,15 +43,20 @@ import org.apache.hadoop.hive.serde2.obj
 @Description(name = "stddev_samp",
     value = "_FUNC_(x) - Returns the sample standard deviation of a set of numbers (vectorized, long)")
 public class VectorUDAFStdSampLong extends VectorAggregateExpression {
+
+    private static final long serialVersionUID = 1L;
     
     /** 
     /* class for storing the current aggregate value. 
     */
     private static final class Aggregation implements AggregationBuffer {
-      private double sum;
-      private long count;
-      private double variance;
-      private boolean isNull;
+
+      private static final long serialVersionUID = 1L;
+
+      transient private double sum;
+      transient private long count;
+      transient private double variance;
+      transient private boolean isNull;
       
       public void init() {
         isNull = false;
@@ -67,17 +72,21 @@ public class VectorUDAFStdSampLong exten
     }
     
     private VectorExpression inputExpression;
-    private LongWritable resultCount;
-    private DoubleWritable resultSum;
-    private DoubleWritable resultVariance;
-    private Object[] partialResult;
+    transient private LongWritable resultCount;
+    transient private DoubleWritable resultSum;
+    transient private DoubleWritable resultVariance;
+    transient private Object[] partialResult;
     
-    private ObjectInspector soi;
+    transient private ObjectInspector soi;
     
     
     public VectorUDAFStdSampLong(VectorExpression inputExpression) {
-      super();
+      this();
       this.inputExpression = inputExpression;
+    }
+
+    public VectorUDAFStdSampLong() {
+      super();
       partialResult = new Object[3];
       resultCount = new LongWritable();
       resultSum = new DoubleWritable();
@@ -500,6 +509,12 @@ public class VectorUDAFStdSampLong exten
     // No-op
   }
 
+  public VectorExpression getInputExpression() {
+    return inputExpression;
+  }
 
+  public void setInputExpression(VectorExpression inputExpression) {
+    this.inputExpression = inputExpression;
+  } 
 }
 

Modified: hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFSumDouble.java
URL: http://svn.apache.org/viewvc/hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFSumDouble.java?rev=1517888&r1=1517887&r2=1517888&view=diff
==============================================================================
--- hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFSumDouble.java (original)
+++ hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFSumDouble.java Tue Aug 27 17:09:56 2013
@@ -39,13 +39,18 @@ import org.apache.hadoop.hive.serde2.obj
 @Description(name = "sum", 
     value = "_FUNC_(expr) - Returns the sum value of expr (vectorized, type: double)")
 public class VectorUDAFSumDouble extends VectorAggregateExpression {
+   
+    private static final long serialVersionUID = 1L;
     
     /** 
      * class for storing the current aggregate value.
      */
     private static final class Aggregation implements AggregationBuffer {
-      private double sum;
-      private boolean isNull;
+
+      private static final long serialVersionUID = 1L;
+
+      transient private double sum;
+      transient private boolean isNull;
       
       public void sumValue(double value) {
         if (isNull) {
@@ -62,12 +67,16 @@ public class VectorUDAFSumDouble extends
       }
     }
     
-    private final VectorExpression inputExpression;
-    private final DoubleWritable result;
+    private VectorExpression inputExpression;
+    transient private final DoubleWritable result;
     
     public VectorUDAFSumDouble(VectorExpression inputExpression) {
-      super();
+      this();
       this.inputExpression = inputExpression;
+    }
+
+    public VectorUDAFSumDouble() {
+      super();
       result = new DoubleWritable();
     }
 
@@ -416,6 +425,12 @@ public class VectorUDAFSumDouble extends
     // No-op
   }
 
+  public VectorExpression getInputExpression() {
+    return inputExpression;
+  }
 
+  public void setInputExpression(VectorExpression inputExpression) {
+    this.inputExpression = inputExpression;
+  }
 }
 

Modified: hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFSumLong.java
URL: http://svn.apache.org/viewvc/hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFSumLong.java?rev=1517888&r1=1517887&r2=1517888&view=diff
==============================================================================
--- hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFSumLong.java (original)
+++ hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFSumLong.java Tue Aug 27 17:09:56 2013
@@ -39,13 +39,18 @@ import org.apache.hadoop.hive.serde2.obj
 @Description(name = "sum", 
     value = "_FUNC_(expr) - Returns the sum value of expr (vectorized, type: long)")
 public class VectorUDAFSumLong extends VectorAggregateExpression {
+   
+    private static final long serialVersionUID = 1L;
     
     /** 
      * class for storing the current aggregate value.
      */
     private static final class Aggregation implements AggregationBuffer {
-      private long sum;
-      private boolean isNull;
+
+      private static final long serialVersionUID = 1L;
+
+      transient private long sum;
+      transient private boolean isNull;
       
       public void sumValue(long value) {
         if (isNull) {
@@ -62,12 +67,16 @@ public class VectorUDAFSumLong extends V
       }
     }
     
-    private final VectorExpression inputExpression;
-    private final LongWritable result;
+    private VectorExpression inputExpression;
+    transient private final LongWritable result;
     
     public VectorUDAFSumLong(VectorExpression inputExpression) {
-      super();
+      this();
       this.inputExpression = inputExpression;
+    }
+
+    public VectorUDAFSumLong() {
+      super();
       result = new LongWritable();
     }
 
@@ -416,6 +425,12 @@ public class VectorUDAFSumLong extends V
     // No-op
   }
 
+  public VectorExpression getInputExpression() {
+    return inputExpression;
+  }
 
+  public void setInputExpression(VectorExpression inputExpression) {
+    this.inputExpression = inputExpression;
+  }
 }
 

Modified: hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFVarPopDouble.java
URL: http://svn.apache.org/viewvc/hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFVarPopDouble.java?rev=1517888&r1=1517887&r2=1517888&view=diff
==============================================================================
--- hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFVarPopDouble.java (original)
+++ hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFVarPopDouble.java Tue Aug 27 17:09:56 2013
@@ -43,15 +43,20 @@ import org.apache.hadoop.hive.serde2.obj
 @Description(name = "variance, var_pop",
     value = "_FUNC_(x) - Returns the variance of a set of numbers (vectorized, double)")
 public class VectorUDAFVarPopDouble extends VectorAggregateExpression {
+
+    private static final long serialVersionUID = 1L;
     
     /** 
     /* class for storing the current aggregate value. 
     */
     private static final class Aggregation implements AggregationBuffer {
-      private double sum;
-      private long count;
-      private double variance;
-      private boolean isNull;
+
+      private static final long serialVersionUID = 1L;
+
+      transient private double sum;
+      transient private long count;
+      transient private double variance;
+      transient private boolean isNull;
       
       public void init() {
         isNull = false;
@@ -67,17 +72,21 @@ public class VectorUDAFVarPopDouble exte
     }
     
     private VectorExpression inputExpression;
-    private LongWritable resultCount;
-    private DoubleWritable resultSum;
-    private DoubleWritable resultVariance;
-    private Object[] partialResult;
+    transient private LongWritable resultCount;
+    transient private DoubleWritable resultSum;
+    transient private DoubleWritable resultVariance;
+    transient private Object[] partialResult;
     
-    private ObjectInspector soi;
+    transient private ObjectInspector soi;
     
     
     public VectorUDAFVarPopDouble(VectorExpression inputExpression) {
-      super();
+      this();
       this.inputExpression = inputExpression;
+    }
+
+    public VectorUDAFVarPopDouble() {
+      super();
       partialResult = new Object[3];
       resultCount = new LongWritable();
       resultSum = new DoubleWritable();
@@ -500,6 +509,12 @@ public class VectorUDAFVarPopDouble exte
     // No-op
   }
 
+  public VectorExpression getInputExpression() {
+    return inputExpression;
+  }
 
+  public void setInputExpression(VectorExpression inputExpression) {
+    this.inputExpression = inputExpression;
+  } 
 }
 

Modified: hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFVarPopLong.java
URL: http://svn.apache.org/viewvc/hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFVarPopLong.java?rev=1517888&r1=1517887&r2=1517888&view=diff
==============================================================================
--- hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFVarPopLong.java (original)
+++ hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFVarPopLong.java Tue Aug 27 17:09:56 2013
@@ -43,15 +43,20 @@ import org.apache.hadoop.hive.serde2.obj
 @Description(name = "variance, var_pop",
     value = "_FUNC_(x) - Returns the variance of a set of numbers (vectorized, long)")
 public class VectorUDAFVarPopLong extends VectorAggregateExpression {
+
+    private static final long serialVersionUID = 1L;
     
     /** 
     /* class for storing the current aggregate value. 
     */
     private static final class Aggregation implements AggregationBuffer {
-      private double sum;
-      private long count;
-      private double variance;
-      private boolean isNull;
+
+      private static final long serialVersionUID = 1L;
+
+      transient private double sum;
+      transient private long count;
+      transient private double variance;
+      transient private boolean isNull;
       
       public void init() {
         isNull = false;
@@ -67,17 +72,21 @@ public class VectorUDAFVarPopLong extend
     }
     
     private VectorExpression inputExpression;
-    private LongWritable resultCount;
-    private DoubleWritable resultSum;
-    private DoubleWritable resultVariance;
-    private Object[] partialResult;
+    transient private LongWritable resultCount;
+    transient private DoubleWritable resultSum;
+    transient private DoubleWritable resultVariance;
+    transient private Object[] partialResult;
     
-    private ObjectInspector soi;
+    transient private ObjectInspector soi;
     
     
     public VectorUDAFVarPopLong(VectorExpression inputExpression) {
-      super();
+      this();
       this.inputExpression = inputExpression;
+    }
+
+    public VectorUDAFVarPopLong() {
+      super();
       partialResult = new Object[3];
       resultCount = new LongWritable();
       resultSum = new DoubleWritable();
@@ -500,6 +509,12 @@ public class VectorUDAFVarPopLong extend
     // No-op
   }
 
+  public VectorExpression getInputExpression() {
+    return inputExpression;
+  }
 
+  public void setInputExpression(VectorExpression inputExpression) {
+    this.inputExpression = inputExpression;
+  } 
 }
 

Modified: hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFVarSampDouble.java
URL: http://svn.apache.org/viewvc/hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFVarSampDouble.java?rev=1517888&r1=1517887&r2=1517888&view=diff
==============================================================================
--- hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFVarSampDouble.java (original)
+++ hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFVarSampDouble.java Tue Aug 27 17:09:56 2013
@@ -43,15 +43,20 @@ import org.apache.hadoop.hive.serde2.obj
 @Description(name = "var_samp",
     value = "_FUNC_(x) - Returns the sample variance of a set of numbers (vectorized, double)")
 public class VectorUDAFVarSampDouble extends VectorAggregateExpression {
+
+    private static final long serialVersionUID = 1L;
     
     /** 
     /* class for storing the current aggregate value. 
     */
     private static final class Aggregation implements AggregationBuffer {
-      private double sum;
-      private long count;
-      private double variance;
-      private boolean isNull;
+
+      private static final long serialVersionUID = 1L;
+
+      transient private double sum;
+      transient private long count;
+      transient private double variance;
+      transient private boolean isNull;
       
       public void init() {
         isNull = false;
@@ -67,17 +72,21 @@ public class VectorUDAFVarSampDouble ext
     }
     
     private VectorExpression inputExpression;
-    private LongWritable resultCount;
-    private DoubleWritable resultSum;
-    private DoubleWritable resultVariance;
-    private Object[] partialResult;
+    transient private LongWritable resultCount;
+    transient private DoubleWritable resultSum;
+    transient private DoubleWritable resultVariance;
+    transient private Object[] partialResult;
     
-    private ObjectInspector soi;
+    transient private ObjectInspector soi;
     
     
     public VectorUDAFVarSampDouble(VectorExpression inputExpression) {
-      super();
+      this();
       this.inputExpression = inputExpression;
+    }
+
+    public VectorUDAFVarSampDouble() {
+      super();
       partialResult = new Object[3];
       resultCount = new LongWritable();
       resultSum = new DoubleWritable();
@@ -500,6 +509,12 @@ public class VectorUDAFVarSampDouble ext
     // No-op
   }
 
+  public VectorExpression getInputExpression() {
+    return inputExpression;
+  }
 
+  public void setInputExpression(VectorExpression inputExpression) {
+    this.inputExpression = inputExpression;
+  } 
 }
 

Modified: hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFVarSampLong.java
URL: http://svn.apache.org/viewvc/hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFVarSampLong.java?rev=1517888&r1=1517887&r2=1517888&view=diff
==============================================================================
--- hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFVarSampLong.java (original)
+++ hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/gen/VectorUDAFVarSampLong.java Tue Aug 27 17:09:56 2013
@@ -43,15 +43,20 @@ import org.apache.hadoop.hive.serde2.obj
 @Description(name = "var_samp",
     value = "_FUNC_(x) - Returns the sample variance of a set of numbers (vectorized, long)")
 public class VectorUDAFVarSampLong extends VectorAggregateExpression {
+
+    private static final long serialVersionUID = 1L;
     
     /** 
     /* class for storing the current aggregate value. 
     */
     private static final class Aggregation implements AggregationBuffer {
-      private double sum;
-      private long count;
-      private double variance;
-      private boolean isNull;
+
+      private static final long serialVersionUID = 1L;
+
+      transient private double sum;
+      transient private long count;
+      transient private double variance;
+      transient private boolean isNull;
       
       public void init() {
         isNull = false;
@@ -67,17 +72,21 @@ public class VectorUDAFVarSampLong exten
     }
     
     private VectorExpression inputExpression;
-    private LongWritable resultCount;
-    private DoubleWritable resultSum;
-    private DoubleWritable resultVariance;
-    private Object[] partialResult;
+    transient private LongWritable resultCount;
+    transient private DoubleWritable resultSum;
+    transient private DoubleWritable resultVariance;
+    transient private Object[] partialResult;
     
-    private ObjectInspector soi;
+    transient private ObjectInspector soi;
     
     
     public VectorUDAFVarSampLong(VectorExpression inputExpression) {
-      super();
+      this();
       this.inputExpression = inputExpression;
+    }
+
+    public VectorUDAFVarSampLong() {
+      super();
       partialResult = new Object[3];
       resultCount = new LongWritable();
       resultSum = new DoubleWritable();
@@ -500,6 +509,12 @@ public class VectorUDAFVarSampLong exten
     // No-op
   }
 
+  public VectorExpression getInputExpression() {
+    return inputExpression;
+  }
 
+  public void setInputExpression(VectorExpression inputExpression) {
+    this.inputExpression = inputExpression;
+  } 
 }
 

Modified: hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/gen/DoubleColAddDoubleColumn.java
URL: http://svn.apache.org/viewvc/hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/gen/DoubleColAddDoubleColumn.java?rev=1517888&r1=1517887&r2=1517888&view=diff
==============================================================================
--- hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/gen/DoubleColAddDoubleColumn.java (original)
+++ hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/gen/DoubleColAddDoubleColumn.java Tue Aug 27 17:09:56 2013
@@ -28,6 +28,9 @@ import org.apache.hadoop.hive.ql.exec.ve
  * expressions between columns.
  */
 public class DoubleColAddDoubleColumn extends VectorExpression {
+
+  private static final long serialVersionUID = 1L;
+  
   private int colNum1;
   private int colNum2;
   private int outputColumn;
@@ -38,6 +41,9 @@ public class DoubleColAddDoubleColumn ex
     this.outputColumn = outputColumn;
   }
 
+  public DoubleColAddDoubleColumn() {
+  }
+
   @Override
   public void evaluate(VectorizedRowBatch batch) {
 
@@ -128,4 +134,24 @@ public class DoubleColAddDoubleColumn ex
   public String getOutputType() {
     return "double";
   }
+  
+  public int getColNum1() {
+    return colNum1;
+  }
+
+  public void setColNum1(int colNum1) {
+    this.colNum1 = colNum1;
+  }
+
+  public int getColNum2() {
+    return colNum2;
+  }
+
+  public void setColNum2(int colNum2) {
+    this.colNum2 = colNum2;
+  }
+
+  public void setOutputColumn(int outputColumn) {
+    this.outputColumn = outputColumn;
+  }
 }

Modified: hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/gen/DoubleColAddDoubleScalar.java
URL: http://svn.apache.org/viewvc/hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/gen/DoubleColAddDoubleScalar.java?rev=1517888&r1=1517887&r2=1517888&view=diff
==============================================================================
--- hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/gen/DoubleColAddDoubleScalar.java (original)
+++ hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/gen/DoubleColAddDoubleScalar.java Tue Aug 27 17:09:56 2013
@@ -29,6 +29,9 @@ import org.apache.hadoop.hive.ql.exec.ve
  * expressions between a column and a scalar.
  */
 public class DoubleColAddDoubleScalar extends VectorExpression {
+
+  private static final long serialVersionUID = 1L;
+
   private int colNum;
   private double value;
   private int outputColumn;
@@ -39,6 +42,9 @@ public class DoubleColAddDoubleScalar ex
     this.outputColumn = outputColumn;
   }
 
+  public DoubleColAddDoubleScalar() {
+  }
+
   @Override
   public void evaluate(VectorizedRowBatch batch) {
 
@@ -105,4 +111,24 @@ public class DoubleColAddDoubleScalar ex
   public String getOutputType() {
     return "double";
   }
+  
+  public int getColNum() {
+    return colNum;
+  }
+  
+  public void setColNum(int colNum) {
+    this.colNum = colNum;
+  }
+
+  public double getValue() {
+    return value;
+  }
+
+  public void setValue(double value) {
+    this.value = value;
+  }
+
+  public void setOutputColumn(int outputColumn) {
+    this.outputColumn = outputColumn;
+  }
 }

Modified: hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/gen/DoubleColAddLongColumn.java
URL: http://svn.apache.org/viewvc/hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/gen/DoubleColAddLongColumn.java?rev=1517888&r1=1517887&r2=1517888&view=diff
==============================================================================
--- hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/gen/DoubleColAddLongColumn.java (original)
+++ hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/gen/DoubleColAddLongColumn.java Tue Aug 27 17:09:56 2013
@@ -28,6 +28,9 @@ import org.apache.hadoop.hive.ql.exec.ve
  * expressions between columns.
  */
 public class DoubleColAddLongColumn extends VectorExpression {
+
+  private static final long serialVersionUID = 1L;
+  
   private int colNum1;
   private int colNum2;
   private int outputColumn;
@@ -38,6 +41,9 @@ public class DoubleColAddLongColumn exte
     this.outputColumn = outputColumn;
   }
 
+  public DoubleColAddLongColumn() {
+  }
+
   @Override
   public void evaluate(VectorizedRowBatch batch) {
 
@@ -128,4 +134,24 @@ public class DoubleColAddLongColumn exte
   public String getOutputType() {
     return "double";
   }
+  
+  public int getColNum1() {
+    return colNum1;
+  }
+
+  public void setColNum1(int colNum1) {
+    this.colNum1 = colNum1;
+  }
+
+  public int getColNum2() {
+    return colNum2;
+  }
+
+  public void setColNum2(int colNum2) {
+    this.colNum2 = colNum2;
+  }
+
+  public void setOutputColumn(int outputColumn) {
+    this.outputColumn = outputColumn;
+  }
 }

Modified: hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/gen/DoubleColAddLongScalar.java
URL: http://svn.apache.org/viewvc/hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/gen/DoubleColAddLongScalar.java?rev=1517888&r1=1517887&r2=1517888&view=diff
==============================================================================
--- hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/gen/DoubleColAddLongScalar.java (original)
+++ hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/gen/DoubleColAddLongScalar.java Tue Aug 27 17:09:56 2013
@@ -29,6 +29,9 @@ import org.apache.hadoop.hive.ql.exec.ve
  * expressions between a column and a scalar.
  */
 public class DoubleColAddLongScalar extends VectorExpression {
+
+  private static final long serialVersionUID = 1L;
+
   private int colNum;
   private long value;
   private int outputColumn;
@@ -39,6 +42,9 @@ public class DoubleColAddLongScalar exte
     this.outputColumn = outputColumn;
   }
 
+  public DoubleColAddLongScalar() {
+  }
+
   @Override
   public void evaluate(VectorizedRowBatch batch) {
 
@@ -105,4 +111,24 @@ public class DoubleColAddLongScalar exte
   public String getOutputType() {
     return "double";
   }
+  
+  public int getColNum() {
+    return colNum;
+  }
+  
+  public void setColNum(int colNum) {
+    this.colNum = colNum;
+  }
+
+  public long getValue() {
+    return value;
+  }
+
+  public void setValue(long value) {
+    this.value = value;
+  }
+
+  public void setOutputColumn(int outputColumn) {
+    this.outputColumn = outputColumn;
+  }
 }

Modified: hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/gen/DoubleColDivideDoubleColumn.java
URL: http://svn.apache.org/viewvc/hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/gen/DoubleColDivideDoubleColumn.java?rev=1517888&r1=1517887&r2=1517888&view=diff
==============================================================================
--- hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/gen/DoubleColDivideDoubleColumn.java (original)
+++ hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/gen/DoubleColDivideDoubleColumn.java Tue Aug 27 17:09:56 2013
@@ -28,6 +28,9 @@ import org.apache.hadoop.hive.ql.exec.ve
  * expressions between columns.
  */
 public class DoubleColDivideDoubleColumn extends VectorExpression {
+
+  private static final long serialVersionUID = 1L;
+  
   private int colNum1;
   private int colNum2;
   private int outputColumn;
@@ -38,6 +41,9 @@ public class DoubleColDivideDoubleColumn
     this.outputColumn = outputColumn;
   }
 
+  public DoubleColDivideDoubleColumn() {
+  }
+
   @Override
   public void evaluate(VectorizedRowBatch batch) {
 
@@ -128,4 +134,24 @@ public class DoubleColDivideDoubleColumn
   public String getOutputType() {
     return "double";
   }
+  
+  public int getColNum1() {
+    return colNum1;
+  }
+
+  public void setColNum1(int colNum1) {
+    this.colNum1 = colNum1;
+  }
+
+  public int getColNum2() {
+    return colNum2;
+  }
+
+  public void setColNum2(int colNum2) {
+    this.colNum2 = colNum2;
+  }
+
+  public void setOutputColumn(int outputColumn) {
+    this.outputColumn = outputColumn;
+  }
 }

Modified: hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/gen/DoubleColDivideDoubleScalar.java
URL: http://svn.apache.org/viewvc/hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/gen/DoubleColDivideDoubleScalar.java?rev=1517888&r1=1517887&r2=1517888&view=diff
==============================================================================
--- hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/gen/DoubleColDivideDoubleScalar.java (original)
+++ hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/gen/DoubleColDivideDoubleScalar.java Tue Aug 27 17:09:56 2013
@@ -29,6 +29,9 @@ import org.apache.hadoop.hive.ql.exec.ve
  * expressions between a column and a scalar.
  */
 public class DoubleColDivideDoubleScalar extends VectorExpression {
+
+  private static final long serialVersionUID = 1L;
+
   private int colNum;
   private double value;
   private int outputColumn;
@@ -39,6 +42,9 @@ public class DoubleColDivideDoubleScalar
     this.outputColumn = outputColumn;
   }
 
+  public DoubleColDivideDoubleScalar() {
+  }
+
   @Override
   public void evaluate(VectorizedRowBatch batch) {
 
@@ -105,4 +111,24 @@ public class DoubleColDivideDoubleScalar
   public String getOutputType() {
     return "double";
   }
+  
+  public int getColNum() {
+    return colNum;
+  }
+  
+  public void setColNum(int colNum) {
+    this.colNum = colNum;
+  }
+
+  public double getValue() {
+    return value;
+  }
+
+  public void setValue(double value) {
+    this.value = value;
+  }
+
+  public void setOutputColumn(int outputColumn) {
+    this.outputColumn = outputColumn;
+  }
 }

Modified: hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/gen/DoubleColDivideLongColumn.java
URL: http://svn.apache.org/viewvc/hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/gen/DoubleColDivideLongColumn.java?rev=1517888&r1=1517887&r2=1517888&view=diff
==============================================================================
--- hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/gen/DoubleColDivideLongColumn.java (original)
+++ hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/gen/DoubleColDivideLongColumn.java Tue Aug 27 17:09:56 2013
@@ -28,6 +28,9 @@ import org.apache.hadoop.hive.ql.exec.ve
  * expressions between columns.
  */
 public class DoubleColDivideLongColumn extends VectorExpression {
+
+  private static final long serialVersionUID = 1L;
+  
   private int colNum1;
   private int colNum2;
   private int outputColumn;
@@ -38,6 +41,9 @@ public class DoubleColDivideLongColumn e
     this.outputColumn = outputColumn;
   }
 
+  public DoubleColDivideLongColumn() {
+  }
+
   @Override
   public void evaluate(VectorizedRowBatch batch) {
 
@@ -128,4 +134,24 @@ public class DoubleColDivideLongColumn e
   public String getOutputType() {
     return "double";
   }
+  
+  public int getColNum1() {
+    return colNum1;
+  }
+
+  public void setColNum1(int colNum1) {
+    this.colNum1 = colNum1;
+  }
+
+  public int getColNum2() {
+    return colNum2;
+  }
+
+  public void setColNum2(int colNum2) {
+    this.colNum2 = colNum2;
+  }
+
+  public void setOutputColumn(int outputColumn) {
+    this.outputColumn = outputColumn;
+  }
 }

Modified: hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/gen/DoubleColDivideLongScalar.java
URL: http://svn.apache.org/viewvc/hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/gen/DoubleColDivideLongScalar.java?rev=1517888&r1=1517887&r2=1517888&view=diff
==============================================================================
--- hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/gen/DoubleColDivideLongScalar.java (original)
+++ hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/gen/DoubleColDivideLongScalar.java Tue Aug 27 17:09:56 2013
@@ -29,6 +29,9 @@ import org.apache.hadoop.hive.ql.exec.ve
  * expressions between a column and a scalar.
  */
 public class DoubleColDivideLongScalar extends VectorExpression {
+
+  private static final long serialVersionUID = 1L;
+
   private int colNum;
   private long value;
   private int outputColumn;
@@ -39,6 +42,9 @@ public class DoubleColDivideLongScalar e
     this.outputColumn = outputColumn;
   }
 
+  public DoubleColDivideLongScalar() {
+  }
+
   @Override
   public void evaluate(VectorizedRowBatch batch) {
 
@@ -105,4 +111,24 @@ public class DoubleColDivideLongScalar e
   public String getOutputType() {
     return "double";
   }
+  
+  public int getColNum() {
+    return colNum;
+  }
+  
+  public void setColNum(int colNum) {
+    this.colNum = colNum;
+  }
+
+  public long getValue() {
+    return value;
+  }
+
+  public void setValue(long value) {
+    this.value = value;
+  }
+
+  public void setOutputColumn(int outputColumn) {
+    this.outputColumn = outputColumn;
+  }
 }

Modified: hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/gen/DoubleColEqualDoubleScalar.java
URL: http://svn.apache.org/viewvc/hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/gen/DoubleColEqualDoubleScalar.java?rev=1517888&r1=1517887&r2=1517888&view=diff
==============================================================================
--- hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/gen/DoubleColEqualDoubleScalar.java (original)
+++ hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/gen/DoubleColEqualDoubleScalar.java Tue Aug 27 17:09:56 2013
@@ -29,6 +29,9 @@ import org.apache.hadoop.hive.ql.exec.ve
  * separate boolean column.
  */
 public class DoubleColEqualDoubleScalar extends VectorExpression {
+
+  private static final long serialVersionUID = 1L;
+
   private int colNum;
   private double value;
   private int outputColumn;
@@ -39,6 +42,9 @@ public class DoubleColEqualDoubleScalar 
     this.outputColumn = outputColumn;
   }
 
+  public DoubleColEqualDoubleScalar() {
+  }
+
   @Override
   public void evaluate(VectorizedRowBatch batch) {
 
@@ -120,4 +126,24 @@ public class DoubleColEqualDoubleScalar 
   public String getOutputType() {
     return "long";
   }
+  
+  public int getColNum() {
+    return colNum;
+  }
+  
+  public void setColNum(int colNum) {
+    this.colNum = colNum;
+  }
+
+  public double getValue() {
+    return value;
+  }
+
+  public void setValue(double value) {
+    this.value = value;
+  }
+
+  public void setOutputColumn(int outputColumn) {
+    this.outputColumn = outputColumn;
+  }
 }

Modified: hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/gen/DoubleColGreaterDoubleScalar.java
URL: http://svn.apache.org/viewvc/hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/gen/DoubleColGreaterDoubleScalar.java?rev=1517888&r1=1517887&r2=1517888&view=diff
==============================================================================
--- hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/gen/DoubleColGreaterDoubleScalar.java (original)
+++ hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/gen/DoubleColGreaterDoubleScalar.java Tue Aug 27 17:09:56 2013
@@ -29,6 +29,9 @@ import org.apache.hadoop.hive.ql.exec.ve
  * separate boolean column.
  */
 public class DoubleColGreaterDoubleScalar extends VectorExpression {
+
+  private static final long serialVersionUID = 1L;
+
   private int colNum;
   private double value;
   private int outputColumn;
@@ -39,6 +42,9 @@ public class DoubleColGreaterDoubleScala
     this.outputColumn = outputColumn;
   }
 
+  public DoubleColGreaterDoubleScalar() {
+  }
+
   @Override
   public void evaluate(VectorizedRowBatch batch) {
 
@@ -120,4 +126,24 @@ public class DoubleColGreaterDoubleScala
   public String getOutputType() {
     return "long";
   }
+  
+  public int getColNum() {
+    return colNum;
+  }
+  
+  public void setColNum(int colNum) {
+    this.colNum = colNum;
+  }
+
+  public double getValue() {
+    return value;
+  }
+
+  public void setValue(double value) {
+    this.value = value;
+  }
+
+  public void setOutputColumn(int outputColumn) {
+    this.outputColumn = outputColumn;
+  }
 }

Modified: hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/gen/DoubleColGreaterEqualDoubleScalar.java
URL: http://svn.apache.org/viewvc/hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/gen/DoubleColGreaterEqualDoubleScalar.java?rev=1517888&r1=1517887&r2=1517888&view=diff
==============================================================================
--- hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/gen/DoubleColGreaterEqualDoubleScalar.java (original)
+++ hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/gen/DoubleColGreaterEqualDoubleScalar.java Tue Aug 27 17:09:56 2013
@@ -29,6 +29,9 @@ import org.apache.hadoop.hive.ql.exec.ve
  * separate boolean column.
  */
 public class DoubleColGreaterEqualDoubleScalar extends VectorExpression {
+
+  private static final long serialVersionUID = 1L;
+
   private int colNum;
   private double value;
   private int outputColumn;
@@ -39,6 +42,9 @@ public class DoubleColGreaterEqualDouble
     this.outputColumn = outputColumn;
   }
 
+  public DoubleColGreaterEqualDoubleScalar() {
+  }
+
   @Override
   public void evaluate(VectorizedRowBatch batch) {
 
@@ -120,4 +126,24 @@ public class DoubleColGreaterEqualDouble
   public String getOutputType() {
     return "long";
   }
+  
+  public int getColNum() {
+    return colNum;
+  }
+  
+  public void setColNum(int colNum) {
+    this.colNum = colNum;
+  }
+
+  public double getValue() {
+    return value;
+  }
+
+  public void setValue(double value) {
+    this.value = value;
+  }
+
+  public void setOutputColumn(int outputColumn) {
+    this.outputColumn = outputColumn;
+  }
 }

Modified: hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/gen/DoubleColLessDoubleScalar.java
URL: http://svn.apache.org/viewvc/hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/gen/DoubleColLessDoubleScalar.java?rev=1517888&r1=1517887&r2=1517888&view=diff
==============================================================================
--- hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/gen/DoubleColLessDoubleScalar.java (original)
+++ hive/branches/vectorization/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/gen/DoubleColLessDoubleScalar.java Tue Aug 27 17:09:56 2013
@@ -29,6 +29,9 @@ import org.apache.hadoop.hive.ql.exec.ve
  * separate boolean column.
  */
 public class DoubleColLessDoubleScalar extends VectorExpression {
+
+  private static final long serialVersionUID = 1L;
+
   private int colNum;
   private double value;
   private int outputColumn;
@@ -39,6 +42,9 @@ public class DoubleColLessDoubleScalar e
     this.outputColumn = outputColumn;
   }
 
+  public DoubleColLessDoubleScalar() {
+  }
+
   @Override
   public void evaluate(VectorizedRowBatch batch) {
 
@@ -120,4 +126,24 @@ public class DoubleColLessDoubleScalar e
   public String getOutputType() {
     return "long";
   }
+  
+  public int getColNum() {
+    return colNum;
+  }
+  
+  public void setColNum(int colNum) {
+    this.colNum = colNum;
+  }
+
+  public double getValue() {
+    return value;
+  }
+
+  public void setValue(double value) {
+    this.value = value;
+  }
+
+  public void setOutputColumn(int outputColumn) {
+    this.outputColumn = outputColumn;
+  }
 }



Mime
View raw message