David
06/07/2020, 3:56 PMsandy
06/07/2020, 9:12 PMDoes that answer your question? There are a bunch of concepts involved - I can explain in more detail if it would be helpful, which is adagster_pyspark.DataFrame
knows how to save and load PySpark DataFrames.DagsterType
tells Dagster that when a solid has a return type annotation for a,make_python_type_usable_as_dagster_type
, then Dagster should use thepyspark.sql.DataFrame
to save and load it.dagster_pyspark.DataFrame
David
06/08/2020, 5:23 AMsandy
06/08/2020, 3:04 PMDavid
06/08/2020, 3:18 PM