Method __init__

python/pathway/internals/groupbys.py:284–304

(
        self,
        _join_result: JoinResult,
        _args: Iterable[expr.ColumnExpression],
        _id: expr.ColumnReference | None,
    )

    _groupby: GroupedTable

    def __init__(
        self,
        _join_result: JoinResult,
        _args: Iterable[expr.ColumnExpression],
        _id: expr.ColumnReference | None,
    ):
        super().__init__(
            _join_result._universe,
            {
                **_join_result._substitution,
                thisclass.this: _join_result,
            },
            _join_result,
        )
        tab, subs = _join_result._substitutions()
        self._substitution_desugaring = SubstitutionDesugaring(subs)
        _args = [self._substitution_desugaring.eval_expression(arg) for arg in _args]
        if _id is not None:
            _id = self._substitution_desugaring.eval_expression(_id)

        self._groupby = tab.groupby(*_args, id=_id)

    @desugar
    @arg_handler(handler=reduce_args_handler)