Method select

python/pathway/stdlib/temporal/_asof_join.py:408–418

(self, *args: pw.ColumnReference, **kwargs: Any)

    @arg_handler(handler=select_args_handler)
    @trace_user_frame
    def select(self, *args: pw.ColumnReference, **kwargs: Any) -> pw.Table:
        if self._mode not in [pw.JoinMode.LEFT, pw.JoinMode.RIGHT, pw.JoinMode.OUTER]:
            raise ValueError(f"Unsupported asof join mode: {self._mode}")

        expressions: dict[str, expr.ColumnExpression] = {}

        all_args = combine_args_kwargs(args, kwargs)

        for new_name, expression in all_args.items():
            expressions[new_name] = self._sub_desugaring.eval_expression(expression)
        return self._merge_result.select(**expressions)


def _asof_join(