

def _cumulative_to_window(translator, expr, window):
    win = ibis.cumulative_window()
    win = win.group_by(window._group_by).order_by(window._order_by)
    op = expr.op()
    klass = _cumulative_to_reduction[type(op)]
    new_op = klass(*op.args)
    new_expr = expr._factory(new_op, name=expr._name)
    if (type(new_expr) in translator._rewrites):
        new_expr = translator._rewrites[type(new_op)](new_expr)
    new_expr = L.windowize_function(new_expr, win)
    return new_expr

dataset/ETHPy150Open cloudera/ibis/ibis/impala/compiler.py _cumulative_to_window/VarMisuse@87/114 `new_op`->`new_expr`