MCPcopy Index your code
hub / github.com/pathwaycom/pathway / _joins_block

Function _joins_block

python/pathway/internals/sql/processing.py:619–626  ·  view source on GitHub ↗
(
    node: sql_expr.Expression, tab: table.Joinable, context: ContextType
)

Source from the content-addressed store, hash-verified

617
618
619def _joins_block(
620 node: sql_expr.Expression, tab: table.Joinable, context: ContextType
621) -> tuple[table.Joinable, ContextType]:
622 if (joins_field := node.args.pop("joins", None)) is not None:
623 for arg in joins_field:
624 fun = _join(arg, context)
625 tab, context = fun(tab, context)
626 return tab, context
627
628
629def _alias_block(

Callers 2

_tableFunction · 0.85
_selectFunction · 0.85

Calls 2

_joinFunction · 0.85
funFunction · 0.50

Tested by

no test coverage detected