Class AsofJoinResult

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

Result of an ASOF join of two tables Example: >>> import pathway as pw >>> >>> t1 = pw.debug.table_from_markdown( ... ''' ... | K | val | t ... 1 | 0 | 1 | 1 ... 2 | 0 | 2 | 4 ... 3 | 0 | 3 | 5 ... 4 | 0 | 4 |

class AsofJoinResult(DesugaringContext):
    """Result of an ASOF join of two tables

    Example:

    >>> import pathway as pw
    >>>
    >>> t1 = pw.debug.table_from_markdown(
    ...     '''
    ...         | K | val |  t
    ...     1   | 0 | 1   |  1
    ...     2   | 0 | 2   |  4
    ...     3   | 0 | 3   |  5
    ...     4   | 0 | 4   |  6
    ...     5   | 0 | 5   |  7
    ...     6   | 0 | 6   |  11
    ...     7   | 0 | 7   |  12
    ...     8   | 1 | 8   |  5
    ...     9   | 1 | 9   |  7
    ... '''
    ... )
    >>>
    >>> t2 = pw.debug.table_from_markdown(
    ...     '''
    ...          | K | val | t
    ...     21   | 1 | 7  | 2
    ...     22   | 1 | 3  | 8
    ...     23   | 0 | 0  | 2
    ...     24   | 0 | 6  | 3
    ...     25   | 0 | 2  | 7
    ...     26   | 0 | 3  | 8
    ...     27   | 0 | 9  | 9
    ...     28   | 0 | 7  | 13
    ...     29   | 0 | 4  | 14
    ...     '''
    ... )
    >>> res = t1.asof_join(
    ...     t2,
    ...     t1.t,
    ...     t2.t,
    ...     t1.K == t2.K,
    ...     how=pw.JoinMode.LEFT,
    ...     defaults={t2.val: -1},
    ... ).select(
    ...     pw.this.instance,
    ...     pw.this.t,
    ...     val_left=t1.val,
    ...     val_right=t2.val,
    ...     sum=t1.val + t2.val,
    ... )
    >>> pw.debug.compute_and_print(res, include_id=False)
    instance | t  | val_left | val_right | sum
    0        | 1  | 1        | -1        | 0
    0        | 4  | 2        | 6         | 8
    0        | 5  | 3        | 6         | 9
    0        | 6  | 4        | 6         | 10
    0        | 7  | 5        | 2         | 7
    0        | 11 | 6        | 9         | 15