Internal error: com.databricks.rpc.RPCResponseTooLarge, when attempting to use mosaic's st_intersects
I get an exception when attempting to run the following line of code, which filters a spark DataFrame based on the geometry.df_tx = df_zip.filter(st_intersects(st_aswkt("zip_code_geom"), tx_poly)) df_tx.show()where, `tx_poly` is,`tx_poly = shapely....
- 6088 Views
- 1 replies
- 1 kudos
Latest Reply
I am not familiar with st_intersects, but it seems that it runs solely on the driver (as python code, not spark).Does mosaic work in pyspark?If not: try to use a larger driver.
- 1 kudos