collect_set/ collect_list Pushdown

[Sam]

Hello,

I've noticed that Collect_Set and Collect_List are not pushed down to the database?

Runtime DB 9.1LTS

Spark 3.1.2

Database: Snowflake

Is there any way to get a distinct set from a group by in a way that will push down the query to the database?

[-werners-]

Hm so collect_set does not get translated to listagg.

Can you try the following?

• use a more recent version of dbrx
• use delta lake as spark source
• use the latest version of the snowflake connector
• check if pushdown to snowflake is enabled