Function _avg

python/pathway/internals/sql/processing.py:112–113

(node: sql_expr.Avg, context: ContextType)

@register(nodetype=sql_expr.Avg)
def _avg(node: sql_expr.Avg, context: ContextType) -> expr.ColumnExpression:
    return reducers.avg(_run(node.this, context))


@register(nodetype=sql_expr.Count)