Skip to main content

join

Class: core · Streaming: accumulating

Hash join. Default type=inner is a plain inner join (never innerunique). type=asof matches the latest right row at or before the left _time.

Signature

| join <right> [type=<enum>] on=<field_list> [tolerance=<duration>]

Positional Arguments

NameTypeRequiredDescription
rightsub_pipelineYeswith $cte or with [ <pipeline> ]

Options

NameTypeDefaultDescription
typeenuminner- Values: inner, left, outer, semi, anti, asof.
onfield_list--
toleranceduration-maximum lag for type=asof

Examples

join type=left on user_id with [from users]
join type=anti on user_id with [from allowlist]
join type=asof on host tolerance=30s with [from deploys]

Generated from the LynxFlow registry. See RFC-002 for the full language specification.