noctis.data_transformation.preprocessing.utilities._save_dataframes_to_partition_csv¶
- noctis.data_transformation.preprocessing.utilities._save_dataframes_to_partition_csv(dict_nodes: dict[str, DataFrame], dict_relationships: dict[str, DataFrame], graph_schema: GraphSchema, output_dir: str, partition_num: int) None[source]¶
Save node and relationship DataFrames to partitioned CSV files.
- Args:
dict_nodes (dict[str, pd.DataFrame]): Dictionary of node DataFrames. dict_relationships (dict[str, pd.DataFrame]): Dictionary of relationship DataFrames. graph_schema (GraphSchema): Schema to determine labels and types. output_dir (str): Directory to save the partitioned CSV files. partition_num (int): Partition number for file naming.
- Note:
CSV files are saved in a directory specific to the partition number.