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

Method left_right

datafusion/core/tests/fuzz_cases/join_fuzz.rs:801–817  ·  view source on GitHub ↗
(&self)

Source from the content-addressed store, hash-verified

799 }
800
801 fn left_right(&self) -> (Arc<DataSourceExec>, Arc<DataSourceExec>) {
802 let schema1 = self.input1[0].schema();
803 let schema2 = self.input2[0].schema();
804 let left = MemorySourceConfig::try_new_exec(
805 std::slice::from_ref(&self.input1),
806 schema1,
807 None,
808 )
809 .unwrap();
810 let right = MemorySourceConfig::try_new_exec(
811 std::slice::from_ref(&self.input2),
812 schema2,
813 None,
814 )
815 .unwrap();
816 (left, right)
817 }
818
819 fn join_filter(&self) -> Option<JoinFilter> {
820 let schema1 = self.input1[0].schema();

Callers 3

sort_merge_joinMethod · 0.80
hash_joinMethod · 0.80
nested_loop_joinMethod · 0.80

Calls 1

schemaMethod · 0.45

Tested by

no test coverage detected