Struct mz_compute::render::join::linear_join::LinearJoinSpec

pub struct LinearJoinSpec {
    implementation: LinearJoinImpl,
    yielding: YieldSpec,
}

Specification of how linear joins are to be executed.

Note that currently yielding only affects the Materialize join implementation, as the DD join doesn’t allow configuring its yielding behavior. Merging #390 would fix this.

Fields

implementation: LinearJoinImpl

yielding: YieldSpec

Implementations

impl LinearJoinSpec

pub fn from_config(config: &ConfigSet) -> Self

Create a LinearJoinSpec based on the given config.

fn render<G, Tr1, Tr2, L, I>( &self, arranged1: &Arranged<G, Tr1>, arranged2: &Arranged<G, Tr2>, shutdown_token: ShutdownToken, result: L, ) -> Collection<G, I::Item, Diff>

where G: Scope, G::Timestamp: Lattice, Tr1: TraceReader<Time = G::Timestamp, Diff = Diff> + Clone + 'static, Tr2: for<'a> TraceReader<Key<'a> = Tr1::Key<'a>, Time = G::Timestamp, Diff = Diff> + Clone + 'static, L: FnMut(Tr1::Key<'_>, Tr1::Val<'_>, Tr2::Val<'_>) -> I + 'static, I: IntoIterator, I::Item: Data,

Render a join operator according to this specification.

Trait Implementations

impl Clone for LinearJoinSpec

fn clone(&self) -> LinearJoinSpec

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for LinearJoinSpec

fn default() -> Self

Returns the “default value” for a type.

impl Copy for LinearJoinSpec