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

Method input

datafusion/datasource/src/sink.rs:133–135  ·  view source on GitHub ↗

Input execution plan

(&self)

Source from the content-addressed store, hash-verified

131
132 /// Input execution plan
133 pub fn input(&self) -> &Arc<dyn ExecutionPlan> {
134 &self.input
135 }
136
137 /// Returns insert sink
138 pub fn sink(&self) -> &dyn DataSink {

Callers 7

find_projectionFunction · 0.45
test_join_with_swapFunction · 0.45
test_nl_join_with_swapFunction · 0.45
check_join_partition_modeFunction · 0.45
test_join_with_maybe_swap_unbounded_caseFunction · 0.45
rewriteMethod · 0.45
validateMethod · 0.45

Calls

no outgoing calls

Tested by 4

test_join_with_swapFunction · 0.36
test_nl_join_with_swapFunction · 0.36
check_join_partition_modeFunction · 0.36
test_join_with_maybe_swap_unbounded_caseFunction · 0.36