Function _from

python/pathway/internals/sql/processing.py:294–302

(node: sql_expr.From, context: ContextType)

@register(nodetype=sql_expr.From)
def _from(node: sql_expr.From, context: ContextType) -> tuple[table.Table, ContextType]:
    tabs = []
    for expression in node.expressions:
        tab, context = _run(expression, context)
        tabs.append(tab)
    ret = tabs[0]
    for tab in tabs[1:]:
        ret = ret.join(tab)
    return ret, context


@register(nodetype=sql_expr.Subquery)