

def test_summary():
    ((chunk, chunk_expr), (agg, agg_expr)) = split(t, summary(a=t.amount.count(), b=(t.id.sum() + 1)))
    assert (chunk.schema == t.schema)
    assert chunk_expr.isidentical(summary(a=chunk.amount.count(), b=chunk.id.sum(), keepdims=True))
    assert agg_expr.isidentical(summary(a=agg.a.sum(), b=(agg.b.sum() + 1)))
    ((chunk, chunk_expr), (agg, agg_expr)) = split(t, summary(total=t.amount.sum()))
    assert chunk_expr.isidentical(summary(total=chunk.amount.sum(), keepdims=True))
    assert agg_expr.isidentical(summary(total=agg.total.sum()))

dataset/ETHPy150Open blaze/blaze/blaze/expr/tests/test_split.py test_summary/original