CREATE TABLE IF NOT EXISTS movies.movies_narratives_embeddings(
id STRING,
narrative STRING,
__embedding ARRAY<FLOAT>
) TBLPROPERTIES (delta.enableChangeDataFeed = true)
# materialize the table
embeddings_table_name = "movies.movies_narratives_embeddings"
df_emd.write.mode("overwrite").saveAsTable(embeddings_table_name)