

@dispatch(Selection, sa.sql.ColumnElement)
def compute_up(expr, data, scope=None, **kwargs):
    predicate = compute(expr.predicate, data, post_compute=False, return_type='native')
    return compute(expr, {
        expr._child: data,
        expr.predicate: predicate,
    }, return_type='native', **kwargs)

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