Module stream_join 

Stream-to-stream temporal joins for geospatial data.

Supports:

• Inner join: emit a pair when both streams have a matching key and their timestamps are within time_tolerance of each other.
• Left outer join (mode variant): same as inner, but the joiner also tracks which left-stream events were emitted without a right-side match (accessible via unmatched_left).
• Interval join: join when right.time + lower ≤ left.time ≤ right.time + upper.

Buffers are bounded: when max_buffer_size is reached, the oldest entry is evicted before inserting the new one.

Structs

JoinEvent

A timestamped event suitable for joining.

JoinedPair

A successfully joined pair from the left and right streams.

TemporalJoinConfig

Configuration for the temporal stream joiner.

TemporalJoiner

Bidirectional temporal stream joiner.

Enums

JoinMode

Which join semantics to apply.