

def test_mean():
    ((chunk, chunk_expr), (agg, agg_expr)) = split(t, t.amount.mean())
    assert (chunk_expr.schema == t.schema)
    assert chunk_expr.isidentical(summary(total=chunk.amount.sum(), count=chunk.amount.count(), keepdims=True))
    assert isrecord(agg.dshape.measure)
    assert agg_expr.isidentical((agg.total.sum() / agg['count'].sum()))

dataset/ETHPy150Open blaze/blaze/blaze/expr/tests/test_split.py test_mean/VarMisuse@38/44 `chunk`->`chunk_expr`