collect_set/ collect_list Pushdown

Sam
New Contributor III

‎12-02-2021 03:53 PM

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?

Labels:

-werners-
Esteemed Contributor III

‎12-02-2021 11:29 PM

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