A Ivanovic
10/30/2024, 7:01 PMColin Ho
10/30/2024, 11:30 PMiter or iter_partitions and specify the results_buffer_size to be a value less than the number of CPUs. https://www.getdaft.io/projects/docs/en/stable/api_docs/doc_gen/dataframe_methods/daft.DataFrame.iter_partitions.html#daft.DataFrame.iter_partitions
• specify resource requests on ur UDF (if you are using one) https://www.getdaft.io/projects/docs/en/stable/user_guide/udf.html#resource-requests
• Split up your dataframe into smaller partitions via into_partitions https://www.getdaft.io/projects/docs/en/stable/api_docs/doc_gen/dataframe_methods/daft.DataFrame.into_partitions.html#daft-dataframe-into-partitions