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;
}