

@dispatch((nunique, Reduction), Select)
def compute_up(expr, data, **kwargs):
    if (expr.axis != (0,)):
        raise ValueError('axis not equal to 0 not defined for SQL reductions')
    data = data.alias(name=next(aliases))
    cols = list(inner_columns(data))
    d = dict(((expr._child[c], cols[i]) for (i, c) in enumerate(expr._child.fields)))
    return select([compute(expr, d, post_compute=False, return_type='native')])

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