

@dispatch(Projection, Select)
def compute_up(expr, data, **kwargs):
    d = dict(((c.name, c) for c in getattr(data, 'inner_columns', data.c)))
    return data.with_only_columns([d[field] for field in expr.fields])

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