

@compute_up.register(BinaryMath, Select, Select)
def binary_math_sql_select(t, lhs, rhs, **kwargs):
    (left, right) = (first(lhs.inner_columns), first(rhs.inner_columns))
    result = getattr(sa.func, type(t).__name__)(left, right)
    assert (lhs.table == rhs.table)
    return reconstruct_select([result], lhs.table)

dataset/ETHPy150Open blaze/blaze/blaze/compute/sql.py binary_math_sql_select/original