Skip to main content

define_inner_star_join

Macro define_inner_star_join 

Source
macro_rules! define_inner_star_join {
    ($n:literal) => { ... };
}
Expand description

Generate a inner_star_joinN function.

Call this macro for every number N in order to generate an N-way inner star join operator for both RootCircuit and NestedCircuit.

The operator computes an incremental join of multiple streams on the same key using a user-provided join function that returns exactly one output value for each input tuple.

Example generated function signature:

impl<K, V1> Stream<RootCircuit, OrdIndexedZSet<K, V1>>
where
    K: DBData,
    V1: DBData,
{
    pub fn inner_star_join4<V2, V3, V4, OV>(
        &self,
        stream2: &Stream<crate::RootCircuit, OrdIndexedZSet<K, V2>>,
        stream3: &Stream<crate::RootCircuit, OrdIndexedZSet<K, V3>>,
        stream4: &Stream<crate::RootCircuit, OrdIndexedZSet<K, V4>>,
        join_func: impl Fn(&K, &V1, &V2, &V3, &V4) -> OV + Clone + 'static,
    ) -> Stream<RootCircuit, OrdZSet<OV>>
    where
        V2: DBData,
        V3: DBData,
        V4: DBData,
        OV: DBData;
}