

@dispatch(Broadcast, Select)
def compute_up(t, s, **kwargs):
    cols = list(inner_columns(s))
    d = dict(((t._scalars[0][c], cols[i]) for (i, c) in enumerate(t._scalars[0].fields)))
    result = compute(i._scalar_expr, d, post_compute=False, return_type='native').label(t._name)
    s = copy(s)
    s.append_column(result)
    return s.with_only_columns([result])

dataset/ETHPy150Open blaze/blaze/blaze/compute/sql.py compute_up/VarMisuse@79/87 `t`->`i`