MCPcopy Create free account
hub / github.com/apache/datafusion / nullify_fields

Function nullify_fields

datafusion/expr/src/logical_plan/builder.rs:1667–1677  ·  view source on GitHub ↗
(
        fields: impl Iterator<Item = (Option<&'a TableReference>, &'a Arc<Field>)>,
    )

Source from the content-addressed store, hash-verified

1665 join_type: &JoinType,
1666) -> Result<DFSchema> {
1667 fn nullify_fields<'a>(
1668 fields: impl Iterator<Item = (Option<&'a TableReference>, &'a Arc<Field>)>,
1669 ) -> Vec<(Option<TableReference>, Arc<Field>)> {
1670 fields
1671 .map(|(q, f)| {
1672 // TODO: find a good way to do that
1673 let field = f.as_ref().clone().with_nullable(true);
1674 (q.cloned(), Arc::new(field))
1675 })
1676 .collect()
1677 }
1678
1679 let right_fields = right.iter();
1680 let left_fields = left.iter();

Callers 1

build_join_schemaFunction · 0.85

Calls 7

newFunction · 0.85
collectMethod · 0.80
mapMethod · 0.45
with_nullableMethod · 0.45
cloneMethod · 0.45
as_refMethod · 0.45
clonedMethod · 0.45

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…