Class WindowJoinResult

python/pathway/stdlib/temporal/_window_join.py:24–149

Result of a window join between tables. Example: >>> import pathway as pw >>> t1 = pw.debug.table_from_markdown( ... ''' ... | t ... 1 | 1 ... 2 | 2 ... 3 | 3 ... 4 | 7 ... 5 | 13 ... ''' ... ) >>> t2 = pw.debug.table_from_

class WindowJoinResult(DesugaringContext):
    """
    Result of a window join between tables.

    Example:

    >>> import pathway as pw
    >>> t1 = pw.debug.table_from_markdown(
    ...     '''
    ...     | t
    ...   1 | 1
    ...   2 | 2
    ...   3 | 3
    ...   4 | 7
    ...   5 | 13
    ... '''
    ... )
    >>> t2 = pw.debug.table_from_markdown(
    ...     '''
    ...     | t
    ...   1 | 2
    ...   2 | 5
    ...   3 | 6
    ...   4 | 7
    ... '''
    ... )
    >>> join_result = t1.window_join_outer(t2, t1.t, t2.t, pw.temporal.tumbling(2))
    >>> isinstance(join_result, pw.temporal.WindowJoinResult)
    True
    >>> pw.debug.compute_and_print(
    ...     join_result.select(left_t=t1.t, right_t=t2.t), include_id=False
    ... )
    left_t | right_t
           | 5
    1      |
    2      | 2
    3      | 2
    7      | 6
    7      | 7
    13     |
    """

    _join_result: pw.JoinResult
    _table_substitution: dict[pw.TableLike, pw.Table]
    _substitution: dict[ThisMetaclass, pw.Joinable]

    def __init__(
        self,
        join_result: pw.JoinResult,
        left_original: pw.Table,
        right_original: pw.Table,
        left_new: pw.Table,
        right_new: pw.Table,
    ):
        self._join_result = join_result
        self._universe = join_result._universe
        self._table_substitution = {
            left_original: left_new,