diff --git a/datafusion/sqllogictest/src/test_context.rs b/datafusion/sqllogictest/src/test_context.rs index 0d59fb826a2f..2466303c32a9 100644 --- a/datafusion/sqllogictest/src/test_context.rs +++ b/datafusion/sqllogictest/src/test_context.rs @@ -106,6 +106,8 @@ impl TestContext { let example_udf = create_example_udf(); test_ctx.ctx.register_udf(example_udf); register_partition_table(&mut test_ctx).await; + info!("Registering table with many types"); + register_table_with_many_types(test_ctx.session_ctx()).await; } "metadata.slt" => { info!("Registering metadata table tables"); diff --git a/datafusion/sqllogictest/test_files/joins.slt b/datafusion/sqllogictest/test_files/joins.slt index d45dbc7ee1ae..e636e93007a4 100644 --- a/datafusion/sqllogictest/test_files/joins.slt +++ b/datafusion/sqllogictest/test_files/joins.slt @@ -4292,3 +4292,24 @@ query T select * from table1 as t1 natural join table1_stringview as t2; ---- foo + +query TT +EXPLAIN SELECT count(*) +FROM my_catalog.my_schema.table_with_many_types AS l +JOIN my_catalog.my_schema.table_with_many_types AS r ON l.binary_col = r.binary_col +---- +logical_plan +01)Aggregate: groupBy=[[]], aggr=[[count(Int64(1)) AS count(*)]] +02)--Projection: +03)----Inner Join: l.binary_col = r.binary_col +04)------SubqueryAlias: l +05)--------TableScan: my_catalog.my_schema.table_with_many_types projection=[binary_col] +06)------SubqueryAlias: r +07)--------TableScan: my_catalog.my_schema.table_with_many_types projection=[binary_col] +physical_plan +01)AggregateExec: mode=Single, gby=[], aggr=[count(*)] +02)--ProjectionExec: expr=[] +03)----CoalesceBatchesExec: target_batch_size=3 +04)------HashJoinExec: mode=CollectLeft, join_type=Inner, on=[(binary_col@0, binary_col@0)] +05)--------MemoryExec: partitions=1, partition_sizes=[1] +06)--------MemoryExec: partitions=1, partition_sizes=[1]