Struct QuadConstraintStream 

pub struct QuadConstraintStream<S, A, K, E, KE, F, Sc>
where
    Sc: Score,
{ /* private fields */ }

Implementations

impl<S, A, K, E, KE, Sc> QuadConstraintStream<S, A, K, E, KE, TrueFilter, Sc>

where S: Send + Sync + 'static, A: Clone + Hash + PartialEq + Send + Sync + 'static, K: Eq + Hash + Clone + Send + Sync, E: CollectionExtract<S, Item = A>, KE: KeyExtract<S, A, K>, Sc: Score + 'static,

pub fn new_self_join(extractor: E, key_extractor: KE) -> Self

impl<S, A, K, E, KE, F, Sc> QuadConstraintStream<S, A, K, E, KE, F, Sc>

where S: Send + Sync + 'static, A: Clone + Hash + PartialEq + Send + Sync + 'static, K: Eq + Hash + Clone + Send + Sync, E: CollectionExtract<S, Item = A>, KE: KeyExtract<S, A, K>, F: QuadFilter<S, A, A, A, A>, Sc: Score + 'static,

pub fn new_self_join_with_filter( extractor: E, key_extractor: KE, filter: F, ) -> Self

pub fn filter<P>( self, predicate: P, ) -> QuadConstraintStream<S, A, K, E, KE, AndQuadFilter<F, FnQuadFilter<impl Fn(&S, &A, &A, &A, &A, usize, usize, usize, usize) -> bool + Send + Sync>>, Sc>

where P: Fn(&A, &A, &A, &A) -> bool + Send + Sync + 'static,

pub fn group_by<GK, GF, Co, V, R, Acc>( self, key: GF, collector: Co, ) -> JoinedGroupedStream<S, FilterNode<SelfJoinNode<S, A, CollectionNode<S, E>, K, KE, 4>, impl Fn(&S, &[Leaf<'_, A>; 4]) -> bool + Send + Sync>, impl Fn(&[Leaf<'_, A>; 4]) -> GK + Send + Sync, TupleCollector<Co, V, R, Acc>, GK, V, R, Acc, Sc>

where E: 'static, KE: 'static, F: 'static, K: 'static, GK: Eq + Hash + Clone + Send + Sync + 'static, GF: Fn(&A, &A, &A, &A) -> GK + Send + Sync + 'static, Co: for<'i> Collector<(&'i A, &'i A, &'i A, &'i A), Value = V, Result = R, Accumulator = Acc> + 'static, V: Send + Sync + 'static, R: Send + Sync + 'static, Acc: Accumulator<V, R> + 'static, for<'i> TupleCollector<Co, V, R, Acc>: Collector<[Leaf<'i, A>; 4], Value = V, Result = R, Accumulator = Acc>,

Groups each matching tuple, preserving upstream filters.

pub fn penalize<W>( self, weight: W, ) -> QuadConstraintBuilder<S, A, K, E, KE, F, impl Fn(&A, &A, &A, &A) -> Sc + Send + Sync, Sc>

where W: for<'w> ConstraintWeight<(&'w A, &'w A, &'w A, &'w A), Sc> + Send + Sync,

pub fn reward<W>( self, weight: W, ) -> QuadConstraintBuilder<S, A, K, E, KE, F, impl Fn(&A, &A, &A, &A) -> Sc + Send + Sync, Sc>

where W: for<'w> ConstraintWeight<(&'w A, &'w A, &'w A, &'w A), Sc> + Send + Sync,

impl<S, A, K, E, KE, F, Sc> QuadConstraintStream<S, A, K, E, KE, F, Sc>

where S: Send + Sync + 'static, A: Clone + Hash + PartialEq + Send + Sync + 'static, K: Eq + Hash + Clone + Send + Sync, E: CollectionExtract<S, Item = A>, KE: Fn(&S, &A, usize) -> K + Send + Sync, F: QuadFilter<S, A, A, A, A>, Sc: Score + 'static,

pub fn join<J>( self, joiner: J, ) -> PentaConstraintStream<S, A, K, E, KE, impl PentaFilter<S, A, A, A, A, A>, Sc>

where J: Joiner<A, A> + 'static, F: 'static,

Trait Implementations

impl<S, A, K, E, KE, F, Sc: Score> Debug for QuadConstraintStream<S, A, K, E, KE, F, Sc>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.