algeon-cudf 0.1.2

Safe libcudf execution component for Algeon
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50

use super::{AstExpression, Exec, FilterJoinInputs, MixedJoinTables, ResolvedExecution, Result, TableView};

pub(super) fn compatible_join_indices_domain(
    left_keys: &TableView<'_>,
    right_keys: &TableView<'_>,
    ctx: Exec<'_>,
    operation: &'static str,
) -> Result<ResolvedExecution> {
    ResolvedExecution::binary(left_keys.execution_domain(), right_keys.execution_domain(), ctx, operation)
}

pub(super) fn compatible_conditional_join_domain(
    left: &TableView<'_>,
    right: &TableView<'_>,
    predicate: &AstExpression,
    ctx: Exec<'_>,
    operation: &'static str,
) -> Result<ResolvedExecution> {
    let mut secondaries = Vec::new();
    secondaries.push(right.execution_domain());
    predicate.literal_domains(&mut secondaries);
    ResolvedExecution::many(left.execution_domain(), secondaries, ctx, operation)
}

pub(super) fn compatible_mixed_join_domain(
    tables: MixedJoinTables<'_, '_>,
    predicate: &AstExpression,
    ctx: Exec<'_>,
    operation: &'static str,
) -> Result<ResolvedExecution> {
    let mut secondaries = Vec::new();
    secondaries.push(tables.right_equality.execution_domain());
    secondaries.push(tables.left_conditional.execution_domain());
    secondaries.push(tables.right_conditional.execution_domain());
    predicate.literal_domains(&mut secondaries);
    ResolvedExecution::many(tables.left_equality.execution_domain(), secondaries, ctx, operation)
}

pub(super) fn compatible_filter_join_indices_domain(
    inputs: FilterJoinInputs<'_, '_>,
    ctx: Exec<'_>,
    operation: &'static str,
) -> Result<ResolvedExecution> {
    let mut secondaries = Vec::new();
    secondaries.push(inputs.right_indices.execution_domain());
    secondaries.push(inputs.left.execution_domain());
    secondaries.push(inputs.right.execution_domain());
    inputs.predicate.literal_domains(&mut secondaries);
    ResolvedExecution::many(inputs.left_indices.execution_domain(), secondaries, ctx, operation)
}