Repository: vaexio/vaex (python)

Issue:
vaex.groupby type casting
In the current implementation of `groupby`, if a column is on of type `int`, calculating the mean will also be of type `int`, which is numerically not accurate. This should probably be cased to `float` somewhere behind the scenes. 

Pull request description:
fix(core,std): standard deviation upcasts numbers to float64 for accuracy
Fixes #308 

Patch:
diff --git a/packages/vaex-core/vaex/agg.py b/packages/vaex-core/vaex/agg.py
index d65e3b7b..bd05da01 100644
--- a/packages/vaex-core/vaex/agg.py
+++ b/packages/vaex-core/vaex/agg.py
@@ -24,7 +24,7 @@ class AggregatorDescriptorBasic(AggregatorDescriptor):
     def __init__(self, name, expression, short_name, multi_args=False, agg_args=[]):
         self.name = name
         self.short_name = short_name
-        self.expression = expression
+        self.expression = str(expression)
         self.agg_args = agg_args
         if not multi_args:
             if self.expression == '*':
@@ -66,10 +66,6 @@ class AggregatorDescriptorMulti(AggregatorDescriptor):
         self.short_name = short_name
         self.expression = expression
         self.expressions = [self.expression]
-        self._add_sub_agg()
-
-    def _add_sub_agg(self):
-        pass
 
     def pretty_name(self, id=None):
         id = id or "_".join(map(str, self.expression))
@@ -80,15 +76,20 @@ class AggregatorDescriptorMean(AggregatorDescriptorMulti):
     def __init__(self, name, expression, short_name="mean"):
         super(AggregatorDescriptorMean, self).__init__(name, expression, short_name)
 
-    def _add_sub_agg(self):
-        self.sum = sum(self.expression)
-        self.count = count(self.expression)
-
     def add_operations(self, agg_task, **kwargs):
-        task_sum = self.sum.add_operations(agg_task, **kwargs)
-        task_count = self.count.add_operations(agg_task, **kwargs)
-        self.dtype_in = self.sum.dtype_in
-        self.dtype_out = self.sum.dtype_out
+        expression = expression_sum = expression = agg_task.df[str(self.expression)]
+        # ints, floats and bools are upcasted
+        if expression_sum.dtype.kind in "buif":
+            expression = expression_sum = expression_sum.astype('float64')
+
+        sum_agg = sum(expression_sum)
+        count_agg = count(expression)
+
+        task_sum = sum_agg.add_operations(agg_task, **kwargs)
+        task_count = count_agg.add_operations(agg_task, **kwargs)
+        self.dtype_in = sum_agg.dtype_in
+        self.dtype_out = sum_agg.dtype_out
+
         @vaex.delayed
         def finish(sum, count):
             dtype = sum.dtype
@@ -101,6 +102,7 @@ class AggregatorDescriptorMean(AggregatorDescriptorMulti):
                 # TODO: not sure why view does not work
                 mean = mean.astype(dtype)
             return mean
+
         return finish(task_sum, task_count)
 
 
@@ -123,7 +125,6 @@ class AggregatorDescriptorVar(AggregatorDescriptorMulti):
         self.dtype_out = sum_.dtype_out
         @vaex.delayed
         def finish(sum_moment, sum, count):
-            # print(self.sum, sum, task_sum)
             dtype = sum.dtype
             if sum.dtype.kind == 'M':
                 sum = sum.view('uint64')
@@ -131,7 +132,6 @@ class AggregatorDescriptorVar(AggregatorDescriptorMulti):
                 count = count.view('uint64')
             with np.errstate(divide='ignore', invalid='ignore'):
                 mean = sum / count
-                print(sum, sum_moment)
                 raw_moments2 = sum_moment/count
                 variance = (raw_moments2 - mean**2) #* count/(count-self.ddof)
             if dtype.kind != mean.dtype.kind:


Test patch:
diff --git a/tests/groupby_test.py b/tests/groupby_test.py
index 7fd0210c..01cbf7a0 100644
--- a/tests/groupby_test.py
+++ b/tests/groupby_test.py
@@ -128,13 +128,13 @@ def test_groupby_datetime_quarter():
 
 def test_groupby_count():
     # ds = ds_local.extract()
-    g = np.array([0, 0, 0, 0, 1, 1, 1, 1, 2, 2], dtype='int32')
+    g = np.array([0, 0, 0, 0, 1, 1, 1, 1, 0, 1], dtype='int32')
     s = np.array(list(map(str, [0, 0, 0, 0, 1, 1, 1, 1, 2, 2])))
     df = vaex.from_arrays(g=g, s=s)
     groupby = df.groupby('s')
     dfg = groupby.agg({'g': 'mean'}).sort('s')
     assert dfg.s.tolist() == ['0', '1', '2']
-    assert dfg.g.tolist() == [0, 1, 2]
+    assert dfg.g.tolist() == [0, 1, 0.5]
 
     dfg2 = df.groupby('s', {'g': 'mean'}).sort('s')
     assert dfg._equals(dfg2)