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.